[sheepdog] [PATCH 5/5] logger: don't show a thread index for an ordered work queue

MORITA Kazutaka morita.kazutaka at lab.ntt.co.jp
Mon Jul 2 20:32:16 CEST 2012


Signed-off-by: MORITA Kazutaka <morita.kazutaka at lab.ntt.co.jp>
---
 lib/logger.c |   10 ++++++++--
 sheep/work.c |    2 +-
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/lib/logger.c b/lib/logger.c
index c64aefc..c1dd160 100644
--- a/lib/logger.c
+++ b/lib/logger.c
@@ -202,9 +202,12 @@ static notrace int log_enqueue(int prio, const char *func, int line, const char
 		strftime(p, MAX_MSG_SIZE, "%b %2d %H:%M:%S", tmp);
 		p += strlen(p);
 
-		if (worker_name)
+		if (worker_name && worker_idx)
 			snprintf(p, MAX_MSG_SIZE - strlen(buff), " [%s %d] ",
 				 worker_name, worker_idx);
+		else if (worker_name)
+			snprintf(p, MAX_MSG_SIZE - strlen(buff), " [%s] ",
+				 worker_name, worker_idx);
 		else
 			strncpy(p, " [main] ", MAX_MSG_SIZE - strlen(buff));
 
@@ -323,9 +326,12 @@ static notrace void dolog(int prio, const char *func, int line,
 
 		vsnprintf(p, MAX_MSG_SIZE, fmt, ap);
 
-		if (worker_name)
+		if (worker_name && worker_idx)
 			fprintf(stderr, "[%s %d] %s(%d) %s", worker_name,
 				worker_idx, func, line, p);
+		else if (worker_name)
+			fprintf(stderr, "[%s] %s(%d) %s", worker_name, func,
+				line, p);
 		else
 			fprintf(stderr, "[main] %s(%d) %s", func, line, p);
 
diff --git a/sheep/work.c b/sheep/work.c
index 9deac01..44aa180 100644
--- a/sheep/work.c
+++ b/sheep/work.c
@@ -61,7 +61,7 @@ static void *run_short_thread(void * arg)
 {
 	struct short_work *sw = arg;
 	eventfd_t value = 1;
-	static uint64_t idx = 0;
+	static uint64_t idx = 1;
 
 	uatomic_inc(&idx);
 	set_thread_name(sw->wi->name, idx);
-- 
1.7.2.5




More information about the sheepdog mailing list