pdxx
/
libfastcommon
mirror of https://github.com/happyfish100/libfastcommon.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

add RDMA callback set_busy_polling

pull/47/head^2 V1.0.70
YuQing 2023-11-18 10:40:37 +08:00
parent 894477753c
commit 6843acb456
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/connection_pool.c
View File

@ -779,6 +779,7 @@ int conn_pool_global_init_for_rdma()
LOAD_API(G_COMMON_CONNECTION_CALLBACKS[fc_comm_type_rdma], LOAD_API(G_COMMON_CONNECTION_CALLBACKS[fc_comm_type_rdma],
is_connected); is_connected);
LOAD_API(G_RDMA_CONNECTION_CALLBACKS, set_busy_polling);
LOAD_API(G_RDMA_CONNECTION_CALLBACKS, alloc_pd); LOAD_API(G_RDMA_CONNECTION_CALLBACKS, alloc_pd);
LOAD_API(G_RDMA_CONNECTION_CALLBACKS, get_connection_size); LOAD_API(G_RDMA_CONNECTION_CALLBACKS, get_connection_size);
LOAD_API(G_RDMA_CONNECTION_CALLBACKS, init_connection); LOAD_API(G_RDMA_CONNECTION_CALLBACKS, init_connection);

4
src/connection_pool.h
View File

@ -59,7 +59,7 @@ typedef struct {
struct fc_server_config; struct fc_server_config;
struct ibv_pd; struct ibv_pd;
typedef int (*fc_global_init_callback)(); typedef void (*fc_set_busy_polling_callback)(const bool busy_polling);
typedef struct ibv_pd *(*fc_alloc_pd_callback)(const char **ip_addrs, typedef struct ibv_pd *(*fc_alloc_pd_callback)(const char **ip_addrs,
const int count, const int port); const int count, const int port);
typedef int (*fc_get_connection_size_callback)(); typedef int (*fc_get_connection_size_callback)();
@ -98,7 +98,7 @@ typedef struct {
} CommonConnectionCallbacks; } CommonConnectionCallbacks;
typedef struct { typedef struct {
fc_global_init_callback global_init; fc_set_busy_polling_callback set_busy_polling;
fc_alloc_pd_callback alloc_pd; fc_alloc_pd_callback alloc_pd;
fc_get_connection_size_callback get_connection_size; fc_get_connection_size_callback get_connection_size;
fc_init_connection_callback init_connection; fc_init_connection_callback init_connection;