aboutsummaryrefslogtreecommitdiff
path: root/network/protocol/pktline
diff options
context:
space:
mode:
Diffstat (limited to 'network/protocol/pktline')
-rw-r--r--network/protocol/pktline/chunk_writer.go2
-rw-r--r--network/protocol/pktline/decoder.go2
-rw-r--r--network/protocol/pktline/encoder.go2
3 files changed, 6 insertions, 0 deletions
diff --git a/network/protocol/pktline/chunk_writer.go b/network/protocol/pktline/chunk_writer.go
index 3c9d409a..f009978e 100644
--- a/network/protocol/pktline/chunk_writer.go
+++ b/network/protocol/pktline/chunk_writer.go
@@ -4,6 +4,8 @@ import "io"
// ChunkWriter packetizes arbitrary stream bytes into data pkt-lines.
// It never writes control packets automatically.
+//
+// Labels: MT-Unsafe.
type ChunkWriter struct {
enc *Encoder
}
diff --git a/network/protocol/pktline/decoder.go b/network/protocol/pktline/decoder.go
index 15cab63d..682dd164 100644
--- a/network/protocol/pktline/decoder.go
+++ b/network/protocol/pktline/decoder.go
@@ -17,6 +17,8 @@ type ReadOptions struct {
// It is advisable to supply a buffered reader.
//
// It preserves frame boundaries and supports one-frame lookahead via PeekFrame.
+//
+// Labels: MT-Unsafe.
type Decoder struct {
r io.Reader
maxData int
diff --git a/network/protocol/pktline/encoder.go b/network/protocol/pktline/encoder.go
index ab8bb823..a7b17108 100644
--- a/network/protocol/pktline/encoder.go
+++ b/network/protocol/pktline/encoder.go
@@ -10,6 +10,8 @@ import (
// Encoder writes pkt-line frames to a flush-capable output transport.
//
// It writes exactly one frame per method call and does not auto-chunk data.
+//
+// Labels: MT-Unsafe.
type Encoder struct {
w iowrap.WriteFlusher
maxData int