odyssey/core/od_server_pool.h

#ifndef OD_SERVER_POOL_H_
#define OD_SERVER_POOL_H_

/*
 * odissey.
 *
 * PostgreSQL connection pooler and request router.
*/

typedef struct od_serverpool_t od_serverpool_t;

typedef int (*od_serverpool_cb_t)(od_server_t*, void*);

struct od_serverpool_t {
	od_list_t active;
	od_list_t connect;
	od_list_t reset;
	od_list_t expire;
	od_list_t idle;
	int       count_active;
	int       count_connect;
	int       count_reset;
	int       count_expire;
	int       count_idle;
	od_list_t link;
};

void od_serverpool_init(od_serverpool_t*);
void od_serverpool_free(od_serverpool_t*);
void od_serverpool_set(od_serverpool_t*, od_server_t*,
                       od_serverstate_t);

od_server_t*
od_serverpool_pop(od_serverpool_t*, od_serverstate_t);

od_server_t*
od_serverpool_foreach(od_serverpool_t*, od_serverstate_t,
                      od_serverpool_cb_t, void*);

#endif