This ensures that object is not cleaned up, triggering a disconnect before we get back
the audit messages. Otherwise they can be lost when the server task calls exit()
while the message thread is still trying to send them.
Signed-off-by: Andrew Bartlett <abartlet@samba.org>
Reviewed-by: Garming Sam <garming@catalyst.net.nz>
binding = "[%s]" % binding
if service == "dnsserver":
binding = "[%s]" % binding
if service == "dnsserver":
- dnsserver.dnsserver("ncacn_ip_tcp:%s%s" % (self.server, binding),
- self.get_loadparm(),
- creds)
+ conn = dnsserver.dnsserver("ncacn_ip_tcp:%s%s" % (self.server, binding),
+ self.get_loadparm(),
+ creds)
elif service == "srvsvc":
elif service == "srvsvc":
- srvsvc.srvsvc("ncacn_ip_tcp:%s%s" % (self.server, binding),
- self.get_loadparm(),
- creds)
+ conn = srvsvc.srvsvc("ncacn_ip_tcp:%s%s" % (self.server, binding),
+ self.get_loadparm(),
+ creds)
- messages = self.waitForMessages(isLastExpectedMessage)
+ messages = self.waitForMessages(isLastExpectedMessage, conn)
checkFunction(messages, authTypes, service, binding, protection)
def rpc_ncacn_ip_tcp_ntlm_check(self, messages, authTypes, service,
checkFunction(messages, authTypes, service, binding, protection)
def rpc_ncacn_ip_tcp_ntlm_check(self, messages, authTypes, service,
(validation, authoritative, netr_flags_out) = result
(validation, authoritative, netr_flags_out) = result
- messages = self.waitForMessages(isLastExpectedMessage)
+ messages = self.waitForMessages(isLastExpectedMessage, netlogon_conn)
checkFunction(messages)
def samlogon_check(self, messages):
checkFunction(messages)
def samlogon_check(self, messages):