Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for SetBlocking (0.07 sec)

  1. 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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 12:20:54 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top