@@ -1619,18 +1619,20 @@ StreamLog(void *arg)
1619
1619
starttli );
1620
1620
1621
1621
#if PG_VERSION_NUM >= 90600
1622
- StreamCtl ctl ;
1623
- ctl .startpos = startpos ;
1624
- ctl .timeline = starttli ;
1625
- ctl .sysidentifier = NULL ;
1626
- ctl .basedir = basedir ;
1627
- ctl .stream_stop = stop_streaming ;
1628
- ctl .standby_message_timeout = standby_message_timeout ;
1629
- ctl .partial_suffix = NULL ;
1630
- ctl .synchronous = false;
1631
- ctl .mark_done = false;
1632
- if (ReceiveXlogStream (conn , & ctl ) == false)
1633
- elog (ERROR , "Problem in recivexlog" );
1622
+ {
1623
+ StreamCtl ctl ;
1624
+ ctl .startpos = startpos ;
1625
+ ctl .timeline = starttli ;
1626
+ ctl .sysidentifier = NULL ;
1627
+ ctl .basedir = basedir ;
1628
+ ctl .stream_stop = stop_streaming ;
1629
+ ctl .standby_message_timeout = standby_message_timeout ;
1630
+ ctl .partial_suffix = NULL ;
1631
+ ctl .synchronous = false;
1632
+ ctl .mark_done = false;
1633
+ if (ReceiveXlogStream (conn , & ctl ) == false)
1634
+ elog (ERROR , "Problem in recivexlog" );
1635
+ }
1634
1636
#else
1635
1637
if (ReceiveXlogStream (conn , startpos , starttli , NULL , basedir ,
1636
1638
stop_streaming , standby_message_timeout , NULL ,
0 commit comments