- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for PutByteBuffer (0.27 sec)
-
internal/grid/grid.go
if cap(b) >= wantSz { return b } PutByteBuffer(b) } if wantSz <= maxBufferSize { b := *internal32KByteBuffer.Get().(*[]byte) if cap(b) >= wantSz { return b[:0] } internal32KByteBuffer.Put(&b) } return make([]byte, 0, wantSz) } // PutByteBuffer is for returning byte buffers. var PutByteBuffer = func(b []byte) { if cap(b) >= biggerBufMin && cap(b) < biggerBufMax {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
if err := enc.Encode(tmpEvt); err != nil { bugLogIf(ctx, err, "event: Encode failed") continue } mergeCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...) case <-ctx.Done(): grid.PutByteBuffer(buf.Bytes()) return } } }() peers, _ := newPeerRestClients(globalEndpoints) err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/grid/README.md
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/grid/msg.go
m.Payload = GetByteBuffer()[:0] } h, err := m.UnmarshalMsg(b) if err != nil { return nil, nil, fmt.Errorf("read write: %v", err) } if len(m.Payload) == 0 && m.Flags&FlagPayloadIsZero == 0 { PutByteBuffer(m.Payload) m.Payload = nil } if m.Flags&FlagCRCxxh3 != 0 { const hashLen = 4 if len(h) < hashLen { return nil, nil, fmt.Errorf("want crc len 4, got %v", len(h)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0)