import struct
from samba import gensec
from samba.tests.dcerpc.raw_testcase import RawDCERPCTest
+from samba.compat import binary_type
global_ndr_print = False
global_hexdump = False
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# And now try a request
req = self.generate_request(call_id=1,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# And now try a alter context
req = self.generate_alter(call_id=0, pfc_flags=req_pfc_flags, ctx_list=[ctx1])
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# And now try a request
req = self.generate_request(call_id=1,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.versions[0].rpc_vers, req.rpc_vers)
self.assertEquals(rep.u.versions[0].rpc_vers_minor, req.rpc_vers_minor)
self.assertEquals(len(rep.u._pad), 3)
- self.assertEquals(rep.u._pad, '\0' * 3)
+ self.assertEquals(rep.u._pad, b'\0' * 3)
def test_invalid_auth_noctx(self):
req = self.generate_bind(call_id=0)
self.assertEquals(rep.u.versions[0].rpc_vers, req.rpc_vers)
self.assertEquals(rep.u.versions[0].rpc_vers_minor, req.rpc_vers_minor)
self.assertEquals(len(rep.u._pad), 3)
- self.assertEquals(rep.u._pad, '\0' * 3)
+ self.assertEquals(rep.u._pad, b'\0' * 3)
def test_no_auth_valid_valid_request(self):
ndr32 = base.transfer_syntax_ndr()
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# Send a bind again
tsf2_list = [ndr32]
self.assertEquals(rep.u.versions[0].rpc_vers, req.rpc_vers)
self.assertEquals(rep.u.versions[0].rpc_vers_minor, req.rpc_vers_minor)
self.assertEquals(len(rep.u._pad), 3)
- self.assertEquals(rep.u._pad, '\0' * 3)
+ self.assertEquals(rep.u._pad, b'\0' * 3)
# wait for a disconnect
rep = self.recv_pdu()
self.assertEquals(rep.u.versions[0].rpc_vers, req.rpc_vers)
self.assertEquals(rep.u.versions[0].rpc_vers_minor, req.rpc_vers_minor)
self.assertEquals(len(rep.u._pad), 3)
- self.assertEquals(rep.u._pad, '\0' * 3)
+ self.assertEquals(rep.u._pad, b'\0' * 3)
# wait for a disconnect
rep = self.recv_pdu()
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# Send a alter
req = self.generate_alter(call_id=1, ctx_list=[])
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# Send a alter
req = self.generate_alter(call_id=1, ctx_list=[ctx1])
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=2,
context_id=ctx1.context_id,
opnum=0xffff,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_FAULT, req.call_id,
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_PROVIDER_REJECTION)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_ABSTRACT_SYNTAX_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# Send a alter
req = self.generate_alter(call_id=1, ctx_list=[ctx1])
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_ABSTRACT_SYNTAX_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=2,
context_id=12345,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_FAULT, req.call_id,
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_ABSTRACT_SYNTAX_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
def test_no_auth_presentation_ctx_invalid2(self):
ndr32 = base.transfer_syntax_ndr()
self.assertEquals(rep.u.versions[0].rpc_vers, req.rpc_vers)
self.assertEquals(rep.u.versions[0].rpc_vers_minor, req.rpc_vers_minor)
self.assertEquals(len(rep.u._pad), 3)
- self.assertEquals(rep.u._pad, '\0' * 3)
+ self.assertEquals(rep.u._pad, b'\0' * 3)
# wait for a disconnect
rep = self.recv_pdu()
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
tsf1b_list = []
ctx1b = dcerpc.ctx_list()
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# With a known but wrong syntax we get a protocol error
# see test_no_auth_presentation_ctx_valid2
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# With a unknown but wrong syntaxes we get NO protocol error
# see test_no_auth_presentation_ctx_invalid4
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_TRANSFER_SYNTAXES_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=2,
context_id=ctx1a.context_id,
opnum=0xffff,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_FAULT, req.call_id,
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_PROVIDER_REJECTION)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_ABSTRACT_SYNTAX_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
tsf0_list = [ndr32]
ctx0 = dcerpc.ctx_list()
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=1,
context_id=ctx0.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=1,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=1,
context_id=ctx2.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.ctx_list[1].reason,
dcerpc.DCERPC_BIND_ACK_REASON_TRANSFER_SYNTAXES_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[1].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=1,
context_id=ctx3.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.ctx_list[1].reason,
dcerpc.DCERPC_BIND_ACK_REASON_TRANSFER_SYNTAXES_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[1].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=1,
context_id=ctx4.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
req = self.generate_request(call_id=1,
context_id=ctx3.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.ctx_list[1].reason,
dcerpc.DCERPC_BIND_ACK_REASON_TRANSFER_SYNTAXES_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[1].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=1,
context_id=ctx4.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
req = self.generate_request(call_id=1,
context_id=ctx3.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.ctx_list[1].reason,
dcerpc.DCERPC_BIND_ACK_REASON_TRANSFER_SYNTAXES_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[1].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=1,
context_id=ctx5mgmt.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.ctx_list[1].reason,
dcerpc.DCERPC_BIND_ACK_REASON_TRANSFER_SYNTAXES_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[1].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
req = self.generate_request(call_id=1,
context_id=ctx5mgmt.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_NEGOTIATE_ACK)
self.assertEquals(rep.u.ctx_list[0].reason, features)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
def test_no_auth_bind_time_none_ignore_additional(self):
features1 = 0
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_NEGOTIATE_ACK)
self.assertEquals(rep.u.ctx_list[0].reason, features1)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
def test_no_auth_bind_time_only_first(self):
features1 = dcerpc.DCERPC_BIND_TIME_KEEP_CONNECTION_ON_ORPHAN
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_PROVIDER_REJECTION)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_ABSTRACT_SYNTAX_NOT_SUPPORTED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
def test_no_auth_bind_time_twice(self):
features1 = dcerpc.DCERPC_BIND_TIME_KEEP_CONNECTION_ON_ORPHAN
self.assertEquals(rep.u.versions[0].rpc_vers, req.rpc_vers)
self.assertEquals(rep.u.versions[0].rpc_vers_minor, req.rpc_vers_minor)
self.assertEquals(len(rep.u._pad), 3)
- self.assertEquals(rep.u._pad, '\0' * 3)
+ self.assertEquals(rep.u._pad, b'\0' * 3)
# wait for a disconnect
rep = self.recv_pdu()
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_NEGOTIATE_ACK)
self.assertEquals(rep.u.ctx_list[0].reason, features)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
def test_no_auth_bind_time_keep_on_orphan_ignore_additional(self):
features1 = dcerpc.DCERPC_BIND_TIME_KEEP_CONNECTION_ON_ORPHAN
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_NEGOTIATE_ACK)
self.assertEquals(rep.u.ctx_list[0].reason, features1)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, zero_syntax)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
def _test_auth_type_level_bind_nak(self, auth_type, auth_level, creds=None,
reason=dcerpc.DCERPC_BIND_NAK_REASON_INVALID_AUTH_TYPE):
auth_level=auth_level,
auth_context_id=auth_context_id,
g_auth_level=dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY)
- from_server = ""
+ from_server = b""
(finished, to_server) = auth_context["gensec"].update(from_server)
self.assertFalse(finished)
auth_context_id=auth_context["auth_context_id"],
auth_blob=to_server)
else:
- to_server = "none"
+ to_server = b"none"
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
auth_context_id=auth_context_id,
self.assertEquals(rep.u.versions[0].rpc_vers, req.rpc_vers)
self.assertEquals(rep.u.versions[0].rpc_vers_minor, req.rpc_vers_minor)
self.assertEquals(len(rep.u._pad), 3)
- self.assertEquals(rep.u._pad, '\0' * 3)
+ self.assertEquals(rep.u._pad, b'\0' * 3)
# wait for a disconnect
rep = self.recv_pdu()
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
req = self.generate_request(call_id=2,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
auth_context_id=auth_context_id,
- auth_blob="none")
+ auth_blob=b"none")
req = self.generate_request(call_id=3,
context_id=ctx1.context_id,
opnum=0,
- stub="",
+ stub=b"",
auth_info=auth_info)
self.send_pdu(req)
rep = self.recv_pdu()
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
assoc_group_id = rep.u.assoc_group_id
if alter_xmit is None:
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
chunk_size = rep_both - dcerpc.DCERPC_REQUEST_LENGTH
req = self.generate_request(call_id=2,
context_id=ctx1.context_id,
opnum=0,
alloc_hint=0xffffffff,
- stub="\00" * chunk_size)
+ stub=b"\00" * chunk_size)
self.send_pdu(req, ndr_print=True, hexdump=True)
rep = self.recv_pdu(ndr_print=True, hexdump=True)
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
context_id=ctx1.context_id,
opnum=0,
alloc_hint=0xffffffff,
- stub="\00" * chunk_size)
+ stub=b"\00" * chunk_size)
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
context_id=ctx1.context_id,
opnum=0,
alloc_hint=0xffffffff,
- stub="\00" * chunk_size)
+ stub=b"\00" * chunk_size)
self.send_pdu(req)
rep = self.recv_pdu()
# We get a fault
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
self.assertEquals(rep.u.ctx_list[0].reason,
dcerpc.DCERPC_BIND_ACK_REASON_NOT_SPECIFIED)
self.assertNDRSyntaxEquals(rep.u.ctx_list[0].syntax, ndr32)
- self.assertEquals(rep.u.auth_info, '\0' * 0)
+ self.assertEquals(rep.u.auth_info, b'\0' * 0)
# And now try a request without auth_info
req = self.generate_request(call_id=2,
context_id=ctx.context_id,
opnum=0,
alloc_hint=0xffffffff,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
context_id=ctx.context_id,
opnum=1,
alloc_hint=0xffffffff,
- stub="\04\00\00\00\00\00\00\00")
+ stub=b"\04\00\00\00\00\00\00\00")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
context_id=ctx.context_id,
opnum=1,
alloc_hint=1,
- stub="\04\00\00\00\00\00\00\00")
+ stub=b"\04\00\00\00\00\00\00\00")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
epmap=True, return_ack=True)
server = '\\\\' + self.target_hostname
- server_utf16 = unicode(server, 'utf-8').encode('utf-16-le')
+ if isinstance(server, binary_type):
+ server_utf16 = server.decode('utf-8').encode('utf-16-le')
+ else:
+ server_utf16 = server.encode('utf-16-le')
computer = 'UNKNOWNCOMPUTER'
- computer_utf16 = unicode(computer, 'utf-8').encode('utf-16-le')
+ if isinstance(server, binary_type):
+ computer_utf16 = computer.decode('utf-8').encode('utf-16-le')
+ else:
+ computer_utf16 = computer.encode('utf-16-le')
real_stub = struct.pack('<IIII', 0x00200000,
len(server) + 1, 0, len(server) + 1)
- real_stub += server_utf16 + '\x00\x00'
+ real_stub += server_utf16 + b'\x00\x00'
mod_len = len(real_stub) % 4
if mod_len != 0:
- real_stub += '\x00' * (4 - mod_len)
+ real_stub += b'\x00' * (4 - mod_len)
real_stub += struct.pack('<III',
len(computer) + 1, 0, len(computer) + 1)
- real_stub += computer_utf16 + '\x00\x00'
- real_stub += '\x11\x22\x33\x44\x55\x66\x77\x88'
+ real_stub += computer_utf16 + b'\x00\x00'
+ real_stub += b'\x11\x22\x33\x44\x55\x66\x77\x88'
return (ctx, ack, real_stub)
if first:
pfc_flags |= dcerpc.DCERPC_PFC_FLAG_FIRST
first = False
- stub = real_stub + '\x00' * (thistime - len(real_stub))
+ stub = real_stub + b'\x00' * (thistime - len(real_stub))
else:
- stub = "\x00" * thistime
+ stub = b"\x00" * thistime
if remaining == 0:
pfc_flags |= dcerpc.DCERPC_PFC_FLAG_LAST
req = self.generate_request(call_id=1,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
pfc_flags=dcerpc.DCERPC_PFC_FLAG_FIRST,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu(timeout=0.01)
self.assertIsNone(rep)
pfc_flags=dcerpc.DCERPC_PFC_FLAG_LAST,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
req = self.generate_request(call_id=2,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
req = self.generate_request(call_id=1,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
pfc_flags=dcerpc.DCERPC_PFC_FLAG_FIRST,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu(timeout=0.1)
self.assertIsNone(rep)
pfc_flags=dcerpc.DCERPC_PFC_FLAG_LAST,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
req = self.generate_request(call_id=2,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
pfc_flags=dcerpc.DCERPC_PFC_FLAG_FIRST,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu(timeout=0.1)
self.assertIsNone(rep)
pfc_flags=dcerpc.DCERPC_PFC_FLAG_LAST,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
req = self.generate_request(call_id=2,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
pfc_flags=dcerpc.DCERPC_PFC_FLAG_FIRST,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req1)
rep = self.recv_pdu(timeout=0.1)
self.assertIsNone(rep)
req2 = self.generate_request(call_id=2,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req2)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_FAULT, req1.call_id,
pfc_flags=dcerpc.DCERPC_PFC_FLAG_FIRST,
context_id=ctx.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req1)
rep = self.recv_pdu(timeout=0.1)
self.assertIsNone(rep)
req2 = self.generate_request(call_id=2,
context_id=ctx.context_id - 1,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req2)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_FAULT, req2.call_id,
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
req = self.generate_request(call_id=2,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
auth_context_id=auth_context_id,
- auth_blob="\x01" +"\x00" *15)
+ auth_blob=b"\x01" +b"\x00" *15)
req = self.generate_request(call_id=3,
context_id=ctx1.context_id,
opnum=0,
- stub="",
+ stub=b"",
auth_info=auth_info)
self.send_pdu(req)
rep = self.recv_pdu()
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY,
auth_context_id=auth_context_id,
- auth_blob="\x01" + "\x00" * 15)
+ auth_blob=b"\x01" + b"\x00" * 15)
req = self.generate_request(call_id=4,
context_id=ctx1.context_id,
opnum=0,
- stub="",
+ stub=b"",
auth_info=auth_info)
self.send_pdu(req)
rep = self.recv_pdu()
auth_level = dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=dcerpc.DCERPC_AUTH_LEVEL_CONNECT,
auth_context_id=auth_context_id,
- auth_blob="\x01" + "\x00" * 15)
+ auth_blob=b"\x01" + b"\x00" * 15)
req = self.generate_request(call_id=3,
context_id=ctx1.context_id,
opnum=0,
- stub="",
+ stub=b"",
auth_info=auth_info)
self.send_pdu(req)
rep = self.recv_pdu()
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
auth_context_id=auth_context_id,
- auth_blob="\x01" + "\x00" * 15)
+ auth_blob=b"\x01" + b"\x00" * 15)
req = self.generate_request(call_id=1,
context_id=ctx1.context_id,
opnum=0,
- stub="",
+ stub=b"",
auth_info=auth_info)
self.send_pdu(req)
rep = self.recv_pdu()
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
req = self.generate_request(call_id=2,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
# We get a fault back
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
req = self.generate_request(call_id=2,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
auth_context_id=auth_context_id,
- auth_blob="\x01" + "\x00" * 15)
+ auth_blob=b"\x01" + b"\x00" * 15)
req = self.generate_request(call_id=3,
context_id=ctx1.context_id,
opnum=0,
- stub="",
+ stub=b"",
auth_info=auth_info)
self.send_pdu(req)
rep = self.recv_pdu()
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
req = self.generate_request(call_id=2,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
auth_context_id=auth_context_id,
- auth_blob="\x01" + "\x00" * 15)
+ auth_blob=b"\x01" + b"\x00" * 15)
req = self.generate_request(call_id=3,
context_id=ctx1.context_id,
opnum=0,
- stub="",
+ stub=b"",
auth_info=auth_info)
self.send_pdu(req)
rep = self.recv_pdu()
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
auth_level = dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
self.assertEquals(rep.u.secondary_address_size, 4)
self.assertEquals(rep.u.secondary_address, "%d" % self.tcp_port)
self.assertEquals(len(rep.u._pad1), 2)
- self.assertEquals(rep.u._pad1, '\0' * 2)
+ self.assertEquals(rep.u._pad1, b'\0' * 2)
self.assertEquals(rep.u.num_results, 1)
self.assertEquals(rep.u.ctx_list[0].result,
dcerpc.DCERPC_BIND_ACK_RESULT_ACCEPTANCE)
auth_level = dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
auth_level = dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
auth_level = dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
auth_level = dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
auth_level = dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
req = self.generate_request(call_id=2,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
auth_context_id=auth_context_id,
- auth_blob="\x01" + "\x00" * 15)
+ auth_blob=b"\x01" + b"\x00" * 15)
req = self.generate_request(call_id=3,
context_id=ctx1.context_id,
opnum=0,
- stub="",
+ stub=b"",
auth_info=auth_info)
self.send_pdu(req)
rep = self.recv_pdu()
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
self.assertEquals(rep.u.versions[0].rpc_vers, req.rpc_vers)
self.assertEquals(rep.u.versions[0].rpc_vers_minor, req.rpc_vers_minor)
self.assertEquals(len(rep.u._pad), 3)
- self.assertEquals(rep.u._pad, '\0' * 3)
+ self.assertEquals(rep.u._pad, b'\0' * 3)
# wait for a disconnect
rep = self.recv_pdu()
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
req = self.generate_request(call_id=2,
context_id=ctx1.context_id,
opnum=0,
- stub="")
+ stub=b"")
self.send_pdu(req)
rep = self.recv_pdu()
self.verify_pdu(rep, dcerpc.DCERPC_PKT_RESPONSE, req.call_id,
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
auth_context_id=auth_context_id,
- auth_blob="\x01" + "\x00" * 15)
+ auth_blob=b"\x01" + b"\x00" * 15)
req = self.generate_request(call_id=3,
context_id=ctx1.context_id,
opnum=0,
- stub="",
+ stub=b"",
auth_info=auth_info)
self.send_pdu(req)
rep = self.recv_pdu()
auth_level = dcerpc.DCERPC_AUTH_LEVEL_CONNECT
auth_context_id = 2
g.start_mech_by_authtype(auth_type, auth_level)
- from_server = ""
+ from_server = b""
(finished, to_server) = g.update(from_server)
self.assertFalse(finished)
self.assertIsNotNone(g)
- stub_bin = '\x00' * 17
+ stub_bin = b'\x00' * 17
mod_len = len(stub_bin) % dcerpc.DCERPC_AUTH_PAD_ALIGNMENT
auth_pad_length = 0
if mod_len > 0:
auth_pad_length = dcerpc.DCERPC_AUTH_PAD_ALIGNMENT - mod_len
- stub_bin += '\x00' * auth_pad_length
+ stub_bin += b'\x00' * auth_pad_length
if g_auth_level >= dcerpc.DCERPC_AUTH_LEVEL_INTEGRITY:
sig_size = g.sig_size(len(stub_bin))
else:
sig_size = 16
- zero_sig = "\x00" * sig_size
+ zero_sig = b"\x00" * sig_size
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
auth_context_id=auth_context_id,
ctx=ctx1)
- stub_bin = '\x00' * 0
+ stub_bin = b'\x00' * 0
mod_len = len(stub_bin) % dcerpc.DCERPC_AUTH_PAD_ALIGNMENT
auth_pad_length = 0
if mod_len > 0:
auth_pad_length = dcerpc.DCERPC_AUTH_PAD_ALIGNMENT - mod_len
- stub_bin += '\x00' * auth_pad_length
+ stub_bin += b'\x00' * auth_pad_length
sig_size = g.sig_size(len(stub_bin))
- zero_sig = "\x00" * sig_size
+ zero_sig = b"\x00" * sig_size
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
g.check_packet(rep_data, rep_whole, rep_sig)
- stub_bin = '\x00' * 17
+ stub_bin = b'\x00' * 17
mod_len = len(stub_bin) % dcerpc.DCERPC_AUTH_PAD_ALIGNMENT
auth_pad_length = 0
if mod_len > 0:
auth_pad_length = dcerpc.DCERPC_AUTH_PAD_ALIGNMENT - mod_len
- stub_bin += '\x00' * auth_pad_length
+ stub_bin += b'\x00' * auth_pad_length
sig_size = g.sig_size(len(stub_bin))
- zero_sig = "\x00" * sig_size
+ zero_sig = b"\x00" * sig_size
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
self.assertEquals(rep.u.reserved, 0)
self.assertEquals(len(rep.u.error_and_verifier), 0)
- stub_bin = '\x00' * 8
+ stub_bin = b'\x00' * 8
mod_len = len(stub_bin) % dcerpc.DCERPC_AUTH_PAD_ALIGNMENT
auth_pad_length = 0
if mod_len > 0:
auth_pad_length = dcerpc.DCERPC_AUTH_PAD_ALIGNMENT - mod_len
- stub_bin += '\x00' * auth_pad_length
+ stub_bin += b'\x00' * auth_pad_length
sig_size = g.sig_size(len(stub_bin))
- zero_sig = "\x00" * sig_size
+ zero_sig = b"\x00" * sig_size
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,
g.check_packet(rep_data, rep_whole, rep_sig)
- stub_bin = '\x00' * 8
+ stub_bin = b'\x00' * 8
mod_len = len(stub_bin) % dcerpc.DCERPC_AUTH_PAD_ALIGNMENT
auth_pad_length = 0
if mod_len > 0:
auth_pad_length = dcerpc.DCERPC_AUTH_PAD_ALIGNMENT - mod_len
- stub_bin += '\x00' * auth_pad_length
+ stub_bin += b'\x00' * auth_pad_length
sig_size = g.sig_size(len(stub_bin))
- zero_sig = "\x00" * sig_size
+ zero_sig = b"\x00" * sig_size
auth_info = self.generate_auth(auth_type=auth_type,
auth_level=auth_level,