Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 3 of 3 for SetBlocking (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/ringbuffer/README.md

    meaning that reads and writes will return immediately with an error if the operation cannot be completed.
    If you want to block when reading or writing, you must enable it:
    
    ```go
    	rb := ringbuffer.New(1024).SetBlocking(true)
    ```
    
    Enabling blocking will cause the ring buffer to behave like a buffered [io.Pipe](https://pkg.go.dev/io#Pipe).
    
    Regular Reads will block until data is available, but not wait for a full buffer. 
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 15 00:11:04 GMT 2024
    - 2.1K bytes
    - Click Count (0)
  2. internal/ringbuffer/ring_buffer.go

    		size: size,
    	}
    }
    
    // NewBuffer returns a new RingBuffer whose buffer is provided.
    func NewBuffer(b []byte) *RingBuffer {
    	return &RingBuffer{
    		buf:  b,
    		size: len(b),
    	}
    }
    
    // SetBlocking sets the blocking mode of the ring buffer.
    // If block is true, Read and Write will block when there is no data to read or no space to write.
    // If block is false, Read and Write will return ErrIsEmpty or ErrIsFull immediately.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  3. cmd/bitrot-streaming.go

    	h := algo.New()
    	buf := globalBytePoolCap.Load().Get()
    	rb := ringbuffer.NewBuffer(buf[:cap(buf)]).SetBlocking(true)
    
    	bw := &streamingBitrotWriter{
    		iow:          ioutil.NewDeadlineWriter(rb.WriteCloser(), globalDriveConfig.GetMaxTimeout()),
    		closeWithErr: rb.CloseWithError,
    		h:            h,
    		shardSize:    shardSize,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jan 17 19:19:30 GMT 2025
    - 6.2K bytes
    - Click Count (0)
Back to Top