diff options
author | Andrew Tridgell <tridge@samba.org> | 2011-07-11 14:05:30 +1000 |
---|---|---|
committer | Andrew Tridgell <tridge@samba.org> | 2011-07-11 14:32:45 +1000 |
commit | 082a9cc72815a3873b1cea2779dff6bc41a9773c (patch) | |
tree | 45254846e79a164c1b7060a3be66b32d70827749 /source4 | |
parent | 396beee776778af7c9b7d48d7c977b32b3ee4654 (diff) | |
download | samba-082a9cc72815a3873b1cea2779dff6bc41a9773c.tar.gz samba-082a9cc72815a3873b1cea2779dff6bc41a9773c.tar.bz2 samba-082a9cc72815a3873b1cea2779dff6bc41a9773c.zip |
dbcheck: improved error checking in fixup of missing metdata
when fixing missing attributes in replPropertyMetaData, allow user to
confirm changes, and check for exceptions
Pair-Programmed-With: Andrew Bartlett <abartlet@samba.org>
Pair-Programmed-With: Amitay Isaacs <amitay@gmail.com>
Diffstat (limited to 'source4')
-rw-r--r-- | source4/scripting/python/samba/dbchecker.py | 50 |
1 files changed, 24 insertions, 26 deletions
diff --git a/source4/scripting/python/samba/dbchecker.py b/source4/scripting/python/samba/dbchecker.py index cad3660ef1..402b3b6714 100644 --- a/source4/scripting/python/samba/dbchecker.py +++ b/source4/scripting/python/samba/dbchecker.py @@ -67,6 +67,7 @@ class dbcheck(object): self.fix_all_DN_GUIDs = False self.remove_all_deleted_DN_links = False self.fix_all_target_mismatch = False + self.fix_all_metadata = False def check_database(self, DN=None, scope=ldb.SCOPE_SUBTREE, controls=[], attrs=['*']): '''perform a database check, returning the number of errors found''' @@ -351,22 +352,22 @@ class dbcheck(object): return list_att - def fix_metadata(self, dn, list): - res = self.samdb.search(base = dn, scope=ldb.SCOPE_BASE, attrs = list, - controls = ["search_options:1:2"]) + def fix_metadata(self, dn, attr): + '''re-write replPropertyMetaData elements for a single attribute for a + object. This is used to fix missing replPropertyMetaData elements''' + res = self.samdb.search(base = dn, scope=ldb.SCOPE_BASE, attrs = [attr], + controls = ["search_options:1:2", "show_deleted:1"]) msg = res[0] nmsg = ldb.Message() - - delta = self.samdb.msg_diff(nmsg, msg) nmsg.dn = dn + nmsg[attr] = ldb.MessageElement(msg[attr], ldb.FLAG_MOD_REPLACE, attr) + try: + self.samdb.modify(nmsg, controls = ["relax:0", "provision:0", "show_deleted:1"]) + except Exception, err: + self.report("Failed to fix metadata for attribute %s : %s" % (attr, err)) + return + self.report("Fixed metadata for attribute %s" % attr) - for att in delta: - if att == "dn": - continue - val = delta.get(att) - nmsg[att] = ldb.MessageElement(val, ldb.FLAG_MOD_REPLACE, att) - - self.samdb.modify(nmsg, controls = ["relax:0", "provision:0"]) ################################################################ # check one object - calls to individual error handlers above @@ -433,19 +434,16 @@ class dbcheck(object): break show_dn = True - if len(list_attrs_seen): - attrs_to_fix = [] - for att in list_attrs_seen: - if not att in list_attrs_from_md: - if show_dn: - print "On object %s" % dn - show_dn = False - print " Attribute %s not present in replication metadata" % (att) - error_count += 1 - attrs_to_fix.append(att) - - if len(attrs_to_fix) and self.fix: - self.fix_metadata(dn, attrs_to_fix) - + for att in list_attrs_seen: + if not att in list_attrs_from_md: + if show_dn: + self.report("On object %s" % dn) + show_dn = False + error_count += 1 + self.report("ERROR: Attribute %s not present in replication metadata" % att) + if not self.confirm_all("Fix missing replPropertyMetaData element '%s'" % att, 'fix_all_metadata'): + self.report("Not fixing missing replPropertyMetaData element '%s'" % att) + continue + self.fix_metadata(dn, att) return error_count |