Make empth_name() and empth_set_name() take a thread argument

include/empthread.h

@@ -128,14 +128,14 @@ empth_t *empth_create(void (*entry)(void *),
 empth_t *empth_self(void);
 
 /*
- * Return the name of the current thread.
+ * Return the name THREAD.
  */
-char *empth_name(void);
+char *empth_name(empth_t *thread);
 
 /*
- * Sets the name of the current thread.
+ * Set the name of THREAD to NAME.
  */
-void empth_set_name(char *);
+void empth_set_name(empth_t *thread, char *name);
 
 /*
  * Terminate the current thread.

src/lib/empthread/lwp.c

@@ -75,15 +75,15 @@ empth_self(void)
 }
 
 char *
-empth_name(void)
+empth_name(empth_t *thread)
 {
-    return lwpName(LwpCurrent);
+    return lwpName(thread);
 }
 
 void
-empth_set_name(char *name)
+empth_set_name(empth_t *thread, char *name)
 {
-    lwpSetName(LwpCurrent, name);
+    lwpSetName(thread, name);
 }
 
 void

src/lib/empthread/ntthread.c

@@ -490,9 +490,9 @@ empth_self(void)
  * empth_name
  */
 char *
-empth_name(void)
+empth_name(empth_t *thread)
 {
-    return empth_self()->szName;
+    return thread->szName;
 }
 
 /************************
@@ -500,11 +500,9 @@ empth_name(void)
  * Set the thread name
  */
 void
-empth_set_name(char *name)
+empth_set_name(empth_t *thread, char *name)
 {
-    empth_t *pThread = TlsGetValue(dwTLSIndex);
-
-    strncpy(pThread->szName, name, sizeof(pThread->szName) - 1);
+    strncpy(thread->szName, name, sizeof(thread->szName) - 1);
 }
 
 /************************

src/lib/empthread/pthread.c

@@ -248,22 +248,17 @@ empth_self(void)
 }
 
 char *
-empth_name(void)
+empth_name(empth_t *thread)
 {
-    return empth_self()->name;
+    return thread->name;
 }
 
 void
-empth_set_name(char *name)
+empth_set_name(empth_t *thread, char *name)
 {
-    empth_t *ctx_ptr;
-    
-    ctx_ptr = pthread_getspecific(ctx_key);
-
-    if (ctx_ptr->name != NULL)
+    if (thread->name)
 	free(ctx_ptr->name);
-
-    ctx_ptr->name = strdup(name);
+    thread->name = strdup(name);
 }
 
 void

src/lib/player/login.c

@@ -344,7 +344,7 @@ play_cmd(void)
 	return RET_FAIL;
     }
     snprintf(buf, sizeof(buf), "Play#%d", player->cnum);
-    empth_set_name(buf);
+    empth_set_name(empth_self(), buf);
     logerror("%s logged in as country #%d", praddr(player), player->cnum);
     pr_id(player, C_INIT, "%d\n", CLIENTPROTO);
     player_main(player);

src/lib/subs/journal.c

@@ -83,7 +83,8 @@ journal_entry(char *fmt, ...)
 
     if (journal) {
 	time(&now);
-	fprintf(journal, "%.24s %10.10s:", ctime(&now), empth_name());
+	fprintf(journal, "%.24s %10.10s:",
+		ctime(&now), empth_name(empth_self()));
 	
 	va_start(ap, fmt);
 	vsnprintf(buf, sizeof(buf) - 1, fmt, ap);