@@ -161,37 +161,37 @@ typedef void (*walrcv_disconnect_fn) (WalReceiverConn *conn);
161
161
162
162
typedef struct WalReceiverFunctionsType
163
163
{
164
- walrcv_connect_fn connect ;
165
- walrcv_get_conninfo_fn get_conninfo ;
166
- walrcv_identify_system_fn identify_system ;
167
- walrcv_readtimelinehistoryfile_fn readtimelinehistoryfile ;
168
- walrcv_startstreaming_fn startstreaming ;
169
- walrcv_endstreaming_fn endstreaming ;
170
- walrcv_receive_fn receive ;
171
- walrcv_send_fn send ;
172
- walrcv_disconnect_fn disconnect ;
164
+ walrcv_connect_fn walrcv_connect ;
165
+ walrcv_get_conninfo_fn walrcv_get_conninfo ;
166
+ walrcv_identify_system_fn walrcv_identify_system ;
167
+ walrcv_readtimelinehistoryfile_fn walrcv_readtimelinehistoryfile ;
168
+ walrcv_startstreaming_fn walrcv_startstreaming ;
169
+ walrcv_endstreaming_fn walrcv_endstreaming ;
170
+ walrcv_receive_fn walrcv_receive ;
171
+ walrcv_send_fn walrcv_send ;
172
+ walrcv_disconnect_fn walrcv_disconnect ;
173
173
} WalReceiverFunctionsType ;
174
174
175
175
extern PGDLLIMPORT WalReceiverFunctionsType * WalReceiverFunctions ;
176
176
177
177
#define walrcv_connect (conninfo , logical , appname ) \
178
- WalReceiverFunctions->connect (conninfo, logical, appname)
178
+ WalReceiverFunctions->walrcv_connect (conninfo, logical, appname)
179
179
#define walrcv_get_conninfo (conn ) \
180
- WalReceiverFunctions->get_conninfo (conn)
180
+ WalReceiverFunctions->walrcv_get_conninfo (conn)
181
181
#define walrcv_identify_system (conn , primary_tli ) \
182
- WalReceiverFunctions->identify_system (conn, primary_tli)
182
+ WalReceiverFunctions->walrcv_identify_system (conn, primary_tli)
183
183
#define walrcv_readtimelinehistoryfile (conn , tli , filename , content , size ) \
184
- WalReceiverFunctions->readtimelinehistoryfile (conn, tli, filename, content, size)
184
+ WalReceiverFunctions->walrcv_readtimelinehistoryfile (conn, tli, filename, content, size)
185
185
#define walrcv_startstreaming (conn , tli , startpoint , slotname ) \
186
- WalReceiverFunctions->startstreaming (conn, tli, startpoint, slotname)
186
+ WalReceiverFunctions->walrcv_startstreaming (conn, tli, startpoint, slotname)
187
187
#define walrcv_endstreaming (conn , next_tli ) \
188
- WalReceiverFunctions->endstreaming (conn, next_tli)
188
+ WalReceiverFunctions->walrcv_endstreaming (conn, next_tli)
189
189
#define walrcv_receive (conn , buffer , wait_fd ) \
190
- WalReceiverFunctions->receive (conn, buffer, wait_fd)
190
+ WalReceiverFunctions->walrcv_receive (conn, buffer, wait_fd)
191
191
#define walrcv_send (conn , buffer , nbytes ) \
192
- WalReceiverFunctions->send (conn, buffer, nbytes)
192
+ WalReceiverFunctions->walrcv_send (conn, buffer, nbytes)
193
193
#define walrcv_disconnect (conn ) \
194
- WalReceiverFunctions->disconnect (conn)
194
+ WalReceiverFunctions->walrcv_disconnect (conn)
195
195
196
196
/* prototypes for functions in walreceiver.c */
197
197
extern void WalReceiverMain (void ) pg_attribute_noreturn ();
0 commit comments