diff options
Diffstat (limited to 'rpc')
| -rw-r--r-- | rpc/rpc-lib/src/rpcsvc.c | 2 | ||||
| -rw-r--r-- | rpc/rpc-transport/rdma/src/rdma.c | 12 | ||||
| -rw-r--r-- | rpc/rpc-transport/socket/src/socket.c | 5 |
3 files changed, 10 insertions, 9 deletions
diff --git a/rpc/rpc-lib/src/rpcsvc.c b/rpc/rpc-lib/src/rpcsvc.c index 16d76a159e8..fa44bb84e16 100644 --- a/rpc/rpc-lib/src/rpcsvc.c +++ b/rpc/rpc-lib/src/rpcsvc.c @@ -1960,7 +1960,7 @@ rpcsvc_program_register (rpcsvc_t *svc, rpcsvc_program_t *program) if (newprog->ownthread) { gf_thread_create (&newprog->thread, NULL, rpcsvc_request_handler, - newprog); + newprog, "rpcsvcrh"); } pthread_mutex_lock (&svc->rpclock); diff --git a/rpc/rpc-transport/rdma/src/rdma.c b/rpc/rpc-transport/rdma/src/rdma.c index 01f96c21b5c..26bcce4fd99 100644 --- a/rpc/rpc-transport/rdma/src/rdma.c +++ b/rpc/rpc-transport/rdma/src/rdma.c @@ -816,7 +816,7 @@ gf_rdma_get_device (rpc_transport_t *this, struct ibv_context *ibctx, /* completion threads */ ret = gf_thread_create (&trav->send_thread, NULL, gf_rdma_send_completion_proc, - trav->send_chan); + trav->send_chan, "rdmascom"); if (ret) { gf_msg (this->name, GF_LOG_ERROR, 0, RDMA_MSG_SEND_COMP_THREAD_FAILED, @@ -826,8 +826,8 @@ gf_rdma_get_device (rpc_transport_t *this, struct ibv_context *ibctx, } ret = gf_thread_create (&trav->recv_thread, NULL, - gf_rdma_recv_completion_proc, - trav->recv_chan); + gf_rdma_recv_completion_proc, + trav->recv_chan, "rdmarcom"); if (ret) { gf_msg (this->name, GF_LOG_ERROR, 0, RDMA_MSG_RECV_COMP_THREAD_FAILED, @@ -837,8 +837,8 @@ gf_rdma_get_device (rpc_transport_t *this, struct ibv_context *ibctx, } ret = gf_thread_create (&trav->async_event_thread, NULL, - gf_rdma_async_event_thread, - ibctx); + gf_rdma_async_event_thread, + ibctx, "rdmaAsyn"); if (ret) { gf_msg (this->name, GF_LOG_ERROR, 0, RDMA_MSG_ASYNC_EVENT_THEAD_FAILED, @@ -4600,7 +4600,7 @@ __gf_rdma_ctx_create (void) ret = gf_thread_create (&rdma_ctx->rdma_cm_thread, NULL, gf_rdma_cm_event_handler, - rdma_ctx->rdma_cm_event_channel); + rdma_ctx->rdma_cm_event_channel, "rdmaehan"); if (ret != 0) { gf_msg (GF_RDMA_LOG_NAME, GF_LOG_WARNING, ret, RDMA_MSG_CM_EVENT_FAILED, "creation of thread to " diff --git a/rpc/rpc-transport/socket/src/socket.c b/rpc/rpc-transport/socket/src/socket.c index 02a0a86526a..5cee869fdfc 100644 --- a/rpc/rpc-transport/socket/src/socket.c +++ b/rpc/rpc-transport/socket/src/socket.c @@ -2700,7 +2700,8 @@ socket_spawn (rpc_transport_t *this) /* Create thread after enable detach flag */ - ret = gf_thread_create_detached (&priv->thread, socket_poller, this); + ret = gf_thread_create_detached (&priv->thread, socket_poller, this, + "spoller"); if (ret) { gf_log (this->name, GF_LOG_ERROR, "could not create poll thread"); @@ -3409,7 +3410,7 @@ err: arg->refd = refd; th_ret = gf_thread_create_detached (&th_id, socket_connect_error_cbk, - arg); + arg, "scleanup"); if (th_ret) { /* Error will be logged by gf_thread_create_attached */ gf_log (this->name, GF_LOG_ERROR, "Thread creation " |