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

send_by_buf1 and recv_data callback for rdma

support_rdma
YuQing 2023-09-24 14:32:42 +08:00
parent e0b93756ab
commit 2e176a9d1b
2 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/connection_pool.c
View File

@ -790,6 +790,8 @@ int conn_pool_global_init_for_rdma()
LOAD_API(G_RDMA_CONNECTION_CALLBACKS, request_by_buf2); LOAD_API(G_RDMA_CONNECTION_CALLBACKS, request_by_buf2);
LOAD_API(G_RDMA_CONNECTION_CALLBACKS, request_by_iov); LOAD_API(G_RDMA_CONNECTION_CALLBACKS, request_by_iov);
LOAD_API(G_RDMA_CONNECTION_CALLBACKS, request_by_mix); LOAD_API(G_RDMA_CONNECTION_CALLBACKS, request_by_mix);
LOAD_API(G_RDMA_CONNECTION_CALLBACKS, send_by_buf1);
LOAD_API(G_RDMA_CONNECTION_CALLBACKS, recv_data);
g_connection_callbacks.inited = true; g_connection_callbacks.inited = true;
return 0; return 0;
@ -830,6 +832,7 @@ ConnectionInfo *conn_pool_alloc_connection_ex(
} }
conn->comm_type = comm_type; conn->comm_type = comm_type;
conn->sock = -1;
return conn; return conn;
} }

9
src/connection_pool.h
View File

@ -59,6 +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 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)();
@ -83,6 +84,10 @@ typedef int (*fc_rdma_request_by_iov_callback)(ConnectionInfo *conn,
typedef int (*fc_rdma_request_by_mix_callback)(ConnectionInfo *conn, typedef int (*fc_rdma_request_by_mix_callback)(ConnectionInfo *conn,
const char *data, const int length, const struct iovec *iov, const char *data, const int length, const struct iovec *iov,
const int iovcnt, const int timeout_ms); const int iovcnt, const int timeout_ms);
typedef int (*fc_rdma_send_by_buf1_callback)(ConnectionInfo *conn,
const char *data, const int length);
typedef int (*fc_rdma_recv_data_callback)(ConnectionInfo *conn,
const int timeout_ms);
typedef struct { typedef struct {
fc_make_connection_callback make_connection; fc_make_connection_callback make_connection;
@ -91,6 +96,7 @@ typedef struct {
} CommonConnectionCallbacks; } CommonConnectionCallbacks;
typedef struct { typedef struct {
fc_global_init_callback global_init;
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;
@ -104,6 +110,9 @@ typedef struct {
fc_rdma_request_by_buf2_callback request_by_buf2; fc_rdma_request_by_buf2_callback request_by_buf2;
fc_rdma_request_by_iov_callback request_by_iov; fc_rdma_request_by_iov_callback request_by_iov;
fc_rdma_request_by_mix_callback request_by_mix; fc_rdma_request_by_mix_callback request_by_mix;
fc_rdma_send_by_buf1_callback send_by_buf1;
fc_rdma_recv_data_callback recv_data;
} RDMAConnectionCallbacks; } RDMAConnectionCallbacks;
typedef struct { typedef struct {