@@ -38,8 +38,8 @@ static int CopyStreamReceive(PGconn *conn, long timeout, pgsocket stop_socket,
38
38
char * * buffer );
39
39
static bool ProcessKeepaliveMsg (PGconn * conn , StreamCtl * stream , char * copybuf ,
40
40
int len , XLogRecPtr blockpos , TimestampTz * last_status );
41
- static bool ProcessXLogDataMsg (PGconn * conn , StreamCtl * stream , char * copybuf , int len ,
42
- XLogRecPtr * blockpos );
41
+ static bool ProcessWALDataMsg (PGconn * conn , StreamCtl * stream , char * copybuf , int len ,
42
+ XLogRecPtr * blockpos );
43
43
static PGresult * HandleEndOfCopyStream (PGconn * conn , StreamCtl * stream , char * copybuf ,
44
44
XLogRecPtr blockpos , XLogRecPtr * stoppos );
45
45
static bool CheckCopyStreamStop (PGconn * conn , StreamCtl * stream , XLogRecPtr blockpos );
@@ -831,7 +831,7 @@ HandleCopyStream(PGconn *conn, StreamCtl *stream,
831
831
}
832
832
else if (copybuf [0 ] == 'w' )
833
833
{
834
- if (!ProcessXLogDataMsg (conn , stream , copybuf , r , & blockpos ))
834
+ if (!ProcessWALDataMsg (conn , stream , copybuf , r , & blockpos ))
835
835
goto error ;
836
836
837
837
/*
@@ -1041,11 +1041,11 @@ ProcessKeepaliveMsg(PGconn *conn, StreamCtl *stream, char *copybuf, int len,
1041
1041
}
1042
1042
1043
1043
/*
1044
- * Process XLogData message.
1044
+ * Process WALData message.
1045
1045
*/
1046
1046
static bool
1047
- ProcessXLogDataMsg (PGconn * conn , StreamCtl * stream , char * copybuf , int len ,
1048
- XLogRecPtr * blockpos )
1047
+ ProcessWALDataMsg (PGconn * conn , StreamCtl * stream , char * copybuf , int len ,
1048
+ XLogRecPtr * blockpos )
1049
1049
{
1050
1050
int xlogoff ;
1051
1051
int bytes_left ;
@@ -1054,13 +1054,13 @@ ProcessXLogDataMsg(PGconn *conn, StreamCtl *stream, char *copybuf, int len,
1054
1054
1055
1055
/*
1056
1056
* Once we've decided we don't want to receive any more, just ignore any
1057
- * subsequent XLogData messages.
1057
+ * subsequent WALData messages.
1058
1058
*/
1059
1059
if (!(still_sending ))
1060
1060
return true;
1061
1061
1062
1062
/*
1063
- * Read the header of the XLogData message, enclosed in the CopyData
1063
+ * Read the header of the WALData message, enclosed in the CopyData
1064
1064
* message. We only need the WAL location field (dataStart), the rest of
1065
1065
* the header is ignored.
1066
1066
*/
@@ -1162,7 +1162,7 @@ ProcessXLogDataMsg(PGconn *conn, StreamCtl *stream, char *copybuf, int len,
1162
1162
return false;
1163
1163
}
1164
1164
still_sending = false;
1165
- return true; /* ignore the rest of this XLogData packet */
1165
+ return true; /* ignore the rest of this WALData packet */
1166
1166
}
1167
1167
}
1168
1168
}
0 commit comments