- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ringBuffer (0.16 sec)
-
internal/ringbuffer/ring_buffer.go
} // New returns a new RingBuffer whose buffer has the given size. func New(size int) *RingBuffer { return &RingBuffer{ buf: make([]byte, size), size: size, } } // NewBuffer returns a new RingBuffer whose buffer is provided. func NewBuffer(b []byte) *RingBuffer { return &RingBuffer{ buf: b, size: len(b), } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
internal/ringbuffer/README.md
# ringbuffer
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.1K bytes - Viewed (0) -
cmd/bitrot-streaming.go
package cmd import ( "bytes" "context" "hash" "io" "sync" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/ioutil" "github.com/minio/minio/internal/ringbuffer" ) // Calculates bitrot in chunks and writes the hash into the stream. type streamingBitrotWriter struct { iow io.WriteCloser closeWithErr func(err error) h hash.Hash shardSize int64
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 6.1K bytes - Viewed (0) -
src/log/slog/internal/benchmarks/handlers_test.go
t.Errorf("\ngot %q\nwant %q", got, wantText) } }) t.Run("async", func(t *testing.T) { h := newAsyncHandler() if err := h.Handle(ctx, r); err != nil { t.Fatal(err) } got := h.ringBuffer[0] if !got.Time.Equal(r.Time) || !slices.EqualFunc(attrSlice(got), attrSlice(r), slog.Attr.Equal) { t.Errorf("got %+v, want %+v", got, r) } }) } func attrSlice(r slog.Record) []slog.Attr {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 17 23:34:11 UTC 2023 - 1.1K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_benchmark_test.go
package ringbuffer import ( "io" "strings" "testing" ) func BenchmarkRingBuffer_Sync(b *testing.B) { rb := New(1024) data := []byte(strings.Repeat("a", 512)) buf := make([]byte, 512) b.ResetTimer() for i := 0; i < b.N; i++ { rb.Write(data) rb.Read(buf) } } func BenchmarkRingBuffer_AsyncRead(b *testing.B) { // Pretty useless benchmark, but it's here for completeness. rb := New(1024)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer_test.go
package ringbuffer import ( "bytes" "errors" "fmt" "hash/crc32" "io" "math/rand" "os" "runtime" "strings" "sync" "testing" "time" ) func TestRingBuffer_interface(t *testing.T) { rb := New(1) var _ io.Writer = rb var _ io.Reader = rb // var _ io.StringWriter = rb var _ io.ByteReader = rb var _ io.ByteWriter = rb } func TestRingBuffer_Write(t *testing.T) { rb := New(64)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0)