sin/samba-mirror
1
0
Fork 0
mirror of https://github.com/samba-team/samba.git synced 2025-07-29 15:42:04 +03:00
Code Activity

s4:ldapcmp.py: pass down outf and errf

Browse Source 
Not all classes are derived from class 'Command'.

metze

Autobuild-User: Stefan Metzmacher <metze@samba.org>
Autobuild-Date: Tue Apr 17 10:06:47 CEST 2012 on sn-devel-104
This commit is contained in:
Stefan Metzmacher
2012-03-26 09:31:55 +02:00
parent 92c5e80f46
commit 4460ba5288
1 changed files with 29 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
source4/scripting/python/samba/netcmd/ldapcmp.py
View File

@ -45,7 +45,8 @@ class LDAPBase(object):
def __init__(self, host, creds, lp, def __init__(self, host, creds, lp,
two=False, quiet=False, descriptor=False, sort_aces=False, verbose=False, two=False, quiet=False, descriptor=False, sort_aces=False, verbose=False,
view="section", base="", scope="SUB"): view="section", base="", scope="SUB",
outf=sys.stdout, errf=sys.stderr):
ldb_options = [] ldb_options = []
samdb_url = host samdb_url = host
if not "://" in host: if not "://" in host:
@ -56,6 +57,8 @@ class LDAPBase(object):
# use 'paged_search' module when connecting remotely # use 'paged_search' module when connecting remotely
if samdb_url.lower().startswith("ldap://"): if samdb_url.lower().startswith("ldap://"):
ldb_options = ["modules:paged_searches"] ldb_options = ["modules:paged_searches"]
self.outf = outf
self.errf = errf
self.ldb = Ldb(url=samdb_url, self.ldb = Ldb(url=samdb_url,
credentials=creds, credentials=creds,
lp=lp, lp=lp,
@ -274,7 +277,9 @@ class LDAPBase(object):
pass pass
class Descriptor(object): class Descriptor(object):
def __init__(self, connection, dn): def __init__(self, connection, dn, outf=sys.stdout, errf=sys.stderr):
self.outf = outf
self.errf = errf
self.con = connection self.con = connection
self.dn = dn self.dn = dn
self.sddl = self.con.get_descriptor_sddl(self.dn) self.sddl = self.con.get_descriptor_sddl(self.dn)
@ -414,7 +419,10 @@ class Descriptor(object):
return (self_aces == [] and other_aces == [], res) return (self_aces == [] and other_aces == [], res)
class LDAPObject(object): class LDAPObject(object):
def __init__(self, connection, dn, summary, filter_list): def __init__(self, connection, dn, summary, filter_list,
outf=sys.stdout, errf=sys.stderr):
self.outf = outf
self.errf = errf
self.con = connection self.con = connection
self.two_domains = self.con.two_domains self.two_domains = self.con.two_domains
self.quiet = self.con.quiet self.quiet = self.con.quiet
@ -535,8 +543,8 @@ class LDAPObject(object):
return self.cmp_attrs(other) return self.cmp_attrs(other)
def cmp_desc(self, other): def cmp_desc(self, other):
d1 = Descriptor(self.con, self.dn) d1 = Descriptor(self.con, self.dn, outf=self.outf, errf=self.errf)
d2 = Descriptor(other.con, other.dn) d2 = Descriptor(other.con, other.dn, outf=self.outf, errf=self.errf)
if self.con.view == "section": if self.con.view == "section":
res = d1.diff_2(d2) res = d1.diff_2(d2)
elif self.con.view == "collision": elif self.con.view == "collision":
@ -668,7 +676,10 @@ class LDAPObject(object):
class LDAPBundel(object): class LDAPBundel(object):
def __init__(self, connection, context, dn_list=None, filter_list=None): def __init__(self, connection, context, dn_list=None, filter_list=None,
outf=sys.stdout, errf=sys.stderr):
self.outf = outf
self.errf = errf
self.con = connection self.con = connection
self.two_domains = self.con.two_domains self.two_domains = self.con.two_domains
self.quiet = self.con.quiet self.quiet = self.con.quiet
@ -759,7 +770,8 @@ class LDAPBundel(object):
object1 = LDAPObject(connection=self.con, object1 = LDAPObject(connection=self.con,
dn=self.dn_list[index], dn=self.dn_list[index],
summary=self.summary, summary=self.summary,
filter_list=self.filter_list) filter_list=self.filter_list,
outf=self.outf, errf=self.errf)
except LdbError, (enum, estr): except LdbError, (enum, estr):
if enum == ERR_NO_SUCH_OBJECT: if enum == ERR_NO_SUCH_OBJECT:
self.log( "\n!!! Object not found: %s" % self.dn_list[index] ) self.log( "\n!!! Object not found: %s" % self.dn_list[index] )
@ -769,7 +781,8 @@ class LDAPBundel(object):
object2 = LDAPObject(connection=other.con, object2 = LDAPObject(connection=other.con,
dn=other.dn_list[index], dn=other.dn_list[index],
summary=other.summary, summary=other.summary,
filter_list=self.filter_list) filter_list=self.filter_list,
outf=self.outf, errf=self.errf)
except LdbError, (enum, estr): except LdbError, (enum, estr):
if enum == ERR_NO_SUCH_OBJECT: if enum == ERR_NO_SUCH_OBJECT:
self.log( "\n!!! Object not found: %s" % other.dn_list[index] ) self.log( "\n!!! Object not found: %s" % other.dn_list[index] )
@ -943,12 +956,14 @@ class cmd_ldapcmp(Command):
con1 = LDAPBase(URL1, creds, lp, con1 = LDAPBase(URL1, creds, lp,
two=two, quiet=quiet, descriptor=descriptor, sort_aces=sort_aces, two=two, quiet=quiet, descriptor=descriptor, sort_aces=sort_aces,
verbose=verbose,view=view, base=base, scope=scope) verbose=verbose,view=view, base=base, scope=scope,
outf=self.outf, errf=self.errf)
assert len(con1.base_dn) > 0 assert len(con1.base_dn) > 0
con2 = LDAPBase(URL2, creds2, lp, con2 = LDAPBase(URL2, creds2, lp,
two=two, quiet=quiet, descriptor=descriptor, sort_aces=sort_aces, two=two, quiet=quiet, descriptor=descriptor, sort_aces=sort_aces,
verbose=verbose, view=view, base=base2, scope=scope) verbose=verbose, view=view, base=base2, scope=scope,
outf=self.outf, errf=self.errf)
assert len(con2.base_dn) > 0 assert len(con2.base_dn) > 0
filter_list = filter.split(",") filter_list = filter.split(",")
@ -958,8 +973,10 @@ class cmd_ldapcmp(Command):
if not quiet: if not quiet:
self.outf.write("\n* Comparing [%s] context...\n" % context) self.outf.write("\n* Comparing [%s] context...\n" % context)
b1 = LDAPBundel(con1, context=context, filter_list=filter_list) b1 = LDAPBundel(con1, context=context, filter_list=filter_list,
b2 = LDAPBundel(con2, context=context, filter_list=filter_list) outf=self.outf, errf=self.errf)
b2 = LDAPBundel(con2, context=context, filter_list=filter_list,
outf=self.outf, errf=self.errf)
if b1 == b2: if b1 == b2:
if not quiet: if not quiet: