Improve logging

Author: knizhnik

arbiter.c

@@ -412,7 +412,7 @@ static bool MtmSendToNode(int node, void const* buf, int size)
 				MtmOnNodeDisconnect(node+1);
 				return false;
 			}
-			MTM_TRACE("Arbiter restablished connection with node %d\n", node+1);
+			MTM_LOG3("Arbiter restablished connection with node %d", node+1);
 		} else { 
 			return true;
 		}
@@ -456,7 +456,7 @@ static void MtmAcceptOneConnection()
 				elog(WARNING, "Arbiter failed to write response for handshake message to node %d", resp.node);
 				close(fd);
 			} else { 
-				elog(NOTICE, "Arbiter established connection with node %d", req.hdr.node); 
+				MTM_LOG1("Arbiter established connection with node %d", req.hdr.node); 
 				BIT_CLEAR(Mtm->connectivityMask, req.hdr.node-1);
 				MtmRegisterSocket(fd, req.hdr.node-1);
 				sockets[req.hdr.node-1] = fd;
@@ -509,8 +509,8 @@ static void MtmAppendBuffer(MtmBuffer* txBuffer, TransactionId xid, int node, Mt
 		}
 		buf->used = 0;
 	}
-	MTM_TRACE("Send %s message CSN=%ld to node %d from node %d for global transaction %d/local transaction %d\n", 
-			  messageText[ts->cmd], ts->csn, node+1, MtmNodeId, ts->gtid.xid, ts->xid);
+	MTM_LOG3("Send %s message CSN=%ld to node %d from node %d for global transaction %d/local transaction %d", 
+			 messageText[ts->cmd], ts->csn, node+1, MtmNodeId, ts->gtid.xid, ts->xid);
 
 	Assert(ts->cmd != MSG_INVALID);
 	buf->data[buf->used].code = ts->cmd;

decoder_raw.c

@@ -108,11 +108,11 @@ decoder_raw_begin_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn)
     Assert(lastXid != txn->xid);
     lastXid = txn->xid;
     if (MMIsLocalTransaction(txn->xid)) {
-        MTM_TRACE("Skip local transaction %u\n", txn->xid);
+        MTM_LOG3("Skip local transaction %u", txn->xid);
         data->isLocal = true;
     } else { 
         OutputPluginPrepareWrite(ctx, true);
-        MTM_TRACE("Send transaction %u to replica\n", txn->xid);
+        MTM_LOG3("Send transaction %u to replica", txn->xid);
         appendStringInfo(ctx->out, "BEGIN %u;", txn->xid);
         OutputPluginWrite(ctx, true);
         data->isLocal = false;
@@ -126,12 +126,12 @@ decoder_raw_commit_txn(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
 {
 	DecoderRawData *data = ctx->output_plugin_private;
     if (!data->isLocal) { 
-        MTM_TRACE("Send commit of transaction %u to replica\n", txn->xid);
+        MTM_LOG3("Send commit of transaction %u to replica", txn->xid);
         OutputPluginPrepareWrite(ctx, true);
         appendStringInfoString(ctx->out, "COMMIT;");
         OutputPluginWrite(ctx, true);
     } else { 
-        MTM_TRACE("Skip commit of transaction %u\n", txn->xid);
+        MTM_LOG3("Skip commit of transaction %u", txn->xid);
     }
 }
 
@@ -483,10 +483,10 @@ decoder_raw_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
 
 	data = ctx->output_plugin_private;
     if (data->isLocal) { 
-        MTM_TRACE("Skip action %d in transaction %u\n", change->action, txn->xid);
+        MTM_LOG3("Skip action %d in transaction %u", change->action, txn->xid);
         return;
     }
-    MTM_TRACE("Send action %d in transaction %u to replica\n", change->action, txn->xid);
+    MTM_LOG3("Send action %d in transaction %u to replica", change->action, txn->xid);
 
  	/* Avoid leaking memory by using and resetting our own context */
 	old = MemoryContextSwitchTo(data->context);