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) 6extern "C" { 7#endif 8 9void __repmgr_handshake_marshal __P((ENV *, __repmgr_handshake_args *, u_int8_t *)); 10int __repmgr_handshake_unmarshal __P((ENV *, __repmgr_handshake_args *, u_int8_t *, size_t, u_int8_t **)); 11void __repmgr_ack_marshal __P((ENV *, __repmgr_ack_args *, u_int8_t *)); 12int __repmgr_ack_unmarshal __P((ENV *, __repmgr_ack_args *, u_int8_t *, size_t, u_int8_t **)); 13void __repmgr_version_proposal_marshal __P((ENV *, __repmgr_version_proposal_args *, u_int8_t *)); 14int __repmgr_version_proposal_unmarshal __P((ENV *, __repmgr_version_proposal_args *, u_int8_t *, size_t, u_int8_t **)); 15void __repmgr_version_confirmation_marshal __P((ENV *, __repmgr_version_confirmation_args *, u_int8_t *)); 16int __repmgr_version_confirmation_unmarshal __P((ENV *, __repmgr_version_confirmation_args *, u_int8_t *, size_t, u_int8_t **)); 17int __repmgr_init_election __P((ENV *, int)); 18int __repmgr_become_master __P((ENV *)); 19int __repmgr_start __P((DB_ENV *, int, u_int32_t)); 20int __repmgr_close __P((ENV *)); 21int __repmgr_set_ack_policy __P((DB_ENV *, int)); 22int __repmgr_get_ack_policy __P((DB_ENV *, int *)); 23int __repmgr_env_create __P((ENV *, DB_REP *)); 24void __repmgr_env_destroy __P((ENV *, DB_REP *)); 25int __repmgr_stop_threads __P((ENV *)); 26int __repmgr_set_local_site __P((DB_ENV *, const char *, u_int, u_int32_t)); 27int __repmgr_add_remote_site __P((DB_ENV *, const char *, u_int, int *, u_int32_t)); 28void *__repmgr_msg_thread __P((void *)); 29int __repmgr_handle_event __P((ENV *, u_int32_t, void *)); 30void __repmgr_stash_generation __P((ENV *)); 31int __repmgr_send __P((DB_ENV *, const DBT *, const DBT *, const DB_LSN *, int, u_int32_t)); 32int __repmgr_send_broadcast __P((ENV *, u_int, const DBT *, const DBT *, u_int *, u_int *)); 33int __repmgr_send_one __P((ENV *, REPMGR_CONNECTION *, u_int, const DBT *, const DBT *, int)); 34int __repmgr_is_permanent __P((ENV *, const DB_LSN *)); 35int __repmgr_bust_connection __P((ENV *, REPMGR_CONNECTION *)); 36int __repmgr_cleanup_connection __P((ENV *, REPMGR_CONNECTION *)); 37int __repmgr_find_site __P((ENV *, const char *, u_int)); 38int __repmgr_pack_netaddr __P((ENV *, const char *, u_int, ADDRINFO *, repmgr_netaddr_t *)); 39int __repmgr_getaddr __P((ENV *, const char *, u_int, int, ADDRINFO **)); 40int __repmgr_add_site __P((ENV *, const char *, u_int, REPMGR_SITE **)); 41int __repmgr_net_create __P((DB_REP *)); 42int __repmgr_listen __P((ENV *)); 43int __repmgr_net_close __P((ENV *)); 44void __repmgr_net_destroy __P((ENV *, DB_REP *)); 45int __repmgr_thread_start __P((ENV *, REPMGR_RUNNABLE *)); 46int __repmgr_thread_join __P((REPMGR_RUNNABLE *)); 47int __repmgr_set_nonblocking __P((socket_t)); 48int __repmgr_wake_waiting_senders __P((ENV *)); 49int __repmgr_await_ack __P((ENV *, const DB_LSN *)); 50void __repmgr_compute_wait_deadline __P((ENV*, struct timespec *, db_timeout_t)); 51int __repmgr_await_drain __P((ENV *, REPMGR_CONNECTION *, db_timeout_t)); 52int __repmgr_alloc_cond __P((cond_var_t *)); 53int __repmgr_free_cond __P((cond_var_t *)); 54int __repmgr_init_sync __P((ENV *, DB_REP *)); 55int __repmgr_close_sync __P((ENV *)); 56int __repmgr_net_init __P((ENV *, DB_REP *)); 57int __repmgr_lock_mutex __P((mgr_mutex_t *)); 58int __repmgr_unlock_mutex __P((mgr_mutex_t *)); 59int __repmgr_signal __P((cond_var_t *)); 60int __repmgr_wake_main_thread __P((ENV*)); 61int __repmgr_writev __P((socket_t, db_iovec_t *, int, size_t *)); 62int __repmgr_readv __P((socket_t, db_iovec_t *, int, size_t *)); 63int __repmgr_select_loop __P((ENV *)); 64int __repmgr_queue_create __P((ENV *, DB_REP *)); 65void __repmgr_queue_destroy __P((ENV *)); 66int __repmgr_queue_get __P((ENV *, REPMGR_MESSAGE **)); 67int __repmgr_queue_put __P((ENV *, REPMGR_MESSAGE *)); 68int __repmgr_queue_size __P((ENV *)); 69void *__repmgr_select_thread __P((void *)); 70int __repmgr_accept __P((ENV *)); 71int __repmgr_compute_timeout __P((ENV *, db_timespec *)); 72int __repmgr_check_timeouts __P((ENV *)); 73int __repmgr_first_try_connections __P((ENV *)); 74int __repmgr_connect_site __P((ENV *, u_int eid)); 75int __repmgr_propose_version __P((ENV *, REPMGR_CONNECTION *)); 76int __repmgr_read_from_site __P((ENV *, REPMGR_CONNECTION *)); 77int __repmgr_write_some __P((ENV *, REPMGR_CONNECTION *)); 78int __repmgr_stat_pp __P((DB_ENV *, DB_REPMGR_STAT **, u_int32_t)); 79int __repmgr_stat_print_pp __P((DB_ENV *, u_int32_t)); 80int __repmgr_site_list __P((DB_ENV *, u_int *, DB_REPMGR_SITE **)); 81#ifndef HAVE_REPLICATION_THREADS 82int __repmgr_close __P((ENV *)); 83#endif 84#ifndef HAVE_REPLICATION_THREADS 85int __repmgr_add_remote_site __P((DB_ENV *, const char *, u_int, int *, u_int32_t)); 86#endif 87#ifndef HAVE_REPLICATION_THREADS 88int __repmgr_get_ack_policy __P((DB_ENV *, int *)); 89#endif 90#ifndef HAVE_REPLICATION_THREADS 91int __repmgr_set_ack_policy __P((DB_ENV *, int)); 92#endif 93#ifndef HAVE_REPLICATION_THREADS 94int __repmgr_set_local_site __P((DB_ENV *, const char *, u_int, u_int32_t)); 95#endif 96#ifndef HAVE_REPLICATION_THREADS 97int __repmgr_site_list __P((DB_ENV *, u_int *, DB_REPMGR_SITE **)); 98#endif 99#ifndef HAVE_REPLICATION_THREADS 100int __repmgr_start __P((DB_ENV *, int, u_int32_t)); 101#endif 102#ifndef HAVE_REPLICATION_THREADS 103int __repmgr_stat_pp __P((DB_ENV *, DB_REPMGR_STAT **, u_int32_t)); 104#endif 105#ifndef HAVE_REPLICATION_THREADS 106int __repmgr_stat_print_pp __P((DB_ENV *, u_int32_t)); 107#endif 108#ifndef HAVE_REPLICATION_THREADS 109int __repmgr_handle_event __P((ENV *, u_int32_t, void *)); 110#endif 111int __repmgr_schedule_connection_attempt __P((ENV *, u_int, int)); 112void __repmgr_reset_for_reading __P((REPMGR_CONNECTION *)); 113int __repmgr_new_connection __P((ENV *, REPMGR_CONNECTION **, socket_t, int)); 114int __repmgr_new_site __P((ENV *, REPMGR_SITE**, const repmgr_netaddr_t *, int)); 115void __repmgr_cleanup_netaddr __P((ENV *, repmgr_netaddr_t *)); 116void __repmgr_iovec_init __P((REPMGR_IOVECS *)); 117void __repmgr_add_buffer __P((REPMGR_IOVECS *, void *, size_t)); 118void __repmgr_add_dbt __P((REPMGR_IOVECS *, const DBT *)); 119int __repmgr_update_consumed __P((REPMGR_IOVECS *, size_t)); 120int __repmgr_prepare_my_addr __P((ENV *, DBT *)); 121u_int __repmgr_get_nsites __P((DB_REP *)); 122void __repmgr_thread_failure __P((ENV *, int)); 123char *__repmgr_format_eid_loc __P((DB_REP *, int, char *)); 124char *__repmgr_format_site_loc __P((REPMGR_SITE *, char *)); 125int __repmgr_repstart __P((ENV *, u_int32_t)); 126int __repmgr_wsa_init __P((ENV *)); 127 128#if defined(__cplusplus) 129} 130#endif 131#endif /* !_repmgr_ext_h_ */ 132