MCPcopy Index your code

hub / github.com/npat-efault/poller / functions

Functions91 in github.com/npat-efault/poller

⨍ Functions 91◇ Types & classes 9
↓ 47 callersFunctiondebugf
(format string, v ...interface{})
poller.go:347
↓ 26 callersMethodClose
Close the file descriptor. It is ok to call Close concurently with other operations (Read, Write, SetDeadline, etc) on the same file-descriptor. In th
poller.go:211
↓ 25 callersMethodUnlock
Unlock unlocks the file-descriptor.
poller.go:337
↓ 21 callersMethodLock
Lock the file-descriptor. It must be called before perfoming miscellaneous operations (e.g. ioctls) on the underlying system file descriptor. It prote
poller.go:327
↓ 17 callersFunctionopenFifo
(t *testing.T, i int, read bool)
poller_test.go:35
↓ 11 callersFunctionwaitN
(t *testing.T, ch <-chan error, n int)
poller_test.go:64
↓ 10 callersMethodError
()
error.go:23
↓ 10 callersMethodRead
TODO(npat): Add FromFile function? Read up to len(p) bytes into p. Returns the number of bytes read (0 <= n <= len(p)) and any error encountered. If s
poller.go:161
↓ 9 callersMethodWrite
Writes len(p) bytes from p to the file-descriptor. Returns the number of bytes written (0 <= n <= len(p)) and any error encountered that caused the w
poller.go:194
↓ 8 callersMethodGetFD
GetFD returns the FD with key id. Returns nil if no such FD is in the map.
poller.go:46
↓ 8 callersFunctionmkFifo
(t *testing.T, i int)
poller_test.go:26
↓ 6 callersMethodSetReadDeadline
SetReadDeadline sets the deadline for Read operations on the file-descriptor.
poller.go:253
↓ 6 callersFunctionreadStr
(fd *FD, s string)
poller_test.go:72
↓ 5 callersFunctionwriteStr
(fd *FD, s string)
poller_test.go:87
↓ 4 callersMethodClear
(sysfd int, rw dirFlag)
poller_select.go:101
↓ 4 callersMethodSeq
()
echo_test.go:124
↓ 4 callersMethodSetWriteDeadline
SetWriteDeadline sets the deadline for Write operations on the file-descriptor.
poller.go:259
↓ 4 callersFunctionopenFifo
(t *testing.T, i int, read bool)
echo_test.go:244
↓ 4 callersFunctionwaitNTmo
(t *testing.T, ch <-chan error, n int, d time.Duration)
poller_test.go:68
↓ 3 callersMethodIsSet
(fd int)
select_cgo.go:53
↓ 3 callersMethodZero
()
select_cgo.go:49
↓ 3 callersFunctionfifoName
(i int)
echo_test.go:223
↓ 3 callersFunctionreadBlock
(fd *FD, n, bs int, dly time.Duration)
poller_test.go:98
↓ 3 callersFunctionwriteBlock
(fd *FD, n, bs int, dly time.Duration)
poller_test.go:119
↓ 2 callersMethodAddFD
AddFD creates an entry for the FD with key "fd.id".
poller.go:63
↓ 2 callersMethodClr
(fds ...int)
select_cgo.go:37
↓ 2 callersMethodData
()
echo_test.go:129
↓ 2 callersMethodDelFD
(id int)
poller.go:73
↓ 2 callersMethodInit
()
poller_select.go:42
↓ 2 callersFunctionNewFD
NewFD initializes and returns a new poller file-descriptor from the given system (unix) file-descriptor. After calling NewFD the system file-descripto
poller.go:146
↓ 2 callersMethodSend
(w io.Writer)
echo_test.go:133
↓ 2 callersMethodSet
(sysfd int, rw dirFlag)
poller_select.go:84
↓ 2 callersMethodSetDeadline
SetDeadline sets the deadline for both Read and Write operations on the file-descriptor. Deadlines are expressed as ABSOLUTE instances in time. For ex
poller.go:244
↓ 2 callersFunctiondebugSets
(pref string, rs, ws *fdSet, nfds int)
poller_select.go:167
↓ 2 callersFunctionepollEvent
(ev *syscall.EpollEvent, write bool)
poller_epoll.go:240
↓ 2 callersFunctionfdIO
* - We use Edge Triggered notifications so we can only sleep (cond.Wait) when the syscall (Read/Write) returns with EAGAIN - While sleeping we don
poller_epoll.go:81
↓ 2 callersFunctionfifoName
tmp/poller-test-fifoXXX
poller_test.go:22
↓ 2 callersFunctionmkErr
(flags errFlags, msg string)
error.go:39
↓ 2 callersFunctionmkFifo
(t *testing.T, i int)
echo_test.go:227
↓ 2 callersFunctionrcvMsg
(r io.Reader)
echo_test.go:138
↓ 2 callersFunctionrmFifo
(t *testing.T, i int)
echo_test.go:236
↓ 2 callersFunctionsetDeadline
TODO(npat): If deadline is not After(time.Now()) wake-up goroutines imediatelly; don't go through the timer callback
poller.go:266
↓ 2 callersFunctionsetStr
(s *fdSet, nfd int)
poller_select.go:145
↓ 2 callersFunctionuxSelect
(nfd int, r, w, e *fdSet, tv *syscall.Timeval)
select_bsd.go:12
↓ 2 callersFunctionwaitNTmo_
(t *testing.T, ch <-chan error, n int, d time.Duration)
poller_test.go:48
↓ 1 callersMethodCloseUnlocked
CloseUnlocked is equivalent to (*FD).Close, with the difference that with CloseUnlocked the caller is responsible for locking the FD before calling it
poller.go:227
↓ 1 callersMethodGetID
GetID reserves and returns the next available ID
poller.go:54
↓ 1 callersMethodInit
(n int)
poller.go:37
↓ 1 callersMethodLen
()
echo_test.go:119
↓ 1 callersMethodNotify
()
poller_select.go:117
↓ 1 callersFunctionOpen
Open the named path for reading, writing or both, depnding on the flags argument.
poller.go:133
↓ 1 callersMethodSet
(fds ...int)
select_cgo.go:43
↓ 1 callersMethodcloseUnlocked
* - Close / CloseUnlocked must acquire *all* locks (read, write and C) before proceeding. Otherwise there is the danger that a concurent re
poller_epoll.go:168
↓ 1 callersMethoddrainPfdr
()
poller_select.go:133
↓ 1 callersFunctionechoN
(r, w *poller.FD, n int)
echo_test.go:191
↓ 1 callersMethodgetSets
()
poller_select.go:126
↓ 1 callersFunctionisReadEvent
(ev *syscall.EpollEvent)
poller_epoll.go:275
↓ 1 callersFunctionisWriteEvent
(ev *syscall.EpollEvent)
poller_epoll.go:282
↓ 1 callersFunctionnewFD
TODO(npat): Add finalizer
poller_epoll.go:23
↓ 1 callersFunctionpackRandData
(p []byte, n int)
echo_test.go:75
↓ 1 callersFunctionpackUInt16BE
(p []byte, i uint16)
echo_test.go:55
↓ 1 callersFunctionpackUInt32BE
tmp/poller-test-fifoXXX
echo_test.go:47
↓ 1 callersFunctionpoller
()
poller_epoll.go:288
↓ 1 callersFunctionrandMsg
(seq uint32)
echo_test.go:104
↓ 1 callersMethodrun
run runs as the select-goroutine. It never returns.
poller_select.go:175
↓ 1 callersFunctionsendN
(r, w *poller.FD, n int)
echo_test.go:154
↓ 1 callersFunctiontimerEvent
(id int, write bool)
poller_epoll.go:204
↓ 1 callersFunctionunpackUInt16BE
(p []byte)
echo_test.go:69
↓ 1 callersFunctionunpackUInt32BE
(p []byte)
echo_test.go:61
↓ 1 callersFunctionwaitNTmo
(t *testing.T, ch <-chan error, n int, d time.Duration)
echo_test.go:257
MethodClosed
()
error.go:35
MethodSysfd
Sysfd returns the system file-descriptor associated with the given poller file-descriptor. See also (*FD).Lock.
poller.go:343
MethodTemporary
()
error.go:31
FunctionTestClose
(t *testing.T)
poller_test.go:168
FunctionTestCloseWrite
(t *testing.T)
poller_test.go:268
FunctionTestDeadlines
(t *testing.T)
poller_test.go:402
FunctionTestEcho
(t *testing.T)
echo_test.go:273
FunctionTestNewFDFail
(t *testing.T)
poller_epoll_test.go:15
FunctionTestOpen
(t *testing.T)
poller_test.go:136
FunctionTestRead
(t *testing.T)
poller_test.go:303
FunctionTestWrite
(t *testing.T)
poller_test.go:347
FunctionTestXBlock
TestXBlock tests if a blocking misc call for an FD (fd1r---keeping the FD locked for the duration), blocks access to another FD (fd0r). With v1.0.0 it
poller_test.go:502
MethodTimeout
()
error.go:27
MethodcloseUnlocked
* - Close / CloseUnlocked must acquire *all* locks (read, write and C) before proceeding. Otherwise there is the danger that a concurent re
poller_select.go:399
FunctionfdIO
* - We use Level-Triggered notifications. We first attempt to read or write, and if we get EAGAIN, we add sysfd to the set of monitored filedescr
poller_select.go:312
Functioninit
()
poller_select.go:476
Functioninit
TODO(npat): Support systems that don't have EpollCreate1
poller_epoll.go:316
FunctionnewErr
(msg string)
error.go:43
FunctionnewFD
(sysfd int)
poller_select.go:258
FunctiontimerEvent
(sysfd int, write bool)
poller_select.go:428
FunctionuxSelect
(nfd int, r, w, e *fdSet, tv *syscall.Timeval)
select_linux.go:12