(t) replication spawn error - continued 3 rockstor#2766

- more debug logging
- remove receiver 'latest_snap or b""' to simplify for debug.

src/rockstor/smart_manager/replication/receiver.py

@@ -126,13 +126,15 @@ def _delete_old_snaps(self, share_name, share_path, num_retain):
                 return self._delete_old_snaps(share_name, share_path, num_retain)
 
     def _send_recv(self, command: bytes, msg: bytes = b""):
+        logger.debug(f"_send_recv called with command: {command}, msg: {msg}.")
         rcommand = rmsg = None
         self.dealer.send_multipart([command, msg])
         # Retry logic doesn't make sense atm. So one long patient wait.
         socks = dict(self.poll.poll(60000))  # 60 seconds.
         if socks.get(self.dealer) == zmq.POLLIN:
             rcommand, rmsg = self.dealer.recv_multipart()
         logger.debug(f"Id: {self.identity} command: {command} rcommand: {rcommand}")
+        logger.debug((f"remote message: {rmsg}"))
         return rcommand, rmsg
 
     def _latest_snap(self, rso):
@@ -265,7 +267,7 @@ def run(self):
             )
 
             self.msg = b"Failed to send receiver-ready"
-            rcommand, rmsg = self._send_recv(b"receiver-ready", latest_snap or b"")
+            rcommand, rmsg = self._send_recv(b"receiver-ready", b"")
             if rcommand is None:
                 logger.error(
                     f"Id: {self.identity}. No response from the broker for receiver-ready command. Aborting."

src/rockstor/smart_manager/replication/sender.py

@@ -250,6 +250,7 @@ def run(self):
             poll_interval = 6000  # 6 seconds
             while True:
                 socks = dict(self.poll.poll(poll_interval))
+                logger.debug(f"Sender socks dict = {socks}")
                 if socks.get(self.send_req) == zmq.POLLIN:
                     # not really necessary because we just want one reply for
                     # now.