diff options
Diffstat (limited to 'xlators/experimental')
-rw-r--r-- | xlators/experimental/fdl/src/fdl-tmpl.c | 3 | ||||
-rw-r--r-- | xlators/experimental/jbr-server/src/jbr.c | 4 |
2 files changed, 4 insertions, 3 deletions
diff --git a/xlators/experimental/fdl/src/fdl-tmpl.c b/xlators/experimental/fdl/src/fdl-tmpl.c index a92f6676ce1..145dad7964a 100644 --- a/xlators/experimental/fdl/src/fdl-tmpl.c +++ b/xlators/experimental/fdl/src/fdl-tmpl.c @@ -454,7 +454,8 @@ fdl_init (xlator_t *this) * exception. */ - if (pthread_create(&priv->worker,NULL,fdl_worker,this) != 0) { + if (gf_thread_create (&priv->worker, NULL, fdl_worker, this, + "fdlwrker") != 0) { gf_log (this->name, GF_LOG_ERROR, "failed to start fdl_worker"); goto err; diff --git a/xlators/experimental/jbr-server/src/jbr.c b/xlators/experimental/jbr-server/src/jbr.c index 3261319bd55..151ba57ab4c 100644 --- a/xlators/experimental/jbr-server/src/jbr.c +++ b/xlators/experimental/jbr-server/src/jbr.c @@ -1678,8 +1678,8 @@ jbr_init (xlator_t *this) priv->leader = priv->config_leader; priv->child_up = _gf_false; - if (pthread_create(&kid, NULL, jbr_flush_thread, - this) != 0) { + if (gf_thread_create (&kid, NULL, jbr_flush_thread, this, + "jbrflush") != 0) { gf_msg (this->name, GF_LOG_ERROR, 0, J_MSG_SYS_CALL_FAILURE, "could not start flush thread"); /* TBD: treat this as a fatal error? */ |