/dports/net/cvsync/cvsync-0.24.19/cvsyncd/ |
H A D | proto.c | 75 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 D | proto.c | 72 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 D | sock_recv.asm | 8 ; ZSock Lib function: sock_recv 11 PUBLIC sock_recv 19 .sock_recv 29 jr nc,sock_recv
|
H A D | zsock_list | 59 sock_recv
|
/dports/net/cvsync/cvsync-0.24.19/common/ |
H A D | receiver_raw.c | 58 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 D | receiver_zlib.c | 63 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 D | network.h | 60 bool sock_recv(int, void *, size_t);
|
H A D | receiver.c | 81 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 D | test_sock_lowlevel.py | 82 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 D | test_sock_lowlevel.py | 82 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 D | test_sock_lowlevel.py | 82 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 D | command.cpp | 70 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 D | sockfuncs.h | 49 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.py | 23 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 D | test_sock_lowlevel.py | 78 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 D | test_sock_lowlevel.py | 78 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 D | test_sock_lowlevel.py | 78 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 D | test_sock_lowlevel.py | 78 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 D | test_sock_lowlevel.py | 78 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 D | sock_tests.cpp | 157 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 D | sock_tests.cpp | 157 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 D | sock_tests.cpp | 157 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 D | test_sockets.py | 20 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 D | testsuite.erl | 133 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.py | 45 return await self._loop.sock_recv(self._socket, max_bytes) 50 packet = await self._loop.sock_recv(self._socket, n - len(data))
|