@@ -688,7 +688,7 @@ SendTimeLineHistory(TimeLineHistoryCmd *cmd)
688
688
static void
689
689
StartReplication (StartReplicationCmd * cmd )
690
690
{
691
- elog (INFO , "in start replication" );
691
+ // elog(INFO, "in start replication");
692
692
StringInfoData buf ;
693
693
XLogRecPtr FlushPtr ;
694
694
TimeLineID FlushTLI ;
@@ -806,11 +806,11 @@ StartReplication(StartReplicationCmd *cmd)
806
806
807
807
streamingDoneSending = streamingDoneReceiving = false;
808
808
809
- elog (INFO , "before entering copy mode" );
809
+ // elog(INFO, "before entering copy mode");
810
810
/* If there is nothing to stream, don't even enter COPY mode */
811
811
if (!sendTimeLineIsHistoric || cmd -> startpoint < sendTimeLineValidUpto )
812
812
{
813
- elog (INFO , "inside copy mode if cond" );
813
+ // elog(INFO, "inside copy mode if cond");
814
814
/*
815
815
* When we first start replication the standby will be behind the
816
816
* primary. For some applications, for example synchronous
@@ -841,7 +841,7 @@ StartReplication(StartReplicationCmd *cmd)
841
841
LSN_FORMAT_ARGS (FlushPtr ))));
842
842
}
843
843
844
- elog (INFO , "started streaming" );
844
+ // elog(INFO, "started streaming");
845
845
/* Start streaming from the requested point */
846
846
sentPtr = cmd -> startpoint ;
847
847
@@ -863,7 +863,7 @@ StartReplication(StartReplicationCmd *cmd)
863
863
WalSndSetState (WALSNDSTATE_STARTUP );
864
864
865
865
Assert (streamingDoneSending && streamingDoneReceiving );
866
- elog (INFO , "dome streaming" );
866
+ // elog(INFO, "done streaming");
867
867
}
868
868
869
869
if (cmd -> slotname )
@@ -1433,7 +1433,7 @@ WalSndWriteData(LogicalDecodingContext *ctx, XLogRecPtr lsn, TransactionId xid,
1433
1433
static void
1434
1434
ProcessPendingWrites (void )
1435
1435
{
1436
- elog (INFO , "walsend waiting for a write" );
1436
+ // elog(INFO, "walsend waiting for a write");
1437
1437
for (;;)
1438
1438
{
1439
1439
long sleeptime ;
@@ -1474,7 +1474,7 @@ ProcessPendingWrites(void)
1474
1474
WalSndShutdown ();
1475
1475
}
1476
1476
1477
- elog (INFO , "walsender latch set!" );
1477
+ // elog(INFO, "walsender latch set!");
1478
1478
1479
1479
/* reactivate latch so WalSndLoop knows to continue */
1480
1480
SetLatch (MyLatch );
@@ -1578,7 +1578,7 @@ WalSndWaitForWal(XLogRecPtr loc)
1578
1578
1579
1579
for (;;)
1580
1580
{
1581
- elog (INFO , "in walsndwaitforwal" );
1581
+ // elog(INFO, "in walsndwaitforwal");
1582
1582
long sleeptime ;
1583
1583
1584
1584
/* Clear any already-pending wakeups */
@@ -1676,7 +1676,7 @@ WalSndWaitForWal(XLogRecPtr loc)
1676
1676
if (pq_is_send_pending ())
1677
1677
wakeEvents |= WL_SOCKET_WRITEABLE ;
1678
1678
1679
- elog (INFO , "Waiting for walsndwait" );
1679
+ // elog(INFO, "Waiting for walsndwait");
1680
1680
1681
1681
WalSndWait (wakeEvents , sleeptime , WAIT_EVENT_WAL_SENDER_WAIT_WAL );
1682
1682
}
@@ -3657,7 +3657,7 @@ pg_stat_get_wal_senders(PG_FUNCTION_ARGS)
3657
3657
static void
3658
3658
WalSndKeepalive (bool requestReply , XLogRecPtr writePtr )
3659
3659
{
3660
- elog (INFO , "sending replication keepalive" );
3660
+ // elog(INFO, "sending replication keepalive");
3661
3661
3662
3662
/* construct the message... */
3663
3663
resetStringInfo (& output_message );
@@ -3701,7 +3701,7 @@ WalSndKeepaliveIfNecessary(void)
3701
3701
wal_sender_timeout / 2 );
3702
3702
if (last_processing >= ping_time || request_keepalive )
3703
3703
{
3704
- elog (INFO , "sending wakeup probably because keepalive was requested!" );
3704
+ // elog(INFO, "sending wakeup probably because keepalive was requested!");
3705
3705
WalSndKeepalive (true, InvalidXLogRecPtr );
3706
3706
3707
3707
/* Try to flush pending output to the client */
0 commit comments