summaryrefslogtreecommitdiffstats
path: root/geo-replication/syncdaemon/master.py
diff options
context:
space:
mode:
Diffstat (limited to 'geo-replication/syncdaemon/master.py')
-rw-r--r--geo-replication/syncdaemon/master.py10
1 files changed, 10 insertions, 0 deletions
diff --git a/geo-replication/syncdaemon/master.py b/geo-replication/syncdaemon/master.py
index d8d26baafe1..51c1e571e53 100644
--- a/geo-replication/syncdaemon/master.py
+++ b/geo-replication/syncdaemon/master.py
@@ -241,6 +241,8 @@ class TarSSHEngine(object):
def a_syncdata(self, files):
self.unlinked_gfids = []
logging.debug('files: %s' % (files))
+ self.current_files_skipped_count = 0
+ del self.skipped_gfid_list[:]
for f in files:
pb = self.syncer.add(f)
@@ -256,6 +258,9 @@ class TarSSHEngine(object):
self.unlinked_gfids.append(se)
return True
logging.warn('tar+ssh: %s [errcode: %d]' % (se, rv[1]))
+ se_list = se.split('/');
+ self.current_files_skipped_count += 1
+ self.skipped_gfid_list.append(se_list[1])
self.add_job(self.FLAT_DIR_HIERARCHY, 'reg', regjob, f, None, pb)
def syncdata_wait(self):
@@ -274,6 +279,8 @@ class RsyncEngine(object):
def a_syncdata(self, files):
self.unlinked_gfids = []
logging.debug('files: %s' % (files))
+ self.current_files_skipped_count = 0
+ del self.skipped_gfid_list[:]
for f in files:
logging.debug('candidate for syncing %s' % f)
pb = self.syncer.add(f)
@@ -292,6 +299,9 @@ class RsyncEngine(object):
self.unlinked_gfids.append(se)
return True
logging.warn('Rsync: %s [errcode: %d]' % (se, rv[1]))
+ se_list = se.split('/');
+ self.current_files_skipped_count += 1
+ self.skipped_gfid_list.append(se_list[1])
self.add_job(self.FLAT_DIR_HIERARCHY, 'reg', regjob, f, None, pb)
def syncdata_wait(self):