| /third_party/python/Lib/test/test_asyncio/ |
| D | test_sock_lowlevel.py | 86 self.loop.sock_recv(sock, 1024))
101 self.loop.sock_recv(sock, 1024))
104 self.loop.sock_recv(sock, 1024))
136 task = asyncio.create_task(self.loop.sock_recv(sock, 1024))
142 data = await self.loop.sock_recv(sock, 1024)
144 await self.loop.sock_recv(sock, 1024)
202 buf = await self.loop.sock_recv(server, 8192)
291 data = await self.loop.sock_recv(sock, DATA_SIZE)
296 data += await self.loop.sock_recv(sock, DATA_SIZE)
309 data = await self.loop.sock_recv(sock, DATA_SIZE)
|
| D | test_windows_events.py | 92 f = asyncio.ensure_future(self.loop.sock_recv(b, 100), loop=self.loop)
|
| D | test_events.py | 1486 data = self.loop.run_until_complete(self.loop.sock_recv(rsock, 1024))
1618 f = self.loop.create_task(self.loop.sock_recv(r, 1))
2523 await loop.sock_recv(f, 10)
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/drivers/ |
| D | driver_atheros.c | 69 struct l2_packet_data *sock_recv; /* raw packet recv socket */ member
1760 drv->sock_recv = l2_packet_init(params->bridge[0], NULL, in atheros_init()
1763 if (drv->sock_recv == NULL) in atheros_init()
1768 drv->sock_recv = l2_packet_init(brname, NULL, ETH_P_EAPOL, in atheros_init()
1770 if (drv->sock_recv == NULL) in atheros_init()
1773 drv->sock_recv = drv->sock_xmit; in atheros_init()
1805 if (drv->sock_recv != NULL && drv->sock_recv != drv->sock_xmit) in atheros_init()
1806 l2_packet_deinit(drv->sock_recv); in atheros_init()
1833 if (drv->sock_recv != NULL && drv->sock_recv != drv->sock_xmit) in atheros_deinit()
1834 l2_packet_deinit(drv->sock_recv); in atheros_deinit()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/drivers/ |
| D | driver_atheros.c | 73 struct l2_packet_data *sock_recv; /* raw packet recv socket */ member
1771 drv->sock_recv = l2_packet_init(params->bridge[0], NULL, in atheros_init()
1774 if (drv->sock_recv == NULL) in atheros_init()
1779 drv->sock_recv = l2_packet_init(brname, NULL, ETH_P_EAPOL, in atheros_init()
1781 if (drv->sock_recv == NULL) in atheros_init()
1784 drv->sock_recv = drv->sock_xmit; in atheros_init()
1816 if (drv->sock_recv != NULL && drv->sock_recv != drv->sock_xmit) in atheros_init()
1817 l2_packet_deinit(drv->sock_recv); in atheros_init()
1844 if (drv->sock_recv != NULL && drv->sock_recv != drv->sock_xmit) in atheros_deinit()
1845 l2_packet_deinit(drv->sock_recv); in atheros_deinit()
|
| /third_party/python/Lib/asyncio/ |
| D | events.py | 531 async def sock_recv(self, sock, nbytes): member in AbstractEventLoop
|
| D | proactor_events.py | 694 async def sock_recv(self, sock, n): member in BaseProactorEventLoop
|
| D | selector_events.py | 353 async def sock_recv(self, sock, n): member in BaseSelectorEventLoop
|
| /third_party/python/Doc/library/ |
| D | asyncio-llapi-index.rst | 186 * - ``await`` :meth:`loop.sock_recv`
|
| D | asyncio-eventloop.rst | 860 .. coroutinemethod:: loop.sock_recv(sock, nbytes)
|
| /third_party/python/Modules/ |
| D | socketmodule.c | 3434 struct sock_recv { struct
3444 struct sock_recv *ctx = data; in sock_recv_impl() argument
3469 struct sock_recv ctx; in sock_recv_guts()
3493 sock_recv(PySocketSockObject *s, PyObject *args) in sock_recv() function
4932 {"recv", (PyCFunction)sock_recv, METH_VARARGS,
|
| /third_party/python/Misc/NEWS.d/ |
| D | 3.7.0a4.rst | 427 Affected functions: loop.sock_sendall, loop.sock_recv, loop.sock_accept,
|
| /third_party/python/Doc/whatsnew/ |
| D | 3.7.rst | 2392 :meth:`loop.sock_recv() <asyncio.loop.sock_recv>`,
|