add log

streamnative · Nov 15, 2024 · 95ceaf7 · 95ceaf7
1 parent 0a03e89
commit 95ceaf7
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/server/leader_controller.go b/server/leader_controller.go
@@ -912,23 +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))
 				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 write to wal", 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 wal", 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 to wal", slog.Any("error", err))
 					lastCallbackError.Store(&err)
 					return
 				}