diff options
Diffstat (limited to 'xlators/features/bit-rot/src')
| -rw-r--r-- | xlators/features/bit-rot/src/bitd/bit-rot-scrub.c | 6 | ||||
| -rw-r--r-- | xlators/features/bit-rot/src/bitd/bit-rot.c | 11 | ||||
| -rw-r--r-- | xlators/features/bit-rot/src/stub/bit-rot-stub.c | 6 | 
3 files changed, 15 insertions, 8 deletions
diff --git a/xlators/features/bit-rot/src/bitd/bit-rot-scrub.c b/xlators/features/bit-rot/src/bitd/bit-rot-scrub.c index e043ef84a52..8812e99535a 100644 --- a/xlators/features/bit-rot/src/bitd/bit-rot-scrub.c +++ b/xlators/features/bit-rot/src/bitd/bit-rot-scrub.c @@ -1299,7 +1299,8 @@ br_scrubber_scale_up (xlator_t *this,                  INIT_LIST_HEAD (&scrub->list);                  ret = gf_thread_create (&scrub->scrubthread, -                                        NULL, br_scrubber_proc, fsscrub); +                                        NULL, br_scrubber_proc, fsscrub, +                                        "brsproc");                  if (ret)                          break; @@ -1976,7 +1977,8 @@ br_scrubber_monitor_init (xlator_t *this, br_private_t *priv)          br_set_scrub_state (&priv->scrub_monitor, BR_SCRUB_STATE_INACTIVE);          /* Start the monitor thread */ -        ret = gf_thread_create (&scrub_monitor->thread, NULL, br_monitor_thread, this); +        ret = gf_thread_create (&scrub_monitor->thread, NULL, +                                br_monitor_thread, this, "brmon");          if (ret != 0) {                  gf_msg (this->name, GF_LOG_ERROR, -ret,                          BRB_MSG_SPAWN_FAILED, "monitor thread creation failed"); diff --git a/xlators/features/bit-rot/src/bitd/bit-rot.c b/xlators/features/bit-rot/src/bitd/bit-rot.c index c591db53ad4..3c42cb2a1f6 100644 --- a/xlators/features/bit-rot/src/bitd/bit-rot.c +++ b/xlators/features/bit-rot/src/bitd/bit-rot.c @@ -1133,7 +1133,8 @@ br_enact_signer (xlator_t *this, br_child_t *child, br_stub_init_t *stub)          }          child->threadrunning = 0; -        ret = gf_thread_create (&child->thread, NULL, br_oneshot_signer, child); +        ret = gf_thread_create (&child->thread, NULL, br_oneshot_signer, child, +                                "brosign");          if (ret)                  gf_msg (this->name, GF_LOG_WARNING, 0, BRB_MSG_SPAWN_FAILED,                          "failed to spawn FS crawler thread"); @@ -1161,7 +1162,8 @@ br_launch_scrubber (xlator_t *this, br_child_t *child,          priv = this->private;          scrub_monitor = &priv->scrub_monitor; -        ret = gf_thread_create (&child->thread, NULL, br_fsscanner, child); +        ret = gf_thread_create (&child->thread, NULL, br_fsscanner, child, +                                "brfsscan");          if (ret != 0) {                  gf_msg (this->name, GF_LOG_ALERT, 0, BRB_MSG_SPAWN_FAILED,                          "failed to spawn bitrot scrubber daemon [Brick: %s]", @@ -1750,7 +1752,7 @@ br_init_signer (xlator_t *this, br_private_t *priv)          for (i = 0; i < BR_WORKERS; i++) {                  ret = gf_thread_create (&priv->obj_queue->workers[i], NULL, -                                        br_process_object, this); +                                        br_process_object, this, "brpobj");                  if (ret != 0) {                          gf_msg (this->name, GF_LOG_ERROR, -ret,                                  BRB_MSG_SPAWN_FAILED, "thread creation" @@ -2021,7 +2023,8 @@ init (xlator_t *this)          if (ret)                  goto cleanup; -        ret = gf_thread_create (&priv->thread, NULL, br_handle_events, this); +        ret = gf_thread_create (&priv->thread, NULL, br_handle_events, this, +                                "brhevent");          if (ret != 0) {                  gf_msg (this->name, GF_LOG_ERROR, -ret,                          BRB_MSG_SPAWN_FAILED, "thread creation failed"); diff --git a/xlators/features/bit-rot/src/stub/bit-rot-stub.c b/xlators/features/bit-rot/src/stub/bit-rot-stub.c index b8a34422522..fb187a3a93a 100644 --- a/xlators/features/bit-rot/src/stub/bit-rot-stub.c +++ b/xlators/features/bit-rot/src/stub/bit-rot-stub.c @@ -97,7 +97,8 @@ br_stub_bad_object_container_init (xlator_t *this, br_stub_private_t *priv)          if (ret < 0)                  goto cleanup_lock; -        ret = gf_thread_create (&priv->container.thread, &w_attr, br_stub_worker, this); +        ret = gf_thread_create (&priv->container.thread, &w_attr, +                                br_stub_worker, this, "brswrker");          if (ret)                  goto cleanup_attr; @@ -158,7 +159,8 @@ init (xlator_t *this)           */          this->private = priv; -        ret = gf_thread_create (&priv->signth, NULL, br_stub_signth, this); +        ret = gf_thread_create (&priv->signth, NULL, br_stub_signth, this, +                                "brssign");          if (ret != 0)                  goto cleanup_lock;  | 
