summaryrefslogtreecommitdiffstats
path: root/geo-replication/syncdaemon/resource.py
diff options
context:
space:
mode:
Diffstat (limited to 'geo-replication/syncdaemon/resource.py')
-rw-r--r--geo-replication/syncdaemon/resource.py18
1 files changed, 17 insertions, 1 deletions
diff --git a/geo-replication/syncdaemon/resource.py b/geo-replication/syncdaemon/resource.py
index ed0e7efe2b2..acbd49e1b54 100644
--- a/geo-replication/syncdaemon/resource.py
+++ b/geo-replication/syncdaemon/resource.py
@@ -773,7 +773,23 @@ class Server(object):
else:
if st.st_ino == st1.st_ino:
# we have a hard link, we can now unlink source
- os.unlink(entry)
+ try:
+ os.unlink(entry)
+ except OSError as e:
+ if e.errno == EISDIR:
+ try:
+ os.rmdir(entry)
+ except OSError as e:
+ if e.errno == ENOTEMPTY:
+ logging.error(
+ "Unable to delete directory "
+ "{0}, Both Old({1}) and New{2}"
+ " directories exists".format(
+ entry, entry, en))
+ else:
+ raise
+ else:
+ raise
else:
rename_with_disk_gfid_confirmation(gfid, entry, en)
if blob: