Rooba
/
odyssey
mirror of https://github.com/yandex/odyssey.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity
odyssey/sources/router.h

74 lines
1.5 KiB
C
Raw Normal View History

odyssey: major io rework and refactoring This patch moves Odyssey from stream based write caching to message driven. All write operations are delayed and happen on a group of messages. This removes necessity to do IO and wait for write completion during calls from SSL_write() context. Write timings should behave more predictable now and number of used syscalls should be also decreased. This patch also simplifies caching management. All clients are simply reusing cached messages without prolonged contention. Several configuration options are no longer used: pipeline, cache, cache_chunk
2018-08-28 14:43:46 +00:00
#ifndef ODYSSEY_ROUTER_H
#define ODYSSEY_ROUTER_H
odissey: group system services; add initial router
2017-05-26 12:17:45 +00:00
/*
odyssey: project rename
2018-03-12 14:03:15 +00:00
* Odyssey.
odissey: group system services; add initial router
2017-05-26 12:17:45 +00:00
*
odyssey: update source file headers
2018-04-04 13:19:58 +00:00
* Scalable PostgreSQL connection pooler.
odissey: group system services; add initial router
2017-05-26 12:17:45 +00:00
*/
typedef struct od_router od_router_t;
odissey: implement client routing procedure
2017-05-26 13:44:42 +00:00
typedef enum
{
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
OD_ROUTER_OK,
OD_ROUTER_ERROR,
OD_ROUTER_ERROR_NOT_FOUND,
OD_ROUTER_ERROR_LIMIT,
OD_ROUTER_ERROR_LIMIT_ROUTE,
OD_ROUTER_ERROR_TIMEDOUT
odyssey: major io rework and refactoring This patch moves Odyssey from stream based write caching to message driven. All write operations are delayed and happen on a group of messages. This removes necessity to do IO and wait for write completion during calls from SSL_write() context. Write timings should behave more predictable now and number of used syscalls should be also decreased. This patch also simplifies caching management. All clients are simply reusing cached messages without prolonged contention. Several configuration options are no longer used: pipeline, cache, cache_chunk
2018-08-28 14:43:46 +00:00
} od_router_status_t;
odissey: implement client routing procedure
2017-05-26 13:44:42 +00:00
odissey: group system services; add initial router
2017-05-26 12:17:45 +00:00
struct od_router
{
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
pthread_mutex_t lock;
od_rules_t rules;
od_route_pool_t route_pool;
Limit global max_clients before doing tls handshake
2019-10-10 10:00:33 +00:00
od_atomic_u32_t clients;
Implement client_max_routing (#72)
2019-10-15 14:15:37 +00:00
od_atomic_u32_t clients_routing;
Implement server_max_routing restriction
2020-01-23 06:22:58 +00:00
od_atomic_u32_t servers_routing;
odissey: group system services; add initial router
2017-05-26 12:17:45 +00:00
};
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
static inline void
od_router_lock(od_router_t *router)
{
pthread_mutex_lock(&router->lock);
}
odissey: implement client routing procedure
2017-05-26 13:44:42 +00:00
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
static inline void
od_router_unlock(od_router_t *router)
{
pthread_mutex_unlock(&router->lock);
}
odissey: group system services; add initial router
2017-05-26 12:17:45 +00:00
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
void od_router_init(od_router_t*);
void od_router_free(od_router_t*);
int od_router_reconfigure(od_router_t*, od_rules_t*);
int od_router_expire(od_router_t*, od_list_t*);
void od_router_gc(od_router_t*);
void od_router_stat(od_router_t*, uint64_t, int, od_route_pool_stat_cb_t, void**);
int od_router_foreach(od_router_t*, od_route_pool_cb_t, void**);
odissey: implicitly detach client from a route
2017-06-01 09:28:23 +00:00
odyssey: major io rework and refactoring This patch moves Odyssey from stream based write caching to message driven. All write operations are delayed and happen on a group of messages. This removes necessity to do IO and wait for write completion during calls from SSL_write() context. Write timings should behave more predictable now and number of used syscalls should be also decreased. This patch also simplifies caching management. All clients are simply reusing cached messages without prolonged contention. Several configuration options are no longer used: pipeline, cache, cache_chunk
2018-08-28 14:43:46 +00:00
od_router_status_t
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
od_router_route(od_router_t*, od_config_t*, od_client_t*);
machinarium: implement router push/pop requests
2017-05-27 13:14:39 +00:00
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
void
od_router_unroute(od_router_t*, od_client_t*);
odissey: proper route client_pool route/unroute logic
2017-05-31 10:49:12 +00:00
Implement router retry timeout
2019-06-27 12:24:44 +00:00
od_router_status_t
odyssey: rework connection retry logic for too many connections case
2019-08-10 18:03:41 +00:00
od_router_attach(od_router_t*, od_config_t*, od_client_t*, bool);
machinarium: implement router push/pop requests
2017-05-27 13:14:39 +00:00
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
void
od_router_detach(od_router_t*, od_config_t*, od_client_t*);
odissey: do retry in and separate frontend attach logic
2017-12-08 13:30:42 +00:00
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
void
od_router_close(od_router_t*, od_client_t*);
odissey: implement router close; update machinarium
2017-05-30 15:04:59 +00:00
odyssey: major io rework and refactoring This patch moves Odyssey from stream based write caching to message driven. All write operations are delayed and happen on a group of messages. This removes necessity to do IO and wait for write completion during calls from SSL_write() context. Write timings should behave more predictable now and number of used syscalls should be also decreased. This patch also simplifies caching management. All clients are simply reusing cached messages without prolonged contention. Several configuration options are no longer used: pipeline, cache, cache_chunk
2018-08-28 14:43:46 +00:00
od_router_status_t
odyssey: major router and shared logic rework Goal is to improve overall performance during massive peaks of connecting clients. This patch makes router a shared structure, instead of being run in separate system worker thread/coroutine. Now router and each route object is protected by separate mutex. Worker threads directly access router object without calls to separate thread.
2018-12-06 14:23:15 +00:00
od_router_cancel(od_router_t*, kiwi_key_t*, od_router_cancel_t*);
void
od_router_kill(od_router_t*, od_id_t*);
odissey: implement router cancel logic
2017-05-30 11:34:08 +00:00
odyssey: major io rework and refactoring This patch moves Odyssey from stream based write caching to message driven. All write operations are delayed and happen on a group of messages. This removes necessity to do IO and wait for write completion during calls from SSL_write() context. Write timings should behave more predictable now and number of used syscalls should be also decreased. This patch also simplifies caching management. All clients are simply reusing cached messages without prolonged contention. Several configuration options are no longer used: pipeline, cache, cache_chunk
2018-08-28 14:43:46 +00:00
#endif /* ODYSSEY_ROUTER_H */