aboutsummaryrefslogtreecommitdiff
path: root/network/protocol/v0v1/server/session.go
diff options
context:
space:
mode:
authorGravatar Runxi Yu2026-03-28 20:03:38 +0000
committerGravatar Runxi Yu2026-03-28 20:03:38 +0000
commit3f9bd8f121b07e30227dac7005e9072ba1a1bdc5 (patch)
treeabe5b3950f1e170d88c9228f53d8db20ea212b17 /network/protocol/v0v1/server/session.go
parentnetwork, internal/progress, format/packfile/ingest: Use WriteFlusher (diff)
signatureNo signature
network: Rename flush (clearly distinguish flushing IO and writing flush packets)
Diffstat (limited to 'network/protocol/v0v1/server/session.go')
-rw-r--r--network/protocol/v0v1/server/session.go18
1 files changed, 9 insertions, 9 deletions
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,
}
}