MCPcopy Create free account
hub / github.com/IceFireDB/IceFireDB / ReadPacketReuseMem

Method ReadPacketReuseMem

IceFireDB-SQLite/pkg/mysql/packet/conn.go:99–111  ·  view source on GitHub ↗
(dst []byte)

Source from the content-addressed store, hash-verified

97}
98
99func (c *Conn) ReadPacketReuseMem(dst []byte) ([]byte, error) {
100 // Here we use `sync.Pool` to avoid allocate/destroy buffers frequently.
101 buf := utils.BytesBufferGet()
102 defer utils.BytesBufferPut(buf)
103
104 if err := c.ReadPacketTo(buf); err != nil {
105 c.pkgErr = err
106 return nil, errors.Trace(err)
107 } else {
108 result := append(dst, buf.Bytes()...)
109 return result, nil
110 }
111}
112
113func (c *Conn) copyN(dst io.Writer, src io.Reader, n int64) (written int64, err error) {
114 for n > 0 {

Callers 6

readResultMethod · 0.95
readResultStreamingMethod · 0.95
readResultColumnsMethod · 0.95
readResultRowsMethod · 0.95
ReadPacketMethod · 0.95

Calls 4

ReadPacketToMethod · 0.95
BytesBufferGetFunction · 0.92
BytesBufferPutFunction · 0.92
BytesMethod · 0.45

Tested by

no test coverage detected