From b2db6b811e8770e6373586fa490a90800351afa3 Mon Sep 17 00:00:00 2001 From: Qiang Zhao Date: Sat, 16 Nov 2024 00:44:43 +0800 Subject: [PATCH] fix log --- server/leader_controller.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/server/leader_controller.go b/server/leader_controller.go index 841c6aa3..db68b3be 100644 --- a/server/leader_controller.go +++ b/server/leader_controller.go @@ -912,27 +912,27 @@ func (lc *leaderController) handleWriteStream(closeStreamSignal chan error, stre lc.appendToWalStreamRequest(writeRequest, func(offset int64, timestamp uint64, err error) { if err != nil { latencyTimer.Done() - slog.Debug("Got an callback error when write to wal", slog.Any("error", err)) + slog.Debug("Got an error when write to wal", slog.Any("error", err)) lastCallbackError.Store(&err) return } lc.quorumAckTracker.WaitForCommitOffsetAsync(stream.Context(), offset, func(_ context.Context, innerErr error) { if innerErr != nil { latencyTimer.Done() - slog.Debug("Got an callback error when commit async", slog.Any("error", err)) + slog.Debug("Got an error when commit async", slog.Any("error", err)) lastCallbackError.Store(&err) return } var writeResponse *proto.WriteResponse if writeResponse, err = lc.db.ProcessWrite(writeRequest, offset, timestamp, WrapperUpdateOperationCallback); err != nil { latencyTimer.Done() - slog.Debug("Got an callback error when write to DB", slog.Any("error", err)) + slog.Debug("Got an error when write to DB", slog.Any("error", err)) lastCallbackError.Store(&err) return } if err = stream.Send(writeResponse); err != nil { latencyTimer.Done() - slog.Debug("Got an callback error when write response to client", slog.Any("error", err)) + slog.Debug("Got an error when write response to client", slog.Any("error", err)) lastCallbackError.Store(&err) return }