diff options
Diffstat (limited to 'ipaserver/install')
| -rw-r--r-- | ipaserver/install/dsinstance.py | 2 | ||||
| -rw-r--r-- | ipaserver/install/ipa_ldap_updater.py | 2 | ||||
| -rw-r--r-- | ipaserver/install/ldapupdate.py | 28 | ||||
| -rw-r--r-- | ipaserver/install/upgradeinstance.py | 2 |
4 files changed, 30 insertions, 4 deletions
diff --git a/ipaserver/install/dsinstance.py b/ipaserver/install/dsinstance.py index 93a226ca9..be629b198 100644 --- a/ipaserver/install/dsinstance.py +++ b/ipaserver/install/dsinstance.py @@ -472,7 +472,7 @@ class DsInstance(service.Service): def apply_updates(self): ld = ldapupdate.LDAPUpdate(dm_password=self.dm_password, sub_dict=self.sub_dict, plugins=True) files = ld.get_all_files(ldapupdate.UPDATES_DIR) - ld.update(files) + ld.update(files, ordered=True) def __add_referint_module(self): self._ldap_mod("referint-conf.ldif") diff --git a/ipaserver/install/ipa_ldap_updater.py b/ipaserver/install/ipa_ldap_updater.py index df409ebb6..09a1962ec 100644 --- a/ipaserver/install/ipa_ldap_updater.py +++ b/ipaserver/install/ipa_ldap_updater.py @@ -185,7 +185,7 @@ class LDAPUpdater_NonUpgrade(LDAPUpdater): if not self.files: self.files = ld.get_all_files(UPDATES_DIR) - modified = ld.update(self.files) + modified = ld.update(self.files, ordered=True) if modified and options.test: self.log.info('Update complete, changes to be made, test mode') diff --git a/ipaserver/install/ldapupdate.py b/ipaserver/install/ldapupdate.py index 79aea1787..8f3e89249 100644 --- a/ipaserver/install/ldapupdate.py +++ b/ipaserver/install/ldapupdate.py @@ -33,6 +33,7 @@ import pwd import fnmatch import csv import inspect +import re import krbV import ldap @@ -900,21 +901,46 @@ class LDAPUpdate: for dn, update in sorted_updates: self._delete_record(update) - def update(self, files): + def update(self, files, ordered=False): """Execute the update. files is a list of the update files to use. + If ordered is True then the updates the file must be of the form + ##-name.update where ## is an integer between 10 and 89. The + changes are applied to LDAP at the end of each value divisible + by 10, so after 20, 30, etc. + returns True if anything was changed, otherwise False """ + pat = re.compile(r'(\d+)-.*\.update') all_updates = {} + r = 20 if self.plugins: self.info('PRE_UPDATE') updates = api.Backend.updateclient.update(PRE_UPDATE, self.dm_password, self.ldapi, self.live_run) self.merge_updates(all_updates, updates) try: self.create_connection() + if ordered and all_updates: + # flush out PRE_UPDATE plugin updates before we begin + self._run_updates(all_updates) + all_updates = {} for f in files: + name = os.path.basename(f) + if ordered: + m = pat.match(name) + if not m: + raise RuntimeError("Filename does not match format #-name.update: %s" % f) + index = int(m.group(1)) + if index < 10 or index > 90: + raise RuntimeError("Index not legal range: %d" % index) + + if index >= r: + self._run_updates(all_updates) + all_updates = {} + r += 10 + try: self.info("Parsing update file '%s'" % f) data = self.read_file(f) diff --git a/ipaserver/install/upgradeinstance.py b/ipaserver/install/upgradeinstance.py index aa4440c71..895f29b3d 100644 --- a/ipaserver/install/upgradeinstance.py +++ b/ipaserver/install/upgradeinstance.py @@ -115,7 +115,7 @@ class IPAUpgrade(service.Service): ld = ldapupdate.LDAPUpdate(dm_password='', ldapi=True, live_run=self.live_run, plugins=True) if len(self.files) == 0: self.files = ld.get_all_files(ldapupdate.UPDATES_DIR) - self.modified = ld.update(self.files) + self.modified = ld.update(self.files, ordered=True) except ldapupdate.BadSyntax, e: root_logger.error('Bad syntax in upgrade %s' % str(e)) self.modified = False |