"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "geo-replication/syncdaemon/master.py" between
glusterfs-9.2.tar.gz and glusterfs-9.3.tar.gz

About: GlusterFS is a network/cluster filesystem. The storage server (or each in a cluster) runs glusterfsd and the clients use mount command or glusterfs client to mount the exported filesystem. Release series 9.x (latest version).

master.py  (glusterfs-9.2):master.py  (glusterfs-9.3)
skipping to change at line 1211 skipping to change at line 1211
entry_start_time = time.time() entry_start_time = time.time()
# sync namespace # sync namespace
if entries and not ignore_entry_ops: if entries and not ignore_entry_ops:
# Increment counters for Status # Increment counters for Status
self.status.inc_value("entry", len(entries)) self.status.inc_value("entry", len(entries))
failures = self.slave.server.entry_ops(entries) failures = self.slave.server.entry_ops(entries)
if gconf.get("gfid-conflict-resolution"): if gconf.get("gfid-conflict-resolution"):
count = 0 count = 0
num_entries = len(entries)
num_failures = len(failures)
if failures: if failures:
logging.info(lf('Entry ops failed with gfid mismatch', logging.info(lf('Entry ops failed with gfid mismatch',
count=len(failures))) count=num_failures))
while failures and count < self.MAX_OE_RETRIES: while failures and count < self.MAX_OE_RETRIES:
count += 1 count += 1
self.handle_entry_failures(failures, entries) self.handle_entry_failures(failures, entries)
logging.info(lf('Retry original entries', count=count)) logging.info(lf('Retry original entries', count=count))
failures = self.slave.server.entry_ops(entries) failures = self.slave.server.entry_ops(entries)
if not failures: if not failures:
logging.info("Successfully fixed all entry ops with " logging.info("Successfully fixed all entry ops with "
"gfid mismatch") "gfid mismatch")
break break
# If this iteration has not removed any entry or reduced
# the number of failures compared to the previous one, we
# don't need to keep iterating because we'll get the same
# result in all other attempts.
if ((num_entries == len(entries)) and
(num_failures == len(failures))):
logging.info(lf("No more gfid mismatches can be fixed",
entries=num_entries,
failures=num_failures))
break
num_entries = len(entries)
num_failures = len(failures)
self.log_failures(failures, 'gfid', gauxpfx(), 'ENTRY') self.log_failures(failures, 'gfid', gauxpfx(), 'ENTRY')
self.status.dec_value("entry", len(entries)) self.status.dec_value("entry", len(entries))
# Update Entry stime in Brick Root only in case of Changelog mode # Update Entry stime in Brick Root only in case of Changelog mode
if self.name in ["live_changelog", "history_changelog"]: if self.name in ["live_changelog", "history_changelog"]:
entry_stime_to_update = (int(change_ts) - 1, 0) entry_stime_to_update = (int(change_ts) - 1, 0)
self.upd_entry_stime(entry_stime_to_update) self.upd_entry_stime(entry_stime_to_update)
self.status.set_field("last_synced_entry", self.status.set_field("last_synced_entry",
entry_stime_to_update[0]) entry_stime_to_update[0])
 End of changes. 3 change blocks. 
1 lines changed or deleted 17 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)