Set thread names under Linux.

ChangeLog

@@ -1,4 +1,5 @@
 xxxx-xx-xx : Version -next
+ * Set thread names under Linux.
  * notify: Added no_code_word/code_word_ok events.
  * notify: Added input_timeout/input_ok events.
  * notify: Added start/stop events.

camd.c

@@ -338,6 +338,9 @@ void camd_msg_free(struct camd_msg **pmsg) {
 
 static void *camd_thread(void *in_ts) {
 	struct ts *ts = in_ts;
+
+	set_thread_name("tsdec-camd");
+
 	while (1) {
 		struct camd_msg *msg;
 		void *req = queue_get(ts->camd35.req_queue); // Waits...

notify.c

@@ -33,6 +33,7 @@
 #include "libfuncs/queue.h"
 
 #include "notify.h"
+#include "util.h"
 
 struct npriv {
 	char	ident[512];
@@ -88,6 +89,8 @@ OUT:
 static void *notify_thread(void *data) {
 	struct notify *n = data;
 
+	set_thread_name("tsdec-notify");
+
 	while (1) {
 		struct npriv *np = queue_get(n->notifications); // Waits...
 		if (!np)

process.c

@@ -20,6 +20,7 @@
 
 #include "data.h"
 #include "tables.h"
+#include "util.h"
 
 static unsigned long ts_pack;
 static int ts_pack_shown;
@@ -178,6 +179,8 @@ void *decode_thread(void *_ts) {
 	int data_size;
 	int req_size = 188 * dvbcsa_bs_batch_size();
 
+	set_thread_name("tsdec-decode");
+
 	while (!ts->decode_stop) {
 		data = cbuf_peek(ts->decode_buf, req_size, &data_size);
 		if (data_size < req_size) {
@@ -203,6 +206,8 @@ void *write_thread(void *_ts) {
 	uint8_t *data;
 	int data_size;
 
+	set_thread_name("tsdec-write");
+
 	while (!ts->write_stop) {
 		data_size = 0;
 		data = cbuf_peek(ts->write_buf, FRAME_SIZE, &data_size);

util.c

@@ -15,6 +15,9 @@
  * along with this program; if not, write to the Free Software
  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
  */
+
+#include <string.h>
+
 #include "util.h"
 
 static unsigned long crc_table[256] = {
@@ -118,3 +121,17 @@ uint8_t *init_2b(uint32_t val, uint8_t *b) {
 	b[1] = (val     ) & 0xff;
 	return b;
 }
+
+#ifdef __linux__
+#include <sys/prctl.h>
+
+void set_thread_name(char *thread_name) {
+	prctl(PR_SET_NAME, thread_name, NULL, NULL, NULL);
+}
+
+#else
+void set_thread_name(char *thread_name) {
+    (void)thread_name;
+}
+
+#endif

util.h

@@ -25,5 +25,6 @@ int32_t boundary(int32_t exp, int32_t n);
 uint8_t *init_4b(uint32_t val, uint8_t *b);
 uint8_t *init_4l(uint32_t val, uint8_t *b);
 uint8_t *init_2b(uint32_t val, uint8_t *b);
+void set_thread_name(char *thread_name);
 
 #endif