From 3f9bd8f121b07e30227dac7005e9072ba1a1bdc5 Mon Sep 17 00:00:00 2001 From: Runxi Yu Date: Sat, 28 Mar 2026 20:03:38 +0000 Subject: network: Rename flush (clearly distinguish flushing IO and writing flush packets) --- .../protocol/v0v1/server/receivepack/parse_test.go | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) (limited to 'network/protocol/v0v1/server/receivepack/parse_test.go') diff --git a/network/protocol/v0v1/server/receivepack/parse_test.go b/network/protocol/v0v1/server/receivepack/parse_test.go index 7c7cbe3b..3a891d3e 100644 --- a/network/protocol/v0v1/server/receivepack/parse_test.go +++ b/network/protocol/v0v1/server/receivepack/parse_test.go @@ -40,9 +40,9 @@ func TestReadRequestParsesCommandsAndPushOptions(t *testing.T) { t.Fatalf("WriteData(second): %v", err) } - err = enc.WriteFlush() + err = enc.WriteFlushPacket() if err != nil { - t.Fatalf("WriteFlush(commands): %v", err) + t.Fatalf("WriteFlushPacket(commands): %v", err) } err = enc.WriteData([]byte("ci.skip\n")) @@ -50,9 +50,9 @@ func TestReadRequestParsesCommandsAndPushOptions(t *testing.T) { t.Fatalf("WriteData(push-option): %v", err) } - err = enc.WriteFlush() + err = enc.WriteFlushPacket() if err != nil { - t.Fatalf("WriteFlush(push-options): %v", err) + t.Fatalf("WriteFlushPacket(push-options): %v", err) } base := common.NewSession(strings.NewReader(wire.String()), &bufferWriteFlusher{}, common.Options{ @@ -111,9 +111,9 @@ func TestReadRequestDeleteOnlyDoesNotExpectPack(t *testing.T) { t.Fatalf("WriteData: %v", err) } - err = enc.WriteFlush() + err = enc.WriteFlushPacket() if err != nil { - t.Fatalf("WriteFlush: %v", err) + t.Fatalf("WriteFlushPacket: %v", err) } base := common.NewSession(strings.NewReader(wire.String()), &bufferWriteFlusher{}, common.Options{ @@ -159,9 +159,9 @@ func TestReadRequestRejectsUnsupportedCapability(t *testing.T) { t.Fatalf("WriteData: %v", err) } - err = enc.WriteFlush() + err = enc.WriteFlushPacket() if err != nil { - t.Fatalf("WriteFlush: %v", err) + t.Fatalf("WriteFlushPacket: %v", err) } base := common.NewSession(strings.NewReader(wire.String()), &bufferWriteFlusher{}, common.Options{ @@ -222,9 +222,9 @@ func TestReadRequestParsesPushCertificate(t *testing.T) { } } - err = enc.WriteFlush() + err = enc.WriteFlushPacket() if err != nil { - t.Fatalf("WriteFlush: %v", err) + t.Fatalf("WriteFlushPacket: %v", err) } base := common.NewSession(strings.NewReader(wire.String()), &bufferWriteFlusher{}, common.Options{ -- cgit v1.3.1-10-gc9f91