ABL

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
 }
 

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()
 		}