diff options
Diffstat (limited to 'xlators/features')
| -rw-r--r-- | xlators/features/changelog/lib/src/gf-history-changelog.c | 4 | ||||
| -rw-r--r-- | xlators/features/changelog/src/changelog-rpc.c | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/xlators/features/changelog/lib/src/gf-history-changelog.c b/xlators/features/changelog/lib/src/gf-history-changelog.c index 7b973b674a4..fd92dd7ed0b 100644 --- a/xlators/features/changelog/lib/src/gf-history-changelog.c +++ b/xlators/features/changelog/lib/src/gf-history-changelog.c @@ -618,8 +618,8 @@ gf_history_consume (void * data) curr->retval = 0; memset (curr->changelog, '\0', PATH_MAX); - snprintf (thread_name, sizeof(thread_name), "%s%d", - "clogc", iter + 1); + snprintf (thread_name, sizeof(thread_name), + "clogc%03hx", ((iter + 1) & 0x3ff)); ret = gf_thread_create (&th_id[iter], NULL, gf_changelog_consume_wrap, curr, diff --git a/xlators/features/changelog/src/changelog-rpc.c b/xlators/features/changelog/src/changelog-rpc.c index 793e7a8aff4..9027fe10a2a 100644 --- a/xlators/features/changelog/src/changelog-rpc.c +++ b/xlators/features/changelog/src/changelog-rpc.c @@ -116,7 +116,7 @@ changelog_init_rpc_threads (xlator_t *this, changelog_priv_t *priv, /* spawn dispatcher threads */ for (; j < nr_dispatchers; j++) { snprintf (thread_name, sizeof(thread_name), - "%s%d", "clogd", j); + "clogd%03hx", (j & 0x3ff)); ret = gf_thread_create (&priv->ev_dispatcher[j], NULL, changelog_ev_dispatch, conn, thread_name); |