@@ -46,8 +46,7 @@ static bool ProcessXLogDataMsg(PGconn *conn, StreamCtl *stream, char *copybuf, i
4646XLogRecPtr * blockpos );
4747static PGresult * HandleEndOfCopyStream (PGconn * conn ,StreamCtl * stream ,char * copybuf ,
4848XLogRecPtr blockpos ,XLogRecPtr * stoppos );
49- static bool CheckCopyStreamStop (PGconn * conn ,StreamCtl * stream ,XLogRecPtr blockpos ,
50- XLogRecPtr * stoppos );
49+ static bool CheckCopyStreamStop (PGconn * conn ,StreamCtl * stream ,XLogRecPtr blockpos );
5150static long CalculateCopyStreamSleeptime (TimestampTz now ,int standby_message_timeout ,
5251TimestampTz last_status );
5352
@@ -747,7 +746,7 @@ HandleCopyStream(PGconn *conn, StreamCtl *stream,
747746/*
748747 * Check if we should continue streaming, or abort at this point.
749748 */
750- if (!CheckCopyStreamStop (conn ,stream ,blockpos , stoppos ))
749+ if (!CheckCopyStreamStop (conn ,stream ,blockpos ))
751750gotoerror ;
752751
753752now = feGetCurrentTimestamp ();
@@ -825,7 +824,7 @@ HandleCopyStream(PGconn *conn, StreamCtl *stream,
825824 * Check if we should continue streaming, or abort at this
826825 * point.
827826 */
828- if (!CheckCopyStreamStop (conn ,stream ,blockpos , stoppos ))
827+ if (!CheckCopyStreamStop (conn ,stream ,blockpos ))
829828gotoerror ;
830829}
831830else
@@ -1203,8 +1202,7 @@ HandleEndOfCopyStream(PGconn *conn, StreamCtl *stream, char *copybuf,
12031202 * Check if we should continue streaming, or abort at this point.
12041203 */
12051204static bool
1206- CheckCopyStreamStop (PGconn * conn ,StreamCtl * stream ,XLogRecPtr blockpos ,
1207- XLogRecPtr * stoppos )
1205+ CheckCopyStreamStop (PGconn * conn ,StreamCtl * stream ,XLogRecPtr blockpos )
12081206{
12091207if (still_sending && stream -> stream_stop (blockpos ,stream -> timeline , false))
12101208{