| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/_assets/patches/ |
| H A D | 0028-p2p-watchdog.patch | 50 - go p.readLoop(readErr)
53 + go p.readLoop(readErr, reads)
62 -func (p *Peer) readLoop(errc chan<- error) {
80 +func (p *Peer) readLoop(errc chan<- error, reads chan<- struct{}) {
84 @@ -261,6 +290,7 @@ func (p *Peer) readLoop(errc chan<- error) {
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/pion/dtls/v2/internal/udp/ |
| H A D | conn.go | 100 go l.readLoop()
109 func (l *Listener) readLoop() { func
112 readLoop:
127 continue readLoop
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/pion/quic/ |
| H A D | transport_test.go | 55 go readLoop(stream) // Read to pull incoming messages
72 go readLoop(stream) // Read to pull incoming messages
100 func readLoop(s *BidirectionalStream) { func
|
| /dports/devel/capnproto080/capnproto-0.8.0/c++/src/capnp/compat/ |
| H A D | json-rpc.c++ | 108 readTask(readLoop().eagerlyEvaluate([this](kj::Exception&& e) { in JsonRpc()
167 kj::Promise<void> JsonRpc::readLoop() { in readLoop() function in capnp::JsonRpc
176 return readLoop(); in readLoop()
185 return readLoop(); in readLoop()
189 return readLoop(); in readLoop()
311 return readLoop(); in readLoop()
|
| /dports/devel/capnproto/capnproto-0.9.0/c++/src/capnp/compat/ |
| H A D | json-rpc.c++ | 108 readTask(readLoop().eagerlyEvaluate([this](kj::Exception&& e) { in JsonRpc()
167 kj::Promise<void> JsonRpc::readLoop() { in readLoop() function in capnp::JsonRpc
176 return readLoop(); in readLoop()
185 return readLoop(); in readLoop()
189 return readLoop(); in readLoop()
311 return readLoop(); in readLoop()
|
| /dports/net/traefik/traefik-2.6.1/pkg/udp/ |
| H A D | conn.go | 54 go l.readLoop()
134 func (l *Listener) readLoop() { func
175 go conn.readLoop()
214 func (c *Conn) readLoop() { func
|
| /dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/pion/turn/v2/ |
| H A D | server.go | 74 s.readLoop(p.PacketConn, allocationManager)
102 go s.readLoop(NewSTUNConn(conn), allocationManager)
138 func (s *Server) readLoop(p net.PacketConn, allocationManager *allocation.Manager) { func
|
| /dports/dns/nextdns/nextdns-1.32.2/ctl/ |
| H A D | client.go | 24 go cl.readLoop()
28 func (c *Client) readLoop() { func
|
| /dports/graphics/opencv/opencv-4.5.3/contrib/modules/cudacodec/src/ |
| H A D | video_source.cpp | 72 thread_.reset(new Thread(readLoop, this)); in start()
92 void cv::cudacodec::detail::RawVideoSourceWrapper::readLoop(void* userData) in readLoop() function in cv::cudacodec::detail::RawVideoSourceWrapper
|
| /dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/pion/dtls/v2/examples/util/ |
| H A D | hub.go | 31 go h.readLoop(conn)
34 func (h *Hub) readLoop(conn net.Conn) { func
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/pion/dtls/v2/examples/util/ |
| H A D | hub.go | 31 go h.readLoop(conn)
34 func (h *Hub) readLoop(conn net.Conn) { func
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/les/vflux/client/ |
| H A D | fillset.go | 64 go fs.readLoop()
70 func (fs *FillSet) readLoop() { func
|
| /dports/www/gitea/gitea-1.16.5/modules/git/ |
| H A D | commit_reader.go | 36 readLoop:
45 break readLoop
|
| /dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/pion/webrtc/v3/internal/mux/ |
| H A D | mux.go | 44 go m.readLoop()
99 func (m *Mux) readLoop() { func
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/pion/webrtc/v2/internal/mux/ |
| H A D | mux.go | 43 go m.readLoop()
98 func (m *Mux) readLoop() { func
|
| /dports/finance/hs-hledger-ui/hledger-ui-1.19/_cabal_deps/vty-5.33/test/ |
| H A D | VerifyUsingMockInput.hs | 130 let readEvents = readLoop eventCount
131 readLoop 0 = return () function
132 readLoop n = do function
135 readLoop (n - 1)
|
| /dports/devel/hs-git-brunch/git-brunch-1.5.1.0/_cabal_deps/vty-5.33/test/ |
| H A D | VerifyUsingMockInput.hs | 130 let readEvents = readLoop eventCount
131 readLoop 0 = return () function
132 readLoop n = do function
135 readLoop (n - 1)
|
| /dports/net-im/matterhorn/matterhorn-50200.13.0/_cabal_deps/vty-5.32/test/ |
| H A D | VerifyUsingMockInput.hs | 130 let readEvents = readLoop eventCount
131 readLoop 0 = return () function
132 readLoop n = do function
135 readLoop (n - 1)
|
| /dports/misc/hs-hascard/hascard-0.3.0.1/_cabal_deps/vty-5.30/test/ |
| H A D | VerifyUsingMockInput.hs | 130 let readEvents = readLoop eventCount
131 readLoop 0 = return () function
132 readLoop n = do function
135 readLoop (n - 1)
|
| /dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/common/websocketconn/ |
| H A D | websocketconn.go | 44 func readLoop(w io.Writer, ws *websocket.Conn) error { func
109 pw1.CloseWithError(closeErrorToEOF(readLoop(pw1, ws)))
|
| /dports/games/tads/tads-3.0.8/tads3/test/data/ |
| H A D | timeout.t | 33 readLoop:
54 break readLoop;
|
| /dports/java/netty/netty-4.1.53.Final/io/netty/channel/kqueue/ |
| H A D | KQueueDomainSocketChannel.java | 154 readLoop: do { in readReadyFd()
162 break readLoop; in readReadyFd() local
|
| /dports/devel/taskctl/taskctl-1.4.2/vendor/github.com/chzyer/readline/ |
| H A D | remote.go | 73 go rs.readLoop(buf)
200 func (r *RemoteSvr) readLoop(buf *bufio.Reader) { func
377 func (r *RemoteCli) readLoop() { func
410 r.readLoop()
|
| /dports/net/evans/evans-0.9.1/vendor/github.com/chzyer/readline/ |
| H A D | remote.go | 73 go rs.readLoop(buf)
200 func (r *RemoteSvr) readLoop(buf *bufio.Reader) { func
377 func (r *RemoteCli) readLoop() { func
410 r.readLoop()
|
| /dports/deskutils/pet/pet-0.4.0/vendor/github.com/chzyer/readline/ |
| H A D | remote.go | 73 go rs.readLoop(buf)
200 func (r *RemoteSvr) readLoop(buf *bufio.Reader) { func
377 func (r *RemoteCli) readLoop() { func
410 r.readLoop()
|