Home
last modified time | relevance | path

Searched refs:receive_future (Results 1 – 3 of 3) sorted by relevance

/unit/src/python/
H A Dnxt_python_asgi_http.c22 PyObject *receive_future; member
97 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()
H A Dnxt_python_asgi_websocket.c38 PyObject *receive_future; member
123 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 …]
H A Dnxt_python_asgi_lifespan.c27 PyObject *receive_future; member
165 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()