Commit a1e40bfc authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 86435f98
...@@ -32,7 +32,7 @@ import ( ...@@ -32,7 +32,7 @@ import (
"lab.nexedi.com/kirr/neo/go/internal/packed" "lab.nexedi.com/kirr/neo/go/internal/packed"
) )
// pktBuf is a buffer with full raw packet (header + data). // pktBuf is a buffer with full raw packet (header + payload).
// //
// Allocate pktBuf via pktAlloc() and free via pktBuf.Free(). // Allocate pktBuf via pktAlloc() and free via pktBuf.Free().
type pktBuf struct { type pktBuf struct {
...@@ -42,7 +42,7 @@ type pktBuf struct { ...@@ -42,7 +42,7 @@ type pktBuf struct {
// Header returns pointer to packet header. // Header returns pointer to packet header.
func (pkt *pktBuf) Header() *proto.PktHeader { func (pkt *pktBuf) Header() *proto.PktHeader {
// NOTE no need to check len(.data) < PktHeader: // NOTE no need to check len(.data) < PktHeader:
// .data is always allocated with cap >= PktHeaderLen // .data is always allocated with cap >= PktHeaderLen.
return (*proto.PktHeader)(unsafe.Pointer(&pkt.data[0])) return (*proto.PktHeader)(unsafe.Pointer(&pkt.data[0]))
} }
...@@ -53,7 +53,7 @@ func (pkt *pktBuf) Payload() []byte { ...@@ -53,7 +53,7 @@ func (pkt *pktBuf) Payload() []byte {
// ---- pktBuf freelist ---- // ---- pktBuf freelist ----
// pktBufPool is sync.Pool<pktBuf> // pktBufPool is sync.Pool<pktBuf>.
var pktBufPool = sync.Pool{New: func() interface{} { var pktBufPool = sync.Pool{New: func() interface{} {
return &pktBuf{data: make([]byte, 0, 4096)} return &pktBuf{data: make([]byte, 0, 4096)}
}} }}
...@@ -78,7 +78,7 @@ func (pkt *pktBuf) Free() { ...@@ -78,7 +78,7 @@ func (pkt *pktBuf) Free() {
// ---- pktBuf dump ---- // ---- pktBuf dump ----
// Strings dumps a packet in human-readable form // String dumps a packet in human-readable form.
func (pkt *pktBuf) String() string { func (pkt *pktBuf) String() string {
if len(pkt.data) < proto.PktHeaderLen { if len(pkt.data) < proto.PktHeaderLen {
return fmt.Sprintf("(! < PktHeaderLen) % x", pkt.data) return fmt.Sprintf("(! < PktHeaderLen) % x", pkt.data)
...@@ -113,7 +113,7 @@ func (pkt *pktBuf) String() string { ...@@ -113,7 +113,7 @@ func (pkt *pktBuf) String() string {
return s return s
} }
// Dump dumps a packet in raw form // Dump dumps a packet in raw form.
func (pkt *pktBuf) Dump() string { func (pkt *pktBuf) Dump() string {
if len(pkt.data) < proto.PktHeaderLen { if len(pkt.data) < proto.PktHeaderLen {
return fmt.Sprintf("(! < pktHeaderLen) % x", pkt.data) return fmt.Sprintf("(! < pktHeaderLen) % x", pkt.data)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment