- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for TryWrite (0.11 sec)
-
internal/ringbuffer/ring_buffer_test.go
err = rb.WriteByte(buf[0]) if err != nil { t.Fatalf("write failed: %v", err) } wroteBytes++ wrote.Write(buf[:1]) debugln("WRITE 3\t", 1, wroteBytes) // TryWrite n, err = rb.TryWrite(buf[:writeRng.Intn(len(buf))]) if err != nil && err != ErrAcquireLock && err != ErrTooMuchDataToWrite && err != ErrIsFull { t.Fatalf("write failed: %v", err) } wroteBytes += n
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 26.8K bytes - Viewed (0) -
internal/ringbuffer/README.md
Regular Reads will block until data is available, but not wait for a full buffer. Writes will block until there is space available and writes bigger than the buffer will wait for reads to make space. `TryRead` and `TryWrite` are still available for non-blocking reads and writes. To signify the end of the stream, close the ring buffer from the writer side with `rb.CloseWriter()`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.1K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
} if r.block && wrote > 0 { r.writeCond.Broadcast() } return wrote, r.setErr(err, true) } // TryWrite writes len(p) bytes from p to the underlying buf like Write, but it is not blocking. // If it has not succeeded to acquire the lock, it return 0 as n and ErrAcquireLock. func (r *RingBuffer) TryWrite(p []byte) (n int, err error) { if len(p) == 0 { return 0, r.setErr(nil, false) } ok := r.mu.TryLock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0)