More cosmetic changes

Author: pct960

src/backend/access/transam/xact.c

@@ -1489,18 +1489,11 @@ RecordTransactionCommit(void)
 	 * anyway if we crash.)
 	 */
 
-	//XLogRecPtr remoteFlushLSN = ((volatile WalSndCtlData *) WalSndCtl)->lsn[Min(synchronous_commit, SYNC_REP_WAIT_APPLY)];
-
-	//elog(INFO, "maxLSN = (%d), remoteflushlsn = (%d), active backends = (%d)", maxLSN, remoteFlushLSN, MinimumActiveBackends(1));
 
 	if ((wrote_xlog && markXidCommitted &&
 		 synchronous_commit > SYNCHRONOUS_COMMIT_OFF) ||
 		forceSyncCommit || nrels > 0)
 	{
-		//XLogRecPtr maxLSN = XLogGetMaxLSN(0);
-		//elog(INFO, "XactLastRecEnd=(%d), maxLSN=(%d), WalSndCtl->lsn[mode]=(%d, %d, %d)", XactLastRecEnd, maxLSN, WalSndCtl->lsn[0], WalSndCtl->lsn[1], WalSndCtl->lsn[2]);
-		//XLogFlush(XactLastRecEnd);
-
 		/*
 		 * Now we may update the CLOG, if we wrote a COMMIT record above
 		 */
@@ -1557,10 +1550,6 @@ RecordTransactionCommit(void)
 	 * in the procarray and continue to hold locks.
 	 */
 
-	//elog(INFO, "xid = (%d), xmin = (%d), xmax = (%d)", xid, MyProc->xmin,XidFromFullTransactionId(ShmemVariableCache->latestCompletedXid));
-	//if (wrote_xlog && markXidCommitted)
-	//	SyncRepWaitForLSN(XactLastRecEnd, true);
-
 	/* remember end of last commit record */
 	XactLastCommitEnd = XactLastRecEnd;
 

src/backend/replication/syncrep.c

@@ -105,14 +105,6 @@ static bool SyncRepGetSyncRecPtr(XLogRecPtr *writePtr,
 								 XLogRecPtr *flushPtr,
 								 XLogRecPtr *applyPtr,
 								 bool *am_sync);
-static bool SyncRepGetLatestSyncRecPtr(XLogRecPtr *writePtr,
-								 XLogRecPtr *flushPtr,
-								 XLogRecPtr *applyPtr);
-static void SyncRepGetNewestSyncRecPtr(XLogRecPtr *writePtr,
-									   XLogRecPtr *flushPtr,
-									   XLogRecPtr *applyPtr,
-									   SyncRepStandbyData *sync_standbys,
-									   int num_standbys);
 static void SyncRepGetOldestSyncRecPtr(XLogRecPtr *writePtr,
 									   XLogRecPtr *flushPtr,
 									   XLogRecPtr *applyPtr,
@@ -153,7 +145,7 @@ static bool SyncRepQueueIsOrderedByLSN(int mode);
  * remote_apply, because only commit records provide apply feedback.
  */
 void
-SyncRepWaitForLSN(XLogRecPtr lsn, bool commit /*, bool readOnlyWait */)
+SyncRepWaitForLSN(XLogRecPtr lsn, bool commit)
 {
 	char	   *new_status = NULL;
 	const char *old_status;
@@ -206,7 +198,6 @@ SyncRepWaitForLSN(XLogRecPtr lsn, bool commit /*, bool readOnlyWait */)
 	if (!WalSndCtl->sync_standbys_defined ||
 		lsn <= WalSndCtl->lsn[mode])
 	{
-		//elog(INFO, "early return from syncrep");
 		LWLockRelease(SyncRepLock);
 		return;
 	}
@@ -596,7 +587,6 @@ SyncRepGetSyncRecPtr(XLogRecPtr *writePtr, XLogRecPtr *flushPtr,
 	 */
 	if (!(*am_sync) || num_standbys < SyncRepConfig->num_sync)
 	{
-		//elog(INFO, "Not enough standbys, returning. num_standbys = (%d), num_sync = (%d)", num_standbys, SyncRepConfig->num_sync);
 		pfree(sync_standbys);
 		return false;
 	}
@@ -907,7 +897,6 @@ SyncRepWakeQueue(bool all, int mode)
 		 * Assume the queue is ordered by LSN
 		 */
 
-		//elog(INFO, "In SyncRepWakeQueue. walsndctl->lsn = (%d), proc->waitlsn = (%d)", walsndctl->lsn[mode], proc->waitLSN);
 		if (!all && walsndctl->lsn[mode] < proc->waitLSN)
 			return numprocs;
 

src/backend/replication/walsender.c

@@ -685,7 +685,6 @@ SendTimeLineHistory(TimeLineHistoryCmd *cmd)
 static void
 StartReplication(StartReplicationCmd *cmd)
 {
-	//elog(INFO, "in start replication");
 	StringInfoData buf;
 	XLogRecPtr	FlushPtr;
 	TimeLineID	FlushTLI;
@@ -803,11 +802,9 @@ StartReplication(StartReplicationCmd *cmd)
 
 	streamingDoneSending = streamingDoneReceiving = false;
 
-	//elog(INFO, "before entering copy mode");
 	/* If there is nothing to stream, don't even enter COPY mode */
 	if (!sendTimeLineIsHistoric || cmd->startpoint < sendTimeLineValidUpto)
 	{
-		//elog(INFO, "inside copy mode if cond");
 		/*
 		 * When we first start replication the standby will be behind the
 		 * primary. For some applications, for example synchronous
@@ -838,7 +835,6 @@ StartReplication(StartReplicationCmd *cmd)
 							LSN_FORMAT_ARGS(FlushPtr))));
 		}
 
-		//elog(INFO, "started streaming");
 		/* Start streaming from the requested point */
 		sentPtr = cmd->startpoint;
 
@@ -860,7 +856,6 @@ StartReplication(StartReplicationCmd *cmd)
 		WalSndSetState(WALSNDSTATE_STARTUP);
 
 		Assert(streamingDoneSending && streamingDoneReceiving);
-		//elog(INFO, "done streaming");
 	}
 
 	if (cmd->slotname)
@@ -1430,7 +1425,6 @@ WalSndWriteData(LogicalDecodingContext *ctx, XLogRecPtr lsn, TransactionId xid,
 static void
 ProcessPendingWrites(void)
 {
-	//elog(INFO, "walsend waiting for a write");
 	for (;;)
 	{
 		long		sleeptime;
@@ -1471,8 +1465,6 @@ ProcessPendingWrites(void)
 			WalSndShutdown();
 	}
 
-	//elog(INFO, "walsender latch set!");
-
 	/* reactivate latch so WalSndLoop knows to continue */
 	SetLatch(MyLatch);
 }
@@ -1575,7 +1567,6 @@ WalSndWaitForWal(XLogRecPtr loc)
 
 	for (;;)
 	{
-		//elog(INFO, "in walsndwaitforwal");
 		long		sleeptime;
 
 		/* Clear any already-pending wakeups */
@@ -1673,8 +1664,6 @@ WalSndWaitForWal(XLogRecPtr loc)
 		if (pq_is_send_pending())
 			wakeEvents |= WL_SOCKET_WRITEABLE;
 
-		//elog(INFO, "Waiting for walsndwait");
-
 		WalSndWait(wakeEvents, sleeptime, WAIT_EVENT_WAL_SENDER_WAIT_WAL);
 	}
 

src/backend/storage/ipc/procarray.c

@@ -2352,9 +2352,6 @@ GetSnapshotData(Snapshot snapshot)
 			if (NormalTransactionIdPrecedes(xid, xmin))
 				xmin = xid;
 
-			//if(allProcs[arrayP->pgprocnos[pgxactoff]].syncRepState == 1)
-			//	continue;
-
 			/* Add XID to snapshot. */
 			xip[count++] = xid;
 

src/backend/tcop/postgres.c

@@ -1044,8 +1044,6 @@ exec_simple_query(const char *query_string)
 	 */
 	parsetree_list = pg_parse_query(query_string);
 
-	//elog(FATAL, "just testing here");
-
 	/* Log immediately if dictated by log_statement */
 	if (check_log_statement(parsetree_list))
 	{