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

init extra_params when comm_type == fc_comm_type_sock

support_rdma
YuQing 2023-09-14 09:55:59 +08:00
parent db49d54a37
commit f49c5d134a
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/connection_pool.c
View File

@ -89,6 +89,8 @@ int conn_pool_init_ex1(ConnectionPool *cp, int connect_timeout,
cp->extra_params = *extra_params; cp->extra_params = *extra_params;
} else { } else {
extra_connection_size = 0; extra_connection_size = 0;
cp->extra_params.buffer_size = 0;
cp->extra_params.pd = NULL;
obj_init_func = (fast_mblock_object_init_func)node_init_for_socket; obj_init_func = (fast_mblock_object_init_func)node_init_for_socket;
} }
if ((result=fast_mblock_init_ex1(&cp->node_allocator, "cpool-node", if ((result=fast_mblock_init_ex1(&cp->node_allocator, "cpool-node",
@ -683,6 +685,8 @@ int conn_pool_set_rdma_extra_params(ConnectionExtraParams *extra_params,
} }
if (server_group->comm_type == fc_comm_type_sock) { if (server_group->comm_type == fc_comm_type_sock) {
extra_params->buffer_size = 0;
extra_params->pd = NULL;
return 0; return 0;
} else { } else {
first_server = FC_SID_SERVERS(*server_cfg); first_server = FC_SID_SERVERS(*server_cfg);