30#include <netinet/in.h>
41#include <freetds/utils/dlist.h>
46#define MAX_POOL_USERS 1024
61typedef void (*TDS_POOL_EXECUTE)(TDS_POOL_EVENT *event);
66 TDS_POOL_EXECUTE execute;
79 DLIST_FIELDS(dlist_user_item);
81 TDS_USER_STATE user_state;
82 TDS_POOL_MEMBER *assigned_member;
88 DLIST_FIELDS(dlist_member_item);
91 TDS_POOL_USER *current_user;
94#define DLIST_PREFIX dlist_member
95#define DLIST_LIST_TYPE dlist_members
96#define DLIST_ITEM_TYPE TDS_POOL_MEMBER
97#include <freetds/utils/dlist.tmpl.h>
99#define DLIST_PREFIX dlist_user
100#define DLIST_LIST_TYPE dlist_users
101#define DLIST_ITEM_TYPE TDS_POOL_USER
102#include <freetds/utils/dlist.tmpl.h>
112 char *server_password;
117 tds_mutex events_mtx;
118 TDS_SYS_SOCKET listen_fd;
119 TDS_SYS_SOCKET wakeup_fd;
120 TDS_SYS_SOCKET event_fd;
121 TDS_POOL_EVENT *events;
123 int num_active_members;
124 dlist_members active_members;
125 dlist_members idle_members;
133 unsigned long user_logins;
134 unsigned long member_logins;
140void pool_process_members(TDS_POOL * pool, fd_set * rfds, fd_set * wfds);
141TDS_POOL_MEMBER *pool_assign_idle_member(TDS_POOL * pool, TDS_POOL_USER *user);
142void pool_mbr_init(TDS_POOL * pool);
143void pool_mbr_destroy(TDS_POOL * pool);
144void pool_free_member(TDS_POOL *pool, TDS_POOL_MEMBER * pmbr);
145void pool_assign_member(TDS_POOL *pool, TDS_POOL_MEMBER * pmbr, TDS_POOL_USER *puser);
146void pool_deassign_member(TDS_POOL *pool, TDS_POOL_MEMBER * pmbr);
147void pool_reset_member(TDS_POOL *pool, TDS_POOL_MEMBER * pmbr);
148bool pool_packet_read(TDSSOCKET * tds);
151void pool_process_users(TDS_POOL * pool, fd_set * rfds, fd_set * wfds);
152void pool_user_init(TDS_POOL * pool);
153void pool_user_destroy(TDS_POOL * pool);
154TDS_POOL_USER *pool_user_create(TDS_POOL * pool, TDS_SYS_SOCKET s);
155void pool_free_user(TDS_POOL * pool, TDS_POOL_USER * puser);
156void pool_user_query(TDS_POOL * pool, TDS_POOL_USER * puser);
157bool pool_user_send_login_ack(TDS_POOL * pool, TDS_POOL_USER * puser);
158void pool_user_finish_login(TDS_POOL * pool, TDS_POOL_USER * puser);
161void dump_login(TDSLOGIN * login);
162void pool_event_add(TDS_POOL *pool, TDS_POOL_EVENT *ev, TDS_POOL_EXECUTE execute);
163int pool_write(TDS_SYS_SOCKET sock,
const void *buf,
size_t len);
164bool pool_write_data(TDS_POOL_SOCKET *from, TDS_POOL_SOCKET *to);
167bool pool_read_conf_files(
const char *path,
const char *poolname, TDS_POOL * pool,
char **err);
Main include file for libtds.
dlist_users waiters
users in wait state
Definition pool.h:128