Searched refs:receive_future (Results 1 – 3 of 3) sorted by relevance
22 PyObject *receive_future; member97 http->receive_future = NULL; in nxt_py_asgi_http_create()153 http->receive_future = future; in nxt_py_asgi_http_receive()154 Py_INCREF(http->receive_future); in nxt_py_asgi_http_receive()472 if (http->receive_future == NULL) { in nxt_py_asgi_http_emit_disconnect()486 future = http->receive_future; in nxt_py_asgi_http_emit_disconnect()487 http->receive_future = NULL; in nxt_py_asgi_http_emit_disconnect()534 if (http->receive_future == NULL) { in nxt_py_asgi_http_data_handler()548 future = http->receive_future; in nxt_py_asgi_http_data_handler()549 http->receive_future = NULL; in nxt_py_asgi_http_data_handler()
38 PyObject *receive_future; member123 ws->receive_future = NULL; in nxt_py_asgi_websocket_create()195 ws->receive_future = future; in nxt_py_asgi_websocket_receive()196 Py_INCREF(ws->receive_future); in nxt_py_asgi_websocket_receive()576 if (ws->receive_future == NULL) { in nxt_py_asgi_websocket_handler()604 if (ws->receive_future == NULL) { in nxt_py_asgi_websocket_handler()632 future = ws->receive_future; in nxt_py_asgi_websocket_receive_done()633 ws->receive_future = NULL; in nxt_py_asgi_websocket_receive_done()653 future = ws->receive_future; in nxt_py_asgi_websocket_receive_fail()654 ws->receive_future = NULL; in nxt_py_asgi_websocket_receive_fail()[all …]
27 PyObject *receive_future; member165 lifespan->receive_future = NULL; in nxt_py_asgi_lifespan_target_startup()317 if (lifespan->receive_future != NULL) { in nxt_py_asgi_lifespan_target_shutdown()318 future = lifespan->receive_future; in nxt_py_asgi_lifespan_target_shutdown()319 lifespan->receive_future = NULL; in nxt_py_asgi_lifespan_target_shutdown()398 lifespan->receive_future = future; in nxt_py_asgi_lifespan_receive()