self.ldb_dc1.add({
"dn": self.ou,
"objectclass": "organizationalUnit"})
- (self.drs, self.drs_handle) = self._ds_bind(self.dnsname_dc1)
+ (self.drs, self.drs_handle) = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
(self.default_hwm, self.default_utdv) = self._get_highest_hwm_utdv(self.ldb_dc1)
def tearDown(self):
nc_guid=misc.GUID("c2d2f745-1610-4e93-964b-d4ba73eb32f8"),
exop=drsuapi.DRSUAPI_EXOP_NONE)
- (drs, drs_handle) = self._ds_bind(fsmo_owner["dns_name"])
+ (drs, drs_handle) = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
try:
(level, ctr) = drs.DsGetNCChanges(drs_handle, 8, req8)
except WERRORError as e1:
nc_guid=misc.GUID("c2d2f745-1610-4e93-964b-d4ba73eb32f8"),
exop=drsuapi.DRSUAPI_EXOP_REPL_OBJ)
- (drs, drs_handle) = self._ds_bind(fsmo_owner["dns_name"])
+ (drs, drs_handle) = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
try:
(level, ctr) = drs.DsGetNCChanges(drs_handle, 8, req8)
except WERRORError as e1:
dc_guid_1 = self.ldb_dc1.get_invocation_id()
- drs, drs_handle = self._ds_bind(self.dnsname_dc1)
+ drs, drs_handle = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
req8 = self._exop_req8(dest_dsa=None,
invocation_id=dc_guid_1,
partial_attribute_set = self.get_partial_attribute_set([99999])
dc_guid_1 = self.ldb_dc1.get_invocation_id()
- drs, drs_handle = self._ds_bind(self.dnsname_dc1)
+ drs, drs_handle = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
try:
pfm = self._samdb_fetch_pfm_and_schi()
partial_attribute_set = self.get_partial_attribute_set([drsuapi.DRSUAPI_ATTID_unicodePwd])
dc_guid_1 = self.ldb_dc1.get_invocation_id()
- drs, drs_handle = self._ds_bind(self.dnsname_dc1)
+ drs, drs_handle = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
try:
pfm = self._samdb_fetch_pfm_and_schi()
partial_attribute_set = self.get_partial_attribute_set([drsuapi.DRSUAPI_ATTID_name])
dc_guid_1 = self.ldb_dc1.get_invocation_id()
- drs, drs_handle = self._ds_bind(self.dnsname_dc1)
+ drs, drs_handle = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
try:
pfm = self._samdb_fetch_pfm_and_schi()
partial_attribute_set_ex = self.get_partial_attribute_set([drsuapi.DRSUAPI_ATTID_unicodePwd])
dc_guid_1 = self.ldb_dc1.get_invocation_id()
- drs, drs_handle = self._ds_bind(self.dnsname_dc1)
+ drs, drs_handle = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
try:
pfm = self._samdb_fetch_pfm_and_schi()
dc_guid_1 = self.ldb_dc1.get_invocation_id()
- drs, drs_handle = self._ds_bind(self.dnsname_dc1)
+ drs, drs_handle = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
req8 = self._exop_req8(dest_dsa=None,
invocation_id=dc_guid_1,
dc_guid_1 = self.ldb_dc1.get_invocation_id()
- drs, drs_handle = self._ds_bind(self.dnsname_dc1)
+ drs, drs_handle = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
# Make sure the max objects count is high enough
req8 = self._exop_req8(dest_dsa=None,
class DrsMoveObjectTestCase(drs_base.DrsBaseTestCase):
- def _ds_bind(self, server_name):
- binding_str = "ncacn_ip_tcp:%s[print,seal]" % server_name
-
- drs = drsuapi(binding_str, self.get_loadparm(), self.get_credentials())
- (drs_handle, supported_extensions) = drs_DsBind(drs)
- return (drs, drs_handle)
-
def setUp(self):
super(DrsMoveObjectTestCase, self).setUp()
# disable automatic replication temporary
self.dc1_guid = self.ldb_dc1.get_invocation_id()
self.dc2_guid = self.ldb_dc2.get_invocation_id()
- self.drs_dc1 = self._ds_bind(self.dnsname_dc1)
- self.drs_dc2 = self._ds_bind(self.dnsname_dc2)
+ self.drs_dc1 = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
+ self.drs_dc2 = self._ds_bind(self.dnsname_dc2, ip=self.url_dc2)
def tearDown(self):
try:
# current Class or Attribute object id
obj_id = 0
- def _ds_bind(self, server_name):
- binding_str = "ncacn_ip_tcp:%s[seal]" % server_name
-
- drs = drsuapi.drsuapi(binding_str, self.get_loadparm(), self.get_credentials())
- (drs_handle, supported_extensions) = drs_DsBind(drs)
- return (drs, drs_handle)
-
def _exop_req8(self, dest_dsa, invocation_id, nc_dn_str, exop,
replica_flags=0, max_objects=0):
req8 = drsuapi.DsGetNCChangesRequest8()
dc_guid_1 = self.ldb_dc1.get_invocation_id()
- drs, drs_handle = self._ds_bind(self.dnsname_dc1)
+ drs, drs_handle = self._ds_bind(self.dnsname_dc1, ip=self.url_dc1)
req8 = self._exop_req8(dest_dsa=None,
invocation_id=dc_guid_1,