From b6d6d077d4b28c2dcc644baadcfbc35e44f37a32 Mon Sep 17 00:00:00 2001 From: Runxi Yu Date: Sun, 29 Mar 2026 03:50:31 +0000 Subject: network: Fix labels --- network/protocol/pktline/chunk_writer.go | 2 ++ network/protocol/pktline/decoder.go | 2 ++ network/protocol/pktline/encoder.go | 2 ++ 3 files changed, 6 insertions(+) (limited to 'network/protocol/pktline') 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 -- cgit v1.3.1-10-gc9f91