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) --- network/protocol/v0v1/server/session.go | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) (limited to 'network/protocol/v0v1/server/session.go') diff --git a/network/protocol/v0v1/server/session.go b/network/protocol/v0v1/server/session.go index 0a4ecb53..45e14c92 100644 --- a/network/protocol/v0v1/server/session.go +++ b/network/protocol/v0v1/server/session.go @@ -79,22 +79,22 @@ func (session *Session) WriteError(p []byte) error { return session.sideband.WriteError(p) } -// WriteFlush writes one trailing flush packet. -func (session *Session) WriteFlush() error { +// WriteFlushPacket writes one trailing flush packet. +func (session *Session) WriteFlushPacket() error { if session.useSideBand { - return session.sideband.WriteFlush() + return session.sideband.WriteFlushPacket() } - return session.enc.WriteFlush() + return session.enc.WriteFlushPacket() } -// FlushIO flushes buffered transport output without emitting pkt-line frames. -func (session *Session) FlushIO() error { +// Flush flushes buffered transport output without emitting pkt-line frames. +func (session *Session) Flush() error { if session.useSideBand { - return session.sideband.FlushIO() + return session.sideband.Flush() } - return session.enc.FlushIO() + return session.enc.Flush() } type flushWriter struct { @@ -120,7 +120,7 @@ func (session *Session) ProgressWriter() iowrap.WriteFlusher { return flushWriter{ writer: sideband64k.NewChunkWriter(session.sideband, sideband64k.BandProgress), - flush: session.sideband.FlushIO, + flush: session.sideband.Flush, } } -- cgit v1.3.1-10-gc9f91