From 480f210a605ec4047823316c41130536f6a2e0ce Mon Sep 17 00:00:00 2001
From: cschen <cschen@codemp.dev>
Date: Mon, 17 Feb 2025 21:54:11 +0100
Subject: [PATCH] changed the worker recognizing the closure of the controller
from error to debug message.
---
src/buffer/worker.rs | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/src/buffer/worker.rs b/src/buffer/worker.rs
index e5ee53b..9b6b434 100644
--- a/src/buffer/worker.rs
+++ b/src/buffer/worker.rs
@@ -115,7 +115,7 @@ impl BufferController {
// received new change ack, merge editor branch up to that version
res = worker.ack_rx.recv() => match res {
- None => break tracing::error!("ack channel closed"),
+ None => break tracing::debug!("stopping: ack channel closed"),
Some(v) => {
tracing::debug!("client acked change");
worker.branch.merge(&worker.oplog, &v);
@@ -126,7 +126,7 @@ impl BufferController {
// received a new poller, add it to collection
res = worker.poller.recv() => match res {
- None => break tracing::error!("poller channel closed"),
+ None => break tracing::debug!("stopping: poller channel closed"),
Some(tx) => worker.pollers.push(tx),
},
@@ -213,10 +213,11 @@ impl BufferWorker {
#[tracing::instrument(skip(self))]
async fn handle_server_change(&mut self, change: BufferEvent) -> bool {
match self.controller.upgrade() {
- None => { // clean exit actually, just weird we caught it here
+ None => {
+ // clean exit actually, just weird we caught it here
tracing::debug!("clean exit while handling server change");
true
- },
+ }
Some(controller) => match self.oplog.decode_and_add(&change.op.data) {
Ok(local_version) => {
tracing::debug!("updating local version: {local_version:?}");