/dports/databases/pgbouncer/pgbouncer-1.16.0/lib/usual/ |
H A D | pgsocket.h | 44 struct PgSocket; 61 void pgs_free(struct PgSocket *db); 67 void pgs_set_lifetime(struct PgSocket *pgs, double lifetime); 70 void pgs_connect(struct PgSocket *db); 73 void pgs_disconnect(struct PgSocket *db); 76 void pgs_send_query_simple(struct PgSocket *db, const char *query); 85 void pgs_sleep(struct PgSocket *db, double timeout); 88 void pgs_reconnect(struct PgSocket *db, double timeout); 91 int pgs_connection_valid(struct PgSocket *db); 94 PGconn *pgs_get_connection(struct PgSocket *db); [all …]
|
H A D | pgsocket.c | 38 struct PgSocket { struct 95 struct PgSocket *db = arg; in timeout_cb() 145 struct PgSocket *db = arg; in result_cb() 175 static void flush(struct PgSocket *db); 179 struct PgSocket *db = arg; in send_cb() 189 struct PgSocket *db = arg; in connect_cb() 212 static void flush(struct PgSocket *db) in flush() 235 struct PgSocket *db; in pgs_create() 262 void pgs_connect(struct PgSocket *db) in pgs_connect() 284 void pgs_disconnect(struct PgSocket *db) in pgs_disconnect() [all …]
|
/dports/databases/pgbouncer/pgbouncer-1.16.0/include/ |
H A D | objects.h | 35 PgSocket *compare_connections_by_time(PgSocket *lhs, PgSocket *rhs); 38 bool find_server(PgSocket *client) _MUSTCHECK; 39 bool release_server(PgSocket *server) /* _MUSTCHECK */; 40 bool finish_client_login(PgSocket *client) _MUSTCHECK; 41 bool check_fast_fail(PgSocket *client) _MUSTCHECK; 43 PgSocket *accept_client(int sock, bool is_unix) _MUSTCHECK; 55 void accept_cancel_request(PgSocket *req); 56 void forward_cancel_request(PgSocket *server); 73 void activate_client(PgSocket *client); 75 void change_client_state(PgSocket *client, SocketState newstate); [all …]
|
H A D | admin.h | 18 bool admin_handle_client(PgSocket *client, PktHdr *pkt) _MUSTCHECK; 19 bool admin_pre_login(PgSocket *client, const char *username) _MUSTCHECK; 20 bool admin_post_login(PgSocket *client) _MUSTCHECK; 22 bool admin_error(PgSocket *console, const char *fmt, ...) _PRINTF(2, 3) /* _MUSTCHECK */; 25 bool admin_flush(PgSocket *admin, PktBuf *buf, const char *desc) /* _MUSTCHECK */; 26 bool admin_ready(PgSocket *admin, const char *desc) _MUSTCHECK; 27 void admin_handle_cancel(PgSocket *client);
|
H A D | proto.h | 42 bool send_pooler_error(PgSocket *client, bool send_ready, bool level_fatal, const char *msg) /*_MU… 47 void finish_welcome_msg(PgSocket *server); 48 bool welcome_client(PgSocket *client) _MUSTCHECK; 50 bool answer_authreq(PgSocket *server, PktHdr *pkt) _MUSTCHECK; 52 bool send_startup_packet(PgSocket *server) _MUSTCHECK; 53 bool send_sslreq_packet(PgSocket *server) _MUSTCHECK;
|
H A D | scram.h | 48 bool read_server_first_message(PgSocket *server, char *input, 50 bool read_server_final_message(PgSocket *server, char *input, char *ServerSignature); 59 bool read_client_first_message(PgSocket *client, char *input, 64 bool read_client_final_message(PgSocket *client, const uint8_t *raw_input, char *input, 77 bool scram_verify_plain_password(PgSocket *client,
|
H A D | stats.h | 21 bool admin_database_stats(PgSocket *client, struct StatList *pool_list) _MUSTCHECK; 22 bool admin_database_stats_totals(PgSocket *client, struct StatList *pool_list) _MUSTCHECK; 23 bool admin_database_stats_averages(PgSocket *client, struct StatList *pool_list) _MUSTCHECK; 24 bool show_stat_totals(PgSocket *client, struct StatList *pool_list) _MUSTCHECK;
|
H A D | bouncer.h | 94 typedef struct PgSocket PgSocket; typedef 388 struct PgSocket { struct 390 PgSocket *link; /* the dest of packets */ argument 575 static inline PgSocket * _MUSTCHECK 581 return container_of(item, PgSocket, head); in pop_socket() 584 static inline PgSocket * 589 return container_of(slist->head.next, PgSocket, head); in first_socket() 592 static inline PgSocket * 597 return container_of(slist->head.prev, PgSocket, head); in last_socket()
|
H A D | varcache.h | 17 bool varcache_apply(PgSocket *server, PgSocket *client, bool *changes_p) _MUSTCHECK; 18 void varcache_fill_unset(VarCache *src, PgSocket *dst);
|
H A D | client.h | 20 bool set_pool(PgSocket *client, const char *dbname, const char *username, const char *password, boo… 21 bool handle_auth_query_response(PgSocket *client, PktHdr *pkt);
|
H A D | util.h | 49 void fill_remote_addr(PgSocket *sk, int fd, bool is_unix); 50 void fill_local_addr(PgSocket *sk, int fd, bool is_unix);
|
H A D | pktbuf.h | 32 PgSocket *queued_dst; 54 bool pktbuf_send_immediate(PktBuf *buf, PgSocket *sk) _MUSTCHECK; 55 bool pktbuf_send_queued(PktBuf *buf, PgSocket *sk) _MUSTCHECK;
|
H A D | takeover.h | 20 bool takeover_login(PgSocket *bouncer) _MUSTCHECK;
|
H A D | pam.h | 34 void pam_auth_begin(PgSocket *client, const char *passwd);
|
/dports/databases/pgbouncer/pgbouncer-1.16.0/src/ |
H A D | objects.c | 81 PgSocket *client = obj; in construct_client() 91 PgSocket *server = obj; in construct_server() 619 PgSocket *server; in find_server() 807 PgSocket *client; in disconnect_server() 1092 PgSocket *compare_connections_by_time(PgSocket *lhs, PgSocket *rhs) in compare_connections_by_time() 1156 PgSocket *server; in launch_new_connection() 1256 PgSocket *client; in accept_client() 1410 PgSocket *client; in use_client_socket() 1490 PgSocket *server; in use_server_socket() 1581 PgSocket *sk; in for_each_server_filtered() [all …]
|
H A D | admin.c | 80 static bool syntax_error(PgSocket *admin) in syntax_error() 252 static bool send_one_fd(PgSocket *admin, in send_one_fd() 323 static bool show_one_fd(PgSocket *admin, PgSocket *sk) in show_one_fd() 392 PgSocket *sk; in show_fds_from_list() 396 sk = container_of(item, PgSocket, head); in show_fds_from_list() 672 PgSocket *sk; in show_socket_list() 764 PgSocket *sk = container_of(item, PgSocket, head); in show_active_socket_list() 806 PgSocket *waiter; in admin_show_pools() 1534 bool admin_post_login(PgSocket *client) in admin_post_login() 1630 PgSocket *admin; in admin_pause_done() [all …]
|
H A D | janitor.c | 33 PgSocket *server; in close_server_list() 44 PgSocket *client; in close_client_list() 76 PgSocket *sk; in suspend_socket_list() 91 PgSocket *sk; in resume_socket_list() 133 PgSocket *server; in launch_recheck() 174 PgSocket *client; in per_loop_activate() 268 PgSocket *server; in count_close_needed() 372 PgSocket *client; in pool_client_maint() 425 PgSocket *server; in check_unused_servers() 472 PgSocket *server; in check_pool_size() [all …]
|
H A D | takeover.c | 35 static PgSocket *old_bouncer = NULL; 77 static void takeover_finish_part1(PgSocket *bouncer) in takeover_finish_part1() 175 PgSocket *server; in takeover_create_link() 178 server = container_of(item, PgSocket, head); in takeover_create_link() 192 PgSocket *sk; in takeover_clean_socket_list() 194 sk = container_of(item, PgSocket, head); in takeover_clean_socket_list() 206 PgSocket *client; in takeover_postprocess_fds() 214 client = container_of(item2, PgSocket, head); in takeover_postprocess_fds() 253 static void takeover_parse_data(PgSocket *bouncer, in takeover_parse_data() 306 PgSocket *bouncer = container_of(arg, PgSocket, sbuf); in takeover_recv_cb() [all …]
|
H A D | proto.c | 124 bool send_pooler_error(PgSocket *client, bool send_ready, bool level_fatal, const char *msg) in send_pooler_error() 210 void finish_welcome_msg(PgSocket *server) in finish_welcome_msg() 218 bool welcome_client(PgSocket *client) in welcome_client() 259 static PgUser *get_srv_psw(PgSocket *server) in get_srv_psw() 274 static bool send_password(PgSocket *server, const char *enc_psw) in send_password() 281 static bool login_clear_psw(PgSocket *server) in login_clear_psw() 288 static bool login_md5_psw(PgSocket *server, const uint8_t *salt) in login_md5_psw() 314 static bool login_scram_sha_256(PgSocket *server) in login_scram_sha_256() 450 bool answer_authreq(PgSocket *server, PktHdr *pkt) in answer_authreq() 535 bool send_startup_packet(PgSocket *server) in send_startup_packet() [all …]
|
H A D | server.c | 25 static bool load_parameter(PgSocket *server, PktHdr *pkt, bool startup) in load_parameter() 28 PgSocket *client = server->link; in load_parameter() 68 PgSocket *client; in kill_pool_logins() 71 client = container_of(item, PgSocket, head); in kill_pool_logins() 90 static bool handle_server_startup(PgSocket *server, PktHdr *pkt) in handle_server_startup() 247 static bool handle_server_work(PgSocket *server, PktHdr *pkt) in handle_server_work() 253 PgSocket *client = server->link; in handle_server_work() 434 static bool handle_connect(PgSocket *server) in handle_connect() 475 static bool handle_sslchar(PgSocket *server, struct MBuf *data) in handle_sslchar() 511 PgSocket *server = container_of(sbuf, PgSocket, sbuf); in server_proto() [all …]
|
H A D | client.c | 38 static bool check_client_passwd(PgSocket *client, const char *passwd) in check_client_passwd() 92 static bool send_client_authreq(PgSocket *client) in send_client_authreq() 151 static bool login_via_cert(PgSocket *client) in login_via_cert() 179 static bool login_as_unix_peer(PgSocket *client) in login_as_unix_peer() 193 static bool finish_set_pool(PgSocket *client, bool takeover) in finish_set_pool() 383 bool handle_auth_query_response(PgSocket *client, PktHdr *pkt) { in handle_auth_query_response() 388 PgSocket *server = client->link; in handle_auth_query_response() 501 static void set_appname(PgSocket *client, const char *app_name) in set_appname() 522 static bool decide_startup_pool(PgSocket *client, PktHdr *pkt) in decide_startup_pool() 881 static bool handle_client_work(PgSocket *client, PktHdr *pkt) in handle_client_work() [all …]
|
H A D | pam.c | 47 PgSocket *client; 141 void pam_auth_begin(PgSocket *client, const char *passwd) in pam_auth_begin() 280 PgSocket *client = request->client; in pam_auth_finish() 416 void pam_auth_begin(PgSocket *client, const char *passwd) in pam_auth_begin()
|
H A D | varcache.c | 117 bool varcache_apply(PgSocket *server, PgSocket *client, bool *changes_p) in varcache_apply() 146 void varcache_fill_unset(VarCache *src, PgSocket *dst) in varcache_fill_unset()
|
H A D | scram.c | 86 static char *read_attr_value(PgSocket *sk, char **input, char attr) in read_attr_value() 128 read_any_attr(PgSocket *sk, char **input, char *attr_p) in read_any_attr() 360 bool read_server_first_message(PgSocket *server, char *input, in read_server_first_message() 428 bool read_server_final_message(PgSocket *server, char *input, char *ServerSignature) in read_server_final_message() 576 bool read_client_first_message(PgSocket *client, char *input, in read_client_first_message() 664 bool read_client_final_message(PgSocket *client, const uint8_t *raw_input, char *input, in read_client_final_message() 1016 scram_verify_plain_password(PgSocket *client, in scram_verify_plain_password()
|
H A D | stats.c | 91 bool admin_database_stats(PgSocket *client, struct StatList *pool_list) in admin_database_stats() 162 bool admin_database_stats_totals(PgSocket *client, struct StatList *pool_list) in admin_database_stats_totals() 229 bool admin_database_stats_averages(PgSocket *client, struct StatList *pool_list) in admin_database_stats_averages() 285 bool show_stat_totals(PgSocket *client, struct StatList *pool_list) in show_stat_totals()
|