From cf23612147479c8d4847c1ae9036cb9211f74210 Mon Sep 17 00:00:00 2001 From: Philip O'Toole Date: Sat, 6 Jan 2024 10:43:28 -0500 Subject: [PATCH] ABL --- cluster/client.go | 2 ++ store/gzip/decompressor_test.go | 4 ++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/cluster/client.go b/cluster/client.go index 2b42a8cb..0f39200f 100644 --- a/cluster/client.go +++ b/cluster/client.go @@ -255,7 +255,9 @@ func (c *Client) Backup(br *command.BackupRequest, nodeAddr string, creds *proto rc = gzr defer rc.Close() } + ss := time.Now() _, err = io.Copy(w, rc) + fmt.Println("backup copy time on client side:", time.Since(ss)) return err } diff --git a/store/gzip/decompressor_test.go b/store/gzip/decompressor_test.go index 56e84507..e96f0851 100644 --- a/store/gzip/decompressor_test.go +++ b/store/gzip/decompressor_test.go @@ -60,10 +60,10 @@ func Test_Decompressor_EndToEnd(t *testing.T) { } compressor, err := NewCompressor(srcBuf, DefaultBufferSize) if err != nil { - t.Fatalf("failed to create compressor: %v", err) + t.Errorf("failed to create compressor: %v", err) } if _, err := io.Copy(conn, compressor); err != nil { - t.Fatalf("failed to copy data: %v", err) + t.Errorf("failed to copy data: %v", err) } conn.Close() }