Location via proxy:   [ UP ]  
[Report a bug]   [Manage cookies]                
Skip to content

Commit 373f919

Browse files
committed
Make raftable worker less verbose about notifying and emitting updates.
1 parent 71b013d commit 373f919

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

contrib/raftable/worker.c

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -237,7 +237,7 @@ static void on_message_recv(Client *c)
237237
}
238238
else
239239
{
240-
elog(WARNING, "emitted raft update %d", index);
240+
elog(DEBUG1, "emitted raft update %d", index);
241241
c->expect = index;
242242
c->state = CLIENT_WAITING;
243243
}
@@ -298,7 +298,7 @@ static void attend(Client *c)
298298
if (c->state == CLIENT_SICK) return;
299299
if (!c->msg) return;
300300
if (c->cursor < c->msg->len) return;
301-
elog(WARNING, "got %d bytes from client", (int)c->cursor);
301+
elog(DEBUG1, "got %d bytes from client", (int)c->cursor);
302302
on_message_recv(c);
303303
break;
304304
case CLIENT_RECVING:
@@ -324,7 +324,7 @@ static void notify(void)
324324
Assert(c->expect >= 0);
325325
if (!raft_applied(raft, server.id, c->expect)) continue;
326326

327-
elog(WARNING, "notify client %d that update %d is applied", i, c->expect);
327+
elog(DEBUG1, "notify client %d that update %d is applied", i, c->expect);
328328
answer = make_single_value_message("", NULL, 0, &answersize);
329329
answer->meaning = MEAN_OK;
330330
c->msg = palloc(sizeof(Message) + answersize);

0 commit comments

Comments
 (0)