diff options
Diffstat (limited to 'libglusterfs')
| -rw-r--r-- | libglusterfs/src/common-utils.h | 8 | ||||
| -rw-r--r-- | libglusterfs/src/event-epoll.c | 5 | ||||
| -rw-r--r-- | libglusterfs/src/syncop.c | 2 |
3 files changed, 8 insertions, 7 deletions
diff --git a/libglusterfs/src/common-utils.h b/libglusterfs/src/common-utils.h index fc581de4998..3217c16a82e 100644 --- a/libglusterfs/src/common-utils.h +++ b/libglusterfs/src/common-utils.h @@ -135,9 +135,11 @@ void trap (void); #define GF_PERCENTAGE(val, total) (((val)*100)/(total)) /* pthread related */ -#define GF_THREAD_NAMEMAX 9 -#define GF_THREAD_NAME_PREFIX "gluster" -#define GF_THREAD_NAME_PREFIX_LEN 7 +/* as per the man page, thread-name should be at max 16 bytes */ +/* with prefix of 'glfs_' (5), we are left with 11 more bytes */ +#define GF_THREAD_NAMEMAX 11 +#define GF_THREAD_NAME_PREFIX "glfs_" +#define GF_THREAD_NAME_PREFIX_LEN 5 #include <stdbool.h> #define gf_boolean_t bool diff --git a/libglusterfs/src/event-epoll.c b/libglusterfs/src/event-epoll.c index c420a8a488f..c1474c8bc69 100644 --- a/libglusterfs/src/event-epoll.c +++ b/libglusterfs/src/event-epoll.c @@ -714,7 +714,7 @@ event_dispatch_epoll (struct event_pool *event_pool) ev_data->event_index = i + 1; snprintf (thread_name, sizeof(thread_name), - "%s%d", "epoll", i); + "epoll%03hx", (i & 0x3ff)); ret = gf_thread_create (&t_id, NULL, event_dispatch_epoll_worker, ev_data, thread_name); @@ -826,8 +826,7 @@ event_reconfigure_threads_epoll (struct event_pool *event_pool, int value) snprintf (thread_name, sizeof(thread_name), - "%s%d", - "epoll", i); + "epoll%03hx", (i & 0x3ff)); ret = gf_thread_create (&t_id, NULL, event_dispatch_epoll_worker, ev_data, thread_name); diff --git a/libglusterfs/src/syncop.c b/libglusterfs/src/syncop.c index 3db6fae6b00..767d2ef6853 100644 --- a/libglusterfs/src/syncop.c +++ b/libglusterfs/src/syncop.c @@ -733,7 +733,7 @@ syncenv_scale (struct syncenv *env) env->proc[i].env = env; snprintf (thread_name, sizeof(thread_name), - "%s%d", "sproc", env->procs); + "sproc%03hx", (env->procs & 0x3ff)); ret = gf_thread_create (&env->proc[i].processor, NULL, syncenv_processor, &env->proc[i], thread_name); |