Home
last modified time | relevance | path

Searched refs:PgSocket (Results 1 – 25 of 31) sorted by relevance

12

/dports/databases/pgbouncer/pgbouncer-1.16.0/lib/usual/
H A Dpgsocket.h44 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 Dpgsocket.c38 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 Dobjects.h35 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 Dadmin.h18 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 Dproto.h42 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 Dscram.h48 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 Dstats.h21 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 Dbouncer.h94 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 Dvarcache.h17 bool varcache_apply(PgSocket *server, PgSocket *client, bool *changes_p) _MUSTCHECK;
18 void varcache_fill_unset(VarCache *src, PgSocket *dst);
H A Dclient.h20 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 Dutil.h49 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 Dpktbuf.h32 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 Dtakeover.h20 bool takeover_login(PgSocket *bouncer) _MUSTCHECK;
H A Dpam.h34 void pam_auth_begin(PgSocket *client, const char *passwd);
/dports/databases/pgbouncer/pgbouncer-1.16.0/src/
H A Dobjects.c81 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 Dadmin.c80 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 Djanitor.c33 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 Dtakeover.c35 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 Dproto.c124 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 Dserver.c25 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 Dclient.c38 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 Dpam.c47 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 Dvarcache.c117 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 Dscram.c86 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 Dstats.c91 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()

12