|
@@ -89,7 +89,9 @@ class Pusher:
|
|
|
|
|
|
# Check if a push operation is already active. If so, don't start another
|
|
|
if p.is_being_pushed_to:
|
|
|
- logger.debug("Waiting for %s:%d to finish pushing...", p.servername, p.port)
|
|
|
+ logger.debug(
|
|
|
+ "Waiting for %s to finish pushing...", p.replication_url_origin
|
|
|
+ )
|
|
|
return
|
|
|
|
|
|
p.is_being_pushed_to = True
|
|
@@ -108,7 +110,7 @@ class Pusher:
|
|
|
return
|
|
|
|
|
|
logger.info(
|
|
|
- "Pushing %d updates to %s:%d", len(assocs), p.servername, p.port
|
|
|
+ "Pushing %d updates to %s", len(assocs), p.replication_url_origin
|
|
|
)
|
|
|
result = await p.pushUpdates(assocs)
|
|
|
|
|
@@ -117,14 +119,13 @@ class Pusher:
|
|
|
)
|
|
|
|
|
|
logger.info(
|
|
|
- "Pushed updates to %s:%d with result %d %s",
|
|
|
- p.servername,
|
|
|
- p.port,
|
|
|
+ "Pushed updates to %s with result %d %s",
|
|
|
+ p.replication_url_origin,
|
|
|
result.code,
|
|
|
result.phrase,
|
|
|
)
|
|
|
except Exception:
|
|
|
- logger.exception("Error pushing updates to %s:%d", p.servername, p.port)
|
|
|
+ logger.exception("Error pushing updates to %s", p.replication_url_origin)
|
|
|
finally:
|
|
|
# Whether pushing completed or an error occurred, signal that pushing has finished
|
|
|
p.is_being_pushed_to = False
|