Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for newDeadlineTimer (0.11 sec)

  1. src/net/net_fake.go

    	incomingEmpty chan bool     // holds true when the incoming queue is empty
    }
    
    func newFakeNetFD(fd *netFD) *fakeNetFD {
    	ffd := &fakeNetFD{fd: fd}
    	ffd.readDeadline.Store(newDeadlineTimer(noDeadline))
    	ffd.writeDeadline.Store(newDeadlineTimer(noDeadline))
    	return ffd
    }
    
    func (ffd *fakeNetFD) Read(p []byte) (n int, err error) {
    	n, _, err = ffd.queue.recvfrom(ffd.readDeadline.Load(), p, false, nil)
    	return n, err
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 27 19:24:21 UTC 2024
    - 26.4K bytes
    - Viewed (0)
Back to top