aboutsummaryrefslogtreecommitdiff
path: root/network/protocol/v0v1/server
diff options
context:
space:
mode:
Diffstat (limited to 'network/protocol/v0v1/server')
-rw-r--r--network/protocol/v0v1/server/receivepack/session.go6
-rw-r--r--network/protocol/v0v1/server/session.go8
2 files changed, 9 insertions, 5 deletions
diff --git a/network/protocol/v0v1/server/receivepack/session.go b/network/protocol/v0v1/server/receivepack/session.go
index c367ed70..65fa6b36 100644
--- a/network/protocol/v0v1/server/receivepack/session.go
+++ b/network/protocol/v0v1/server/receivepack/session.go
@@ -10,6 +10,8 @@ import (
)
// Session is one stateful server-side receive-pack protocol session.
+//
+// Labels: MT-Unsafe.
type Session struct {
base *common.Session
supported Capabilities
@@ -171,7 +173,7 @@ func (session *Session) WriteProgress(p []byte) error {
//
// When side-band-64k was not negotiated, writes are discarded.
//
-// Labels: Life-Parent, Close-No.
+// Labels: Life-Parent.
func (session *Session) ProgressWriter() iowrap.WriteFlusher {
return session.base.ProgressWriter()
}
@@ -185,7 +187,7 @@ func (session *Session) WriteError(p []byte) error {
//
// When side-band-64k was not negotiated, writes are discarded.
//
-// Labels: Life-Parent, Close-No.
+// Labels: Life-Parent.
func (session *Session) ErrorWriter() iowrap.WriteFlusher {
return session.base.ErrorWriter()
}
diff --git a/network/protocol/v0v1/server/session.go b/network/protocol/v0v1/server/session.go
index 5d00b373..a66cc37a 100644
--- a/network/protocol/v0v1/server/session.go
+++ b/network/protocol/v0v1/server/session.go
@@ -18,6 +18,8 @@ type Options struct {
}
// Session is one stateful server-side v0/v1 server protocol session.
+//
+// Labels: MT-Unsafe.
type Session struct {
dec *pktline.Decoder
enc *pktline.Encoder
@@ -103,7 +105,7 @@ func (session *Session) Flush() error {
//
// When side-band-64k was not negotiated, writes are discarded.
//
-// Labels: Life-Parent, Close-No.
+// Labels: Life-Parent.
func (session *Session) ProgressWriter() iowrap.WriteFlusher {
if !session.useSideBand {
return iowrap.NopFlush(io.Discard)
@@ -116,7 +118,7 @@ func (session *Session) ProgressWriter() iowrap.WriteFlusher {
//
// When side-band-64k was not negotiated, writes are discarded.
//
-// Labels: Life-Parent, Close-No.
+// Labels: Life-Parent.
func (session *Session) ErrorWriter() iowrap.WriteFlusher {
if !session.useSideBand {
return iowrap.NopFlush(io.Discard)
@@ -130,7 +132,7 @@ func (session *Session) ErrorWriter() iowrap.WriteFlusher {
// When side-band-64k is enabled, writes are chunked into band-1 sideband
// frames. Otherwise writes are chunked into direct pkt-line data frames.
//
-// Labels: Life-Parent, Close-No.
+// Labels: Life-Parent.
func (session *Session) PrimaryDataWriter() iowrap.WriteFlusher {
if session.useSideBand {
return sideband64k.NewChunkWriter(session.sideband, sideband64k.BandData)