Added missing newline symbol when writing to CRDT log. Removed or clarified some log printings.

Author: numbleroot

comm/receiver.go

@@ -376,6 +376,13 @@ func (recv *Receiver) StoreIncMsgs(conn net.Conn) {
 		log.Fatalf("[comm.StoreIncMsgs] Writing to CRDT log file failed with: %s\n", err.Error())
 	}
 
+	// Append a newline symbol to just written line.
+	newline := []byte("\n")
+	_, err = recv.writeLog.Write(newline)
+	if err != nil {
+		log.Fatalf("[comm.StoreIncMsgs] Appending a newline symbol to CRDT log file failed with: %s\n", err.Error())
+	}
+
 	// Save to stable storage.
 	err = recv.writeLog.Sync()
 	if err != nil {

comm/sender.go

@@ -287,13 +287,13 @@ func (sender *Sender) SendMsgs() {
 					// Connect to node.
 					conn, err := ReliableConnect(nodeAddr, sender.tlsConfig, sender.intlConnRetry)
 					if err != nil {
-						log.Fatalf("[comm.SendMsgs] Failed to connect to %s: %s\n", err.Error())
+						log.Fatalf("[comm.SendMsgs] Failed to connect to '%s': %s\n", nodeAddr, err.Error())
 					}
 
 					// Send payload reliably to other nodes.
 					err = ReliableSend(conn, marshalledMsg, nodeAddr, sender.tlsConfig, sender.intlConnTimeout, sender.intlConnRetry)
 					if err != nil {
-						log.Fatalf("[comm.SendMsgs] Failed to send: %s\n", err.Error())
+						log.Fatalf("[comm.SendMsgs] Failed to send to '%s': %s\n", nodeAddr, err.Error())
 					}
 				}
 

imap/distributor-commands.go

@@ -217,7 +217,7 @@ func (distr *Distributor) Proxy(c *Connection, rawReq string) bool {
 	// Pass message to worker node.
 	err := c.InternalSend(false, rawReq)
 	if err != nil {
-		fmt.Printf("HERE HERE HERE: '%s'\n", err.Error())
+		c.Error("Could not proxy request to worker", err)
 		return false
 	}
 
@@ -227,7 +227,7 @@ func (distr *Distributor) Proxy(c *Connection, rawReq string) bool {
 	// Receive incoming worker response.
 	curResp, err := c.InternalReceive(false)
 	if err != nil {
-		c.Error("123: Encountered receive error from worker", err)
+		c.Error("Failed to receive worker's response to proxied command", err)
 		return false
 	}
 

imap/worker.go

@@ -524,7 +524,7 @@ func (failWorker *FailoverWorker) HandleFailover(conn net.Conn) {
 		// Pass message to storage node.
 		err := c.InternalSend(false, rawReq)
 		if err != nil {
-			fmt.Printf("HERE 2 HERE 2 HERE 2: '%s'\n", err.Error())
+			c.Error("Could not proxy request to storage", err)
 			return
 		}
 
@@ -534,7 +534,7 @@ func (failWorker *FailoverWorker) HandleFailover(conn net.Conn) {
 		// Receive incoming storage response.
 		curResp, err := c.InternalReceive(false)
 		if err != nil {
-			c.Error("Encountered receive error from storage", err)
+			c.Error("Failed to receive storage's response to proxied command", err)
 			return
 		}