1 /* DO NOT EDIT: automatically built by dist/s_include. */
2 #ifndef	_repmgr_ext_h_
3 #define	_repmgr_ext_h_
4 
5 #if defined(__cplusplus)
6 extern "C" {
7 #endif
8 
9 int __repmgr_init_recover __P((ENV *, DB_DISTAB *));
10 void __repmgr_handshake_marshal __P((ENV *, __repmgr_handshake_args *, u_int8_t *));
11 int __repmgr_handshake_unmarshal __P((ENV *, __repmgr_handshake_args *, u_int8_t *, size_t, u_int8_t **));
12 void __repmgr_v3handshake_marshal __P((ENV *, __repmgr_v3handshake_args *, u_int8_t *));
13 int __repmgr_v3handshake_unmarshal __P((ENV *, __repmgr_v3handshake_args *, u_int8_t *, size_t, u_int8_t **));
14 void __repmgr_v2handshake_marshal __P((ENV *, __repmgr_v2handshake_args *, u_int8_t *));
15 int __repmgr_v2handshake_unmarshal __P((ENV *, __repmgr_v2handshake_args *, u_int8_t *, size_t, u_int8_t **));
16 void __repmgr_parm_refresh_marshal __P((ENV *, __repmgr_parm_refresh_args *, u_int8_t *));
17 int __repmgr_parm_refresh_unmarshal __P((ENV *, __repmgr_parm_refresh_args *, u_int8_t *, size_t, u_int8_t **));
18 void __repmgr_v6permlsn_marshal __P((ENV *, __repmgr_v6permlsn_args *, u_int8_t *));
19 int __repmgr_v6permlsn_unmarshal __P((ENV *, __repmgr_v6permlsn_args *, u_int8_t *, size_t, u_int8_t **));
20 void __repmgr_permlsn_marshal __P((ENV *, __repmgr_permlsn_args *, u_int8_t *));
21 int __repmgr_permlsn_unmarshal __P((ENV *, __repmgr_permlsn_args *, u_int8_t *, size_t, u_int8_t **));
22 void __repmgr_heartbeat_marshal __P((ENV *, __repmgr_heartbeat_args *, u_int8_t *));
23 int __repmgr_heartbeat_unmarshal __P((ENV *, __repmgr_heartbeat_args *, u_int8_t *, size_t, u_int8_t **));
24 void __repmgr_readonly_response_marshal __P((ENV *, __repmgr_readonly_response_args *, u_int8_t *));
25 int __repmgr_readonly_response_unmarshal __P((ENV *, __repmgr_readonly_response_args *, u_int8_t *, size_t, u_int8_t **));
26 void __repmgr_version_proposal_marshal __P((ENV *, __repmgr_version_proposal_args *, u_int8_t *));
27 int __repmgr_version_proposal_unmarshal __P((ENV *, __repmgr_version_proposal_args *, u_int8_t *, size_t, u_int8_t **));
28 void __repmgr_version_confirmation_marshal __P((ENV *, __repmgr_version_confirmation_args *, u_int8_t *));
29 int __repmgr_version_confirmation_unmarshal __P((ENV *, __repmgr_version_confirmation_args *, u_int8_t *, size_t, u_int8_t **));
30 void __repmgr_msg_hdr_marshal __P((ENV *, __repmgr_msg_hdr_args *, u_int8_t *));
31 int __repmgr_msg_hdr_unmarshal __P((ENV *, __repmgr_msg_hdr_args *, u_int8_t *, size_t, u_int8_t **));
32 void __repmgr_msg_metadata_marshal __P((ENV *, __repmgr_msg_metadata_args *, u_int8_t *));
33 int __repmgr_msg_metadata_unmarshal __P((ENV *, __repmgr_msg_metadata_args *, u_int8_t *, size_t, u_int8_t **));
34 int __repmgr_membership_key_marshal __P((ENV *, __repmgr_membership_key_args *, u_int8_t *, size_t, size_t *));
35 int __repmgr_membership_key_unmarshal __P((ENV *, __repmgr_membership_key_args *, u_int8_t *, size_t, u_int8_t **));
36 void __repmgr_membership_data_marshal __P((ENV *, __repmgr_membership_data_args *, u_int8_t *));
37 int __repmgr_membership_data_unmarshal __P((ENV *, __repmgr_membership_data_args *, u_int8_t *, size_t, u_int8_t **));
38 void __repmgr_v4membership_data_marshal __P((ENV *, __repmgr_v4membership_data_args *, u_int8_t *));
39 int __repmgr_v4membership_data_unmarshal __P((ENV *, __repmgr_v4membership_data_args *, u_int8_t *, size_t, u_int8_t **));
40 void __repmgr_member_metadata_marshal __P((ENV *, __repmgr_member_metadata_args *, u_int8_t *));
41 int __repmgr_member_metadata_unmarshal __P((ENV *, __repmgr_member_metadata_args *, u_int8_t *, size_t, u_int8_t **));
42 int __repmgr_gm_fwd_marshal __P((ENV *, __repmgr_gm_fwd_args *, u_int8_t *, size_t, size_t *));
43 int __repmgr_gm_fwd_unmarshal __P((ENV *, __repmgr_gm_fwd_args *, u_int8_t *, size_t, u_int8_t **));
44 void __repmgr_membr_vers_marshal __P((ENV *, __repmgr_membr_vers_args *, u_int8_t *));
45 int __repmgr_membr_vers_unmarshal __P((ENV *, __repmgr_membr_vers_args *, u_int8_t *, size_t, u_int8_t **));
46 int __repmgr_site_info_marshal __P((ENV *, __repmgr_site_info_args *, u_int8_t *, size_t, size_t *));
47 int __repmgr_site_info_unmarshal __P((ENV *, __repmgr_site_info_args *, u_int8_t *, size_t, u_int8_t **));
48 int __repmgr_v4site_info_marshal __P((ENV *, __repmgr_v4site_info_args *, u_int8_t *, size_t, size_t *));
49 int __repmgr_v4site_info_unmarshal __P((ENV *, __repmgr_v4site_info_args *, u_int8_t *, size_t, u_int8_t **));
50 void __repmgr_connect_reject_marshal __P((ENV *, __repmgr_connect_reject_args *, u_int8_t *));
51 int __repmgr_connect_reject_unmarshal __P((ENV *, __repmgr_connect_reject_args *, u_int8_t *, size_t, u_int8_t **));
52 void __repmgr_v4connect_reject_marshal __P((ENV *, __repmgr_v4connect_reject_args *, u_int8_t *));
53 int __repmgr_v4connect_reject_unmarshal __P((ENV *, __repmgr_v4connect_reject_args *, u_int8_t *, size_t, u_int8_t **));
54 void __repmgr_lsnhist_match_marshal __P((ENV *, __repmgr_lsnhist_match_args *, u_int8_t *));
55 int __repmgr_lsnhist_match_unmarshal __P((ENV *, __repmgr_lsnhist_match_args *, u_int8_t *, size_t, u_int8_t **));
56 int __repmgr_member_print __P((ENV *, DBT *, DB_LSN *, db_recops, void *));
57 int __repmgr_init_print __P((ENV *, DB_DISTAB *));
58 int __repmgr_init_election __P((ENV *, u_int32_t));
59 int __repmgr_claim_victory __P((ENV *));
60 int __repmgr_turn_on_elections __P((ENV *));
61 int __repmgr_start_pp __P((DB_ENV *, int, u_int32_t));
62 int __repmgr_start_int __P((ENV *, int, u_int32_t));
63 int __repmgr_valid_config __P((ENV *, u_int32_t));
64 int __repmgr_prefmas_auto_config __P((DB_ENV *, u_int32_t *));
65 int __repmgr_autostart __P((ENV *));
66 int __repmgr_start_selector __P((ENV *));
67 int __repmgr_close __P((ENV *));
68 int __repmgr_stop __P((ENV *));
69 int __repmgr_set_ssl_config_pp __P((DB_ENV *, int, char *value));
70 int __repmgr_set_ack_policy __P((DB_ENV *, int));
71 int __repmgr_get_ack_policy __P((DB_ENV *, int *));
72 int __repmgr_set_incoming_queue_max __P((DB_ENV *, u_int32_t, u_int32_t));
73 int __repmgr_get_incoming_queue_max __P((DB_ENV *, u_int32_t *, u_int32_t *));
74 void __repmgr_set_incoming_queue_redzone __P((void *, u_int32_t, u_int32_t));
75 int __repmgr_get_incoming_queue_redzone __P((DB_ENV *, u_int32_t *, u_int32_t *));
76 int __repmgr_get_incoming_queue_fullevent __P((DB_ENV *, int *));
77 int __repmgr_env_create __P((ENV *, DB_REP *));
78 void __repmgr_env_destroy __P((ENV *, DB_REP *));
79 int __repmgr_stop_threads __P((ENV *));
80 int __repmgr_local_site __P((DB_ENV *, DB_SITE **));
81 int __repmgr_channel __P((DB_ENV *, int, DB_CHANNEL **, u_int32_t));
82 int __repmgr_set_msg_dispatch __P((DB_ENV *, void (*)(DB_ENV *, DB_CHANNEL *, DBT *, u_int32_t, u_int32_t), u_int32_t));
83 int __repmgr_send_msg __P((DB_CHANNEL *, DBT *, u_int32_t, u_int32_t));
84 int __repmgr_send_request __P((DB_CHANNEL *, DBT *, u_int32_t, DBT *, db_timeout_t, u_int32_t));
85 int __repmgr_send_response __P((DB_CHANNEL *, DBT *, u_int32_t, u_int32_t));
86 int __repmgr_channel_close __P((DB_CHANNEL *, u_int32_t));
87 int __repmgr_channel_timeout __P((DB_CHANNEL *, db_timeout_t));
88 int __repmgr_send_request_inval __P((DB_CHANNEL *, DBT *, u_int32_t, DBT *, db_timeout_t, u_int32_t));
89 int __repmgr_channel_close_inval __P((DB_CHANNEL *, u_int32_t));
90 int __repmgr_channel_timeout_inval __P((DB_CHANNEL *, db_timeout_t));
91 int __repmgr_join_group __P((ENV *));
92 int __repmgr_site __P((DB_ENV *, const char *, u_int, DB_SITE **, u_int32_t));
93 int __repmgr_site_by_eid __P((DB_ENV *, int, DB_SITE **));
94 int __repmgr_get_site_address __P((DB_SITE *, const char **, u_int *));
95 int __repmgr_get_eid __P((DB_SITE *, int *));
96 int __repmgr_get_config __P((DB_SITE *, u_int32_t, u_int32_t *));
97 int __repmgr_site_config_pp __P((DB_SITE *, u_int32_t, u_int32_t));
98 int __repmgr_site_config_int __P((DB_SITE *, u_int32_t, u_int32_t));
99 int __repmgr_site_close __P((DB_SITE *));
100 int __repmgr_set_socket __P((DB_ENV *, int (*)(DB_ENV *, DB_REPMGR_SOCKET, int *, u_int32_t)));
101 void *__repmgr_msg_thread __P((void *));
102 int __repmgr_send_err_resp __P((ENV *, CHANNEL *, int));
103 int __repmgr_handle_event __P((ENV *, u_int32_t, void *));
104 int __repmgr_update_membership __P((ENV *, DB_THREAD_INFO *, int, u_int32_t, u_int32_t));
105 int __repmgr_set_gm_version __P((ENV *, DB_THREAD_INFO *, DB_TXN *, u_int32_t));
106 int __repmgr_setup_gmdb_op __P((ENV *, DB_THREAD_INFO *, DB_TXN **, u_int32_t));
107 int __repmgr_cleanup_gmdb_op __P((ENV *, int));
108 int __repmgr_hold_master_role __P((ENV *, REPMGR_CONNECTION *, u_int32_t));
109 int __repmgr_rlse_master_role __P((ENV *));
110 void __repmgr_set_sites __P((ENV *));
111 int __repmgr_connect __P((ENV *, repmgr_netaddr_t *, REPMGR_CONNECTION **, int *));
112 int __repmgr_send __P((DB_ENV *, const DBT *, const DBT *, const DB_LSN *, int, u_int32_t));
113 int __repmgr_sync_siteaddr __P((ENV *));
114 int __repmgr_send_broadcast __P((ENV *, u_int, const DBT *, const DBT *, u_int *, u_int *, int *));
115 int __repmgr_send_one __P((ENV *, REPMGR_CONNECTION *, u_int, const DBT *, const DBT *, db_timeout_t));
116 int __repmgr_send_many __P((ENV *, REPMGR_CONNECTION *, REPMGR_IOVECS *, db_timeout_t));
117 int __repmgr_send_own_msg __P((ENV *, REPMGR_CONNECTION *, u_int32_t, u_int8_t *, u_int32_t));
118 int __repmgr_write_iovecs __P((ENV *, REPMGR_CONNECTION *, REPMGR_IOVECS *, size_t *));
119 int __repmgr_bust_connection __P((ENV *, REPMGR_CONNECTION *));
120 int __repmgr_disable_connection __P((ENV *, REPMGR_CONNECTION *));
121 int __repmgr_cleanup_defunct __P((ENV *, REPMGR_CONNECTION *));
122 int __repmgr_close_connection __P((ENV *, REPMGR_CONNECTION *));
123 int __repmgr_decr_conn_ref __P((ENV *, REPMGR_CONNECTION *));
124 int __repmgr_destroy_conn __P((ENV *, REPMGR_CONNECTION *));
125 int __repmgr_pack_netaddr __P((ENV *, const char *, u_int, repmgr_netaddr_t *));
126 int __repmgr_getaddr __P((ENV *, const char *, u_int, int, ADDRINFO **));
127 int __repmgr_listen __P((ENV *));
128 int __repmgr_net_close __P((ENV *));
129 void __repmgr_net_destroy __P((ENV *, DB_REP *));
130 void __repmgr_print_addr __P((ENV *, struct sockaddr *, const char *, int, int));
131 int __repmgr_set_ssl_ctx __P((ENV *));
132 int __repmgr_ssl_accept __P((ENV *, REPMGR_CONNECTION *, socket_t));
133 int __repmgr_ssl_connect __P((ENV *, socket_t, REPMGR_CONNECTION *));
134 int __repmgr_ssl_shutdown __P ((ENV *, REPMGR_CONNECTION *));
135 int __repmgr_ssl_write __P((REPMGR_CONNECTION *, char *, size_t, int *));
136 ssize_t __repmgr_ssl_writemsg __P((REPMGR_CONNECTION *, char *, size_t, int *));
137 ssize_t __repmgr_ssl_writev __P((REPMGR_CONNECTION *, db_iovec_t *, int, size_t *));
138 int __repmgr_ssl_readv __P((REPMGR_CONNECTION *, db_iovec_t *, int, size_t *));
139 int __repmgr_ssl_write_possible __P ((REPMGR_CONNECTION *, int, int));
140 int __repmgr_ssl_read_possible __P ((REPMGR_CONNECTION *, int, int));
141 int __repmgr_thread_start __P((ENV *, REPMGR_RUNNABLE *));
142 int __repmgr_thread_join __P((REPMGR_RUNNABLE *));
143 int __repmgr_set_nonblock_conn __P((REPMGR_CONNECTION *));
144 int __repmgr_set_nonblocking __P((socket_t));
145 int __repmgr_wake_waiters __P((ENV *, waiter_t *));
146 int __repmgr_await_cond __P((ENV *, PREDICATE, void *, db_timeout_t, waiter_t *));
147 int __repmgr_await_gmdbop __P((ENV *));
148 void __repmgr_compute_wait_deadline __P((ENV*, struct timespec *, db_timeout_t));
149 int __repmgr_await_drain __P((ENV *, REPMGR_CONNECTION *, db_timeout_t));
150 int __repmgr_alloc_cond __P((cond_var_t *));
151 int __repmgr_free_cond __P((cond_var_t *));
152 void __repmgr_env_create_pf __P((DB_REP *));
153 int __repmgr_create_mutex_pf __P((mgr_mutex_t *));
154 int __repmgr_destroy_mutex_pf __P((mgr_mutex_t *));
155 int __repmgr_init __P((ENV *));
156 int __repmgr_deinit __P((ENV *));
157 int __repmgr_init_waiters __P((ENV *, waiter_t *));
158 int __repmgr_destroy_waiters __P((ENV *, waiter_t *));
159 int __repmgr_lock_mutex __P((mgr_mutex_t *));
160 int __repmgr_unlock_mutex __P((mgr_mutex_t *));
161 int __repmgr_signal __P((cond_var_t *));
162 int __repmgr_wake_msngers __P((ENV*, u_int));
163 int __repmgr_wake_main_thread __P((ENV*));
164 int __repmgr_writev __P((socket_t, db_iovec_t *, int, size_t *));
165 int __repmgr_readv __P((socket_t, db_iovec_t *, int, size_t *));
166 int __repmgr_network_event_handler __P((ENV *));
167 int __repmgr_queue_destroy __P((ENV *));
168 int __repmgr_queue_get __P((ENV *, REPMGR_MESSAGE **, REPMGR_RUNNABLE *));
169 int __repmgr_queue_put __P((ENV *, REPMGR_MESSAGE *));
170 int __repmgr_member_recover __P((ENV *, DBT *, DB_LSN *, db_recops, void *));
171 void *__repmgr_select_thread __P((void *));
172 int __repmgr_bow_out __P((ENV *));
173 int __repmgr_accept __P((ENV *));
174 int __repmgr_compute_timeout __P((ENV *, db_timespec *));
175 REPMGR_SITE *__repmgr_connected_master __P((ENV *));
176 int __repmgr_check_timeouts __P((ENV *));
177 int __repmgr_refresh_selector __P((ENV *));
178 int __repmgr_first_try_connections __P((ENV *));
179 int __repmgr_send_v1_handshake __P((ENV *, REPMGR_CONNECTION *, void *, size_t));
180 int __repmgr_read_from_site __P((ENV *, REPMGR_CONNECTION *));
181 int __repmgr_read_conn __P((REPMGR_CONNECTION *));
182 int __repmgr_prepare_simple_input __P((ENV *, REPMGR_CONNECTION *, __repmgr_msg_hdr_args *));
183 int __repmgr_send_handshake __P((ENV *, REPMGR_CONNECTION *, void *, size_t, u_int32_t));
184 int __repmgr_find_version_info __P((ENV *, REPMGR_CONNECTION *, DBT *));
185 int __repmgr_write_some __P((ENV *, REPMGR_CONNECTION *));
186 int __repmgr_stat_pp __P((DB_ENV *, DB_REPMGR_STAT **, u_int32_t));
187 int __repmgr_stat_print_pp __P((DB_ENV *, u_int32_t));
188 int __repmgr_stat_print __P((ENV *, u_int32_t));
189 int __repmgr_site_list_pp __P((DB_ENV *, u_int *, DB_REPMGR_SITE **));
190 int __repmgr_site_list_int __P((ENV *, u_int *, DB_REPMGR_SITE **));
191 #ifndef HAVE_REPLICATION_THREADS
192 int __repmgr_close __P((ENV *));
193 #endif
194 #ifndef HAVE_REPLICATION_THREADS
195 int __repmgr_get_ack_policy __P((DB_ENV *, int *));
196 #endif
197 #ifndef HAVE_REPLICATION_THREADS
198 int __repmgr_set_ack_policy __P((DB_ENV *, int));
199 #endif
200 #ifndef HAVE_REPLICATION_THREADS
201 int __repmgr_get_incoming_queue_max __P((DB_ENV *, u_int32_t *, u_int32_t *));
202 #endif
203 #ifndef HAVE_REPLICATION_THREADS
204 int __repmgr_set_incoming_queue_max __P((DB_ENV *, u_int32_t, u_int32_t));
205 #endif
206 #ifndef HAVE_REPLICATION_THREADS
207 int __repmgr_get_incoming_queue_redzone __P((DB_ENV *, u_int32_t *, u_int32_t *));
208 #endif
209 #ifndef HAVE_REPLICATION_THREADS
210 int __repmgr_get_incoming_queue_fullevent __P((DB_ENV *, int *));
211 #endif
212 #ifndef HAVE_REPLICATION_THREADS
213 int __repmgr_site __P((DB_ENV *, const char *, u_int, DB_SITE **, u_int32_t));
214 #endif
215 #ifndef HAVE_REPLICATION_THREADS
216 int __repmgr_site_by_eid __P((DB_ENV *, int, DB_SITE **));
217 #endif
218 #ifndef HAVE_REPLICATION_THREADS
219 int __repmgr_local_site __P((DB_ENV *, DB_SITE **));
220 #endif
221 #ifndef HAVE_REPLICATION_THREADS
222 int __repmgr_site_list_pp __P((DB_ENV *, u_int *, DB_REPMGR_SITE **));
223 #endif
224 #ifndef HAVE_REPLICATION_THREADS
225 int __repmgr_start_pp __P((DB_ENV *, int, u_int32_t));
226 #endif
227 #ifndef HAVE_REPLICATION_THREADS
228 int __repmgr_stat_pp __P((DB_ENV *, DB_REPMGR_STAT **, u_int32_t));
229 #endif
230 #ifndef HAVE_REPLICATION_THREADS
231 int __repmgr_stat_print_pp __P((DB_ENV *, u_int32_t));
232 #endif
233 #ifndef HAVE_REPLICATION_THREADS
234 int __repmgr_handle_event __P((ENV *, u_int32_t, void *));
235 #endif
236 #ifndef HAVE_REPLICATION_THREADS
237 int __repmgr_channel __P((DB_ENV *, int, DB_CHANNEL **, u_int32_t));
238 #endif
239 #ifndef HAVE_REPLICATION_THREADS
240 int __repmgr_set_msg_dispatch __P((DB_ENV *, void (*)(DB_ENV *, DB_CHANNEL *, DBT *, u_int32_t, u_int32_t), u_int32_t));
241 #endif
242 #ifndef HAVE_REPLICATION_THREADS
243 int __repmgr_init_recover __P((ENV *, DB_DISTAB *));
244 #endif
245 #ifndef HAVE_REPLICATION_THREADS
246 int __repmgr_set_socket __P((DB_ENV *, int (*)(DB_ENV *, DB_REPMGR_SOCKET, int *, u_int32_t)));
247 #endif
248 #ifndef HAVE_REPLICATION_THREADS
249 int __repmgr_set_ssl_config_pp __P((DB_ENV *, int, char *value));
250 #endif
251 int __repmgr_schedule_connection_attempt __P((ENV *, int, int));
252 int __repmgr_is_server __P((ENV *, REPMGR_SITE *));
253 void __repmgr_reset_for_reading __P((REPMGR_CONNECTION *));
254 int __repmgr_new_connection __P((ENV *, REPMGR_CONNECTION **, socket_t, int));
255 int __repmgr_set_keepalive __P((ENV *, REPMGR_CONNECTION *));
256 int __repmgr_new_site __P((ENV *, REPMGR_SITE**, const char *, u_int));
257 int __repmgr_create_mutex __P((ENV *, mgr_mutex_t **));
258 int __repmgr_destroy_mutex __P((ENV *, mgr_mutex_t *));
259 void __repmgr_cleanup_netaddr __P((ENV *, repmgr_netaddr_t *));
260 void __repmgr_iovec_init __P((REPMGR_IOVECS *));
261 void __repmgr_add_buffer __P((REPMGR_IOVECS *, void *, size_t));
262 void __repmgr_add_dbt __P((REPMGR_IOVECS *, const DBT *));
263 int __repmgr_update_consumed __P((REPMGR_IOVECS *, size_t));
264 int __repmgr_prepare_my_addr __P((ENV *, DBT *));
265 int __repmgr_get_nsites __P((ENV *, u_int32_t *));
266 int __repmgr_thread_failure __P((ENV *, int));
267 char *__repmgr_format_eid_loc __P((DB_REP *, REPMGR_CONNECTION *, char *));
268 char *__repmgr_format_site_loc __P((REPMGR_SITE *, char *));
269 char *__repmgr_format_addr_loc __P((repmgr_netaddr_t *, char *));
270 int __repmgr_repstart __P((ENV *, u_int32_t, u_int32_t));
271 int __repmgr_become_master __P((ENV *, u_int32_t));
272 int __repmgr_each_connection __P((ENV *, CONNECTION_ACTION, void *, int));
273 int __repmgr_open __P((ENV *, void *));
274 int __repmgr_join __P((ENV *, void *));
275 int __repmgr_env_refresh __P((ENV *env));
276 int __repmgr_share_netaddrs __P((ENV *, void *, u_int, u_int));
277 int __repmgr_copy_in_added_sites __P((ENV *));
278 int __repmgr_init_new_sites __P((ENV *, int, int));
279 int __repmgr_failchk __P((ENV *));
280 int __repmgr_master_is_known __P((ENV *));
281 int __repmgr_stable_lsn __P((ENV *, DB_LSN *));
282 int __repmgr_make_request_conn __P((ENV *, repmgr_netaddr_t *, REPMGR_CONNECTION **));
283 int __repmgr_send_sync_msg __P((ENV *, REPMGR_CONNECTION *, u_int32_t, u_int8_t *, u_int32_t));
284 int __repmgr_read_own_msg __P((ENV *, REPMGR_CONNECTION *, u_int32_t *, u_int8_t **, size_t *));
285 int __repmgr_prefmas_connected __P((ENV *));
286 int __repmgr_restart_site_as_client __P((ENV *, int));
287 int __repmgr_make_site_readonly_master __P((ENV *, int, u_int32_t *, DB_LSN *));
288 int __repmgr_lsnhist_match __P((ENV *, DB_THREAD_INFO *, int, int *));
289 int __repmgr_prefmas_get_wait __P((ENV *, u_int32_t *, u_long *));
290 int __repmgr_marshal_member_list __P((ENV *, u_int32_t, u_int8_t **, size_t *));
291 int __repmgr_refresh_membership __P((ENV *, u_int8_t *, size_t, u_int32_t));
292 int __repmgr_reload_gmdb __P((ENV *));
293 int __repmgr_gmdb_version_cmp __P((ENV *, u_int32_t, u_int32_t));
294 int __repmgr_init_save __P((ENV *, DBT *));
295 int __repmgr_init_restore __P((ENV *, DBT *));
296 int __repmgr_defer_op __P((ENV *, u_int32_t));
297 void __repmgr_fire_conn_err_event __P((ENV *, REPMGR_CONNECTION *, int));
298 void __repmgr_print_conn_err __P((ENV *, repmgr_netaddr_t *, int));
299 int __repmgr_become_client __P((ENV *));
300 REPMGR_SITE *__repmgr_lookup_site __P((ENV *, const char *, u_int));
301 int __repmgr_find_site __P((ENV *, const char *, u_int, int *));
302 int __repmgr_set_membership __P((ENV *, const char *, u_int, u_int32_t, u_int32_t));
303 int __repmgr_bcast_parm_refresh __P((ENV *));
304 int __repmgr_chg_prio __P((ENV *, u_int32_t, u_int32_t));
305 int __repmgr_bcast_own_msg __P((ENV *, u_int32_t, u_int8_t *, size_t));
306 int __repmgr_bcast_member_list __P((ENV *));
307 int __repmgr_forward_single_write __P((u_int32_t, DB *, DBT *, DBT *, u_int32_t));
308 void __repmgr_msgdispatch __P((DB_ENV *, DB_CHANNEL *, DBT *, u_int32_t, u_int32_t));
309 int __repmgr_set_write_forwarding __P((ENV *, int));
310 
311 #if defined(__cplusplus)
312 }
313 #endif
314 #endif /* !_repmgr_ext_h_ */
315