Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for SetBlocking (0.21 sec)

  1. src/internal/poll/fd_unix.go

    	if fd.isBlocking == 0 {
    		runtime_Semacquire(&fd.csema)
    	}
    
    	return err
    }
    
    // SetBlocking puts the file into blocking mode.
    func (fd *FD) SetBlocking() error {
    	if err := fd.incref(); err != nil {
    		return err
    	}
    	defer fd.decref()
    	// Atomic store so that concurrent calls to SetBlocking
    	// do not cause a race condition. isBlocking only ever goes
    	// from 0 to 1 so there is no real race here.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  2. internal/ringbuffer/ring_buffer_test.go

    		t.Fatalf("expect 16 abcd and 4 1234 but got %s. r.w=%d, r.r=%d", rb.Bytes(nil), rb.w, rb.r)
    	}
    }
    
    func TestRingBuffer_WriteBlocking(t *testing.T) {
    	rb := New(64).SetBlocking(true)
    
    	// check empty or full
    	if !rb.IsEmpty() {
    		t.Fatalf("expect IsEmpty is true but got false")
    	}
    	if rb.IsFull() {
    		t.Fatalf("expect IsFull is false but got true")
    	}
    	if rb.Length() != 0 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  3. 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.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. src/os/file_unix.go

    	// because historically we have always returned a descriptor
    	// opened in blocking mode. The File will continue to work,
    	// but any blocking operation will tie up a thread.
    	if f.nonblock {
    		f.pfd.SetBlocking()
    	}
    
    	return uintptr(f.pfd.Sysfd)
    }
    
    // NewFile returns a new File with the given file descriptor and
    // name. The returned value will be nil if fd is not a valid file
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 13:52:34 UTC 2024
    - 14.9K bytes
    - Viewed (0)
Back to top