From 9b5fd7c9ea67c145f2769f7213fde0ede5704f53 Mon Sep 17 00:00:00 2001
From: Dominik Werder <dominik.werder@gmail.com>
Date: Fri, 28 May 2021 10:26:27 +0200
Subject: [PATCH] It is no error if client disconnects

---
 disk/src/raw/conn.rs | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/disk/src/raw/conn.rs b/disk/src/raw/conn.rs
index 3df22f5..c7e2957 100644
--- a/disk/src/raw/conn.rs
+++ b/disk/src/raw/conn.rs
@@ -13,6 +13,7 @@ use err::Error;
 use futures_util::StreamExt;
 use netpod::log::*;
 use netpod::{AggKind, ByteSize, NodeConfigCached, PerfOpts};
+use std::io;
 use std::net::SocketAddr;
 use tokio::io::AsyncWriteExt;
 use tokio::net::tcp::OwnedWriteHalf;
@@ -60,10 +61,13 @@ async fn events_conn_handler_inner(
                 make_frame::<Result<StreamItem<RangeCompletableItem<MinMaxAvgScalarEventBatch>>, Error>>(&Err(ce.err))?;
             match ce.netout.write_all(&buf).await {
                 Ok(_) => (),
-                Err(e) => {
-                    error!("events_conn_handler_inner sees: {:?}", e);
-                    return Err(e)?;
-                }
+                Err(e) => match e.kind() {
+                    io::ErrorKind::BrokenPipe => {}
+                    _ => {
+                        error!("events_conn_handler_inner sees: {:?}", e);
+                        return Err(e)?;
+                    }
+                },
             }
         }
     }