Home
last modified time | relevance | path

Searched refs:sock_recv (Results 1 – 25 of 524) sorted by relevance

12345678910>>...21

/dports/net/cvsync/cvsync-0.24.19/cvsyncd/
H A Dproto.c75 if (!sock_recv(sock, cmd, 2)) in protocol_exchange()
79 if (!sock_recv(sock, cmd, len)) in protocol_exchange()
99 if (!sock_recv(sock, cmd, 2)) in protocol_exchange()
103 if (!sock_recv(sock, cmd, len)) in protocol_exchange()
183 if (!sock_recv(sock, cmd, 2)) in hash_exchange()
188 if (!sock_recv(sock, name, len)) in hash_exchange()
373 if (!sock_recv(sock, cmd, 2)) in collection_fetch()
379 if (!sock_recv(sock, cmd, 2)) in collection_fetch()
481 if (!sock_recv(sock, cmd, 2)) in compress_exchange()
486 if (!sock_recv(sock, cmd, len)) in compress_exchange()
[all …]
/dports/net/cvsync/cvsync-0.24.19/cvsync/
H A Dproto.c72 if (!sock_recv(sock, cmd, 2)) { in protocol_exchange()
80 if (!sock_recv(sock, cmd, len)) { in protocol_exchange()
171 if (!sock_recv(sock, cmd, 2)) { in hash_exchange()
232 if (!sock_recv(sock, cmd, 2)) in collectionlist_exchange()
236 if (!sock_recv(sock, cmd, len)) in collectionlist_exchange()
277 if (!sock_recv(sock, cmd, 2)) in collection_exchange_list()
290 if (!sock_recv(sock, cmd, len)) in collection_exchange_list()
336 if (!sock_recv(sock, cmd, 2)) in collection_exchange_rcs()
350 if (!sock_recv(sock, cmd, len)) in collection_exchange_rcs()
405 if (!sock_recv(sock, cmd, 2)) in compress_exchange()
[all …]
/dports/devel/z88dk/z88dk/libsrc/target/z88/net/
H A Dsock_recv.asm8 ; ZSock Lib function: sock_recv
11 PUBLIC sock_recv
19 .sock_recv
29 jr nc,sock_recv
H A Dzsock_list59 sock_recv
/dports/net/cvsync/cvsync-0.24.19/common/
H A Dreceiver_raw.c58 if (!sock_recv(mx->mx_socket, cmd, MUX_CMDLEN_DATA - 2)) { in receiver_data_raw()
111 if (!sock_recv(mx->mx_socket, &mxb->mxb_buffer[tail], len1)) { in receiver_data_raw()
118 if (!sock_recv(mx->mx_socket, mxb->mxb_buffer, len2)) { in receiver_data_raw()
H A Dreceiver_zlib.c63 if (!sock_recv(mx->mx_socket, cmd, MUX_CMDLEN_DATA - 2)) { in receiver_data_zlib()
74 if (!sock_recv(mx->mx_socket, stream->ms_zbuffer_in, (size_t)mss)) { in receiver_data_zlib()
H A Dnetwork.h60 bool sock_recv(int, void *, size_t);
H A Dreceiver.c81 if (!sock_recv(mx->mx_socket, cmd, 2)) { in receiver()
237 if (!sock_recv(mx->mx_socket, cmd, MUX_CMDLEN_RESET - 2)) { in receiver_reset()
/dports/lang/python310/Python-3.10.1/Lib/test/test_asyncio/
H A Dtest_sock_lowlevel.py82 self.loop.sock_recv(sock, 1024))
97 self.loop.sock_recv(sock, 1024))
100 self.loop.sock_recv(sock, 1024))
132 task = asyncio.create_task(self.loop.sock_recv(sock, 1024))
138 data = await self.loop.sock_recv(sock, 1024)
140 await self.loop.sock_recv(sock, 1024)
198 buf = await self.loop.sock_recv(server, 8192)
287 data = await self.loop.sock_recv(sock, DATA_SIZE)
292 data += await self.loop.sock_recv(sock, DATA_SIZE)
305 data = await self.loop.sock_recv(sock, DATA_SIZE)
/dports/lang/python311/Python-3.11.0a3/Lib/test/test_asyncio/
H A Dtest_sock_lowlevel.py82 self.loop.sock_recv(sock, 1024))
97 self.loop.sock_recv(sock, 1024))
100 self.loop.sock_recv(sock, 1024))
132 task = asyncio.create_task(self.loop.sock_recv(sock, 1024))
138 data = await self.loop.sock_recv(sock, 1024)
140 await self.loop.sock_recv(sock, 1024)
198 buf = await self.loop.sock_recv(server, 8192)
287 data = await self.loop.sock_recv(sock, DATA_SIZE)
292 data += await self.loop.sock_recv(sock, DATA_SIZE)
305 data = await self.loop.sock_recv(sock, DATA_SIZE)
/dports/lang/python39/Python-3.9.9/Lib/test/test_asyncio/
H A Dtest_sock_lowlevel.py82 self.loop.sock_recv(sock, 1024))
97 self.loop.sock_recv(sock, 1024))
100 self.loop.sock_recv(sock, 1024))
132 task = asyncio.create_task(self.loop.sock_recv(sock, 1024))
138 data = await self.loop.sock_recv(sock, 1024)
140 await self.loop.sock_recv(sock, 1024)
198 buf = await self.loop.sock_recv(server, 8192)
287 data = await self.loop.sock_recv(sock, DATA_SIZE)
292 data += await self.loop.sock_recv(sock, DATA_SIZE)
305 data = await self.loop.sock_recv(sock, DATA_SIZE)
/dports/multimedia/butt/butt-0.1.27/src/
H A Dcommand.cpp70 bytes_count = sock_recv(conn_sock, recv_buf, sizeof(recv_buf), COMMAND_TIMEOUT); in listen_thread_func()
78 … bytes_count += sock_recv(conn_sock, recv_buf+bytes_count, remaining_bytes, COMMAND_TIMEOUT); in listen_thread_func()
172 return sock_recv(client_sock, (char*)status, sizeof(uint32_t), COMMAND_TIMEOUT); in command_recv_status_reply()
H A Dsockfuncs.h49 int sock_recv(int s, char *buf, int len, int timout_ms);
/dports/net/py-python-socks/python-socks-2.0.1/python_socks/async_/asyncio/
H A D_stream.py23 return await self._loop.sock_recv(self._socket, max_bytes)
28 packet = await self._loop.sock_recv(self._socket, n - len(data))
/dports/databases/py-sqlite3/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_sock_lowlevel.py78 self.loop.sock_recv(sock, 1024))
93 self.loop.sock_recv(sock, 1024))
96 self.loop.sock_recv(sock, 1024))
139 data = await self.loop.sock_recv(sock, DATA_SIZE)
144 data += await self.loop.sock_recv(sock, DATA_SIZE)
157 data = await self.loop.sock_recv(sock, DATA_SIZE)
/dports/databases/py-gdbm/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_sock_lowlevel.py78 self.loop.sock_recv(sock, 1024))
93 self.loop.sock_recv(sock, 1024))
96 self.loop.sock_recv(sock, 1024))
139 data = await self.loop.sock_recv(sock, DATA_SIZE)
144 data += await self.loop.sock_recv(sock, DATA_SIZE)
157 data = await self.loop.sock_recv(sock, DATA_SIZE)
/dports/lang/python-tools/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_sock_lowlevel.py78 self.loop.sock_recv(sock, 1024))
93 self.loop.sock_recv(sock, 1024))
96 self.loop.sock_recv(sock, 1024))
139 data = await self.loop.sock_recv(sock, DATA_SIZE)
144 data += await self.loop.sock_recv(sock, DATA_SIZE)
157 data = await self.loop.sock_recv(sock, DATA_SIZE)
/dports/lang/python38/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_sock_lowlevel.py78 self.loop.sock_recv(sock, 1024))
93 self.loop.sock_recv(sock, 1024))
96 self.loop.sock_recv(sock, 1024))
139 data = await self.loop.sock_recv(sock, DATA_SIZE)
144 data += await self.loop.sock_recv(sock, DATA_SIZE)
157 data = await self.loop.sock_recv(sock, DATA_SIZE)
/dports/x11-toolkits/py-tkinter/Python-3.8.12/Lib/test/test_asyncio/
H A Dtest_sock_lowlevel.py78 self.loop.sock_recv(sock, 1024))
93 self.loop.sock_recv(sock, 1024))
96 self.loop.sock_recv(sock, 1024))
139 data = await self.loop.sock_recv(sock, DATA_SIZE)
144 data += await self.loop.sock_recv(sock, DATA_SIZE)
157 data = await self.loop.sock_recv(sock, DATA_SIZE)
/dports/net-p2p/bitcoin-utils/bitcoin-22.0/src/test/
H A Dsock_tests.cpp157 Sock sock_recv(s[1]); in BOOST_AUTO_TEST_CASE() local
159 std::thread receiver([&sock_recv, &timeout, &interrupt]() { in BOOST_AUTO_TEST_CASE()
165 (void)sock_recv.RecvUntilTerminator('\n', timeout, interrupt, max_data); in BOOST_AUTO_TEST_CASE()
/dports/net-p2p/bitcoin/bitcoin-22.0/src/test/
H A Dsock_tests.cpp157 Sock sock_recv(s[1]); in BOOST_AUTO_TEST_CASE() local
159 std::thread receiver([&sock_recv, &timeout, &interrupt]() { in BOOST_AUTO_TEST_CASE()
165 (void)sock_recv.RecvUntilTerminator('\n', timeout, interrupt, max_data); in BOOST_AUTO_TEST_CASE()
/dports/net-p2p/bitcoin-daemon/bitcoin-22.0/src/test/
H A Dsock_tests.cpp157 Sock sock_recv(s[1]); in BOOST_AUTO_TEST_CASE() local
159 std::thread receiver([&sock_recv, &timeout, &interrupt]() { in BOOST_AUTO_TEST_CASE()
165 (void)sock_recv.RecvUntilTerminator('\n', timeout, interrupt, max_data); in BOOST_AUTO_TEST_CASE()
/dports/devel/py-uvloop/uvloop-0.16.0/tests/
H A Dtest_sockets.py20 buf += await self.loop.sock_recv(sock, nbytes - len(buf))
142 self.loop.sock_recv(sock, 0))
223 self.loop.sock_recv(sock_client, 1)
242 data = await self.loop.sock_recv(sock_client, 1)
278 self.loop.sock_recv(sock_client, 1)
291 data = await self.loop.sock_recv(sock_client, 1)
474 f = asyncio.ensure_future(self.loop.sock_recv(sock, 10),
543 return await self.loop.sock_recv(s2, 2)
565 asyncio.ensure_future(self.loop.sock_recv(sock, 10),
641 f = asyncio.ensure_future(self.loop.sock_recv(sock, 10),
[all …]
/dports/www/yaws/yaws-2.0.6/testsuite/
H A Dtestsuite.erl133 sock_recv(Sock, Length) -> function
135 undefined -> sock_recv(Sock, Length, infinity);
144 sock_recv(Sock, Length, Time)
149 sock_recv(Sock, Length, Tout) -> ssl:recv(Sock, Length, Tout). function
164 sock_recv(Sock, Length).
221 case sock_recv(Sock, 0) of
244 case sock_recv(Sock, 0) of
258 case sock_recv(Sock, 0) of
264 case sock_recv(Sock, 0) of
274 case sock_recv(Sock, 0) of
[all …]
/dports/finance/electrum/Electrum-4.1.5/packages/python_socks/
H A D_stream_async_aio.py45 return await self._loop.sock_recv(self._socket, max_bytes)
50 packet = await self._loop.sock_recv(self._socket, n - len(data))

12345678910>>...21