diff options
Diffstat (limited to 'network/protocol/pktline')
| -rw-r--r-- | network/protocol/pktline/chunk_writer.go | 2 | ||||
| -rw-r--r-- | network/protocol/pktline/decoder.go | 2 | ||||
| -rw-r--r-- | network/protocol/pktline/encoder.go | 2 |
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 |
