Lines Matching refs:future
43 PyObject *future, PyObject *msg);
44 static PyObject *nxt_py_asgi_http_done(PyObject *self, PyObject *future);
115 PyObject *msg, *future; in nxt_py_asgi_http_receive() local
138 future = PyObject_CallObject(ctx_data->loop_create_future, NULL); in nxt_py_asgi_http_receive()
139 if (nxt_slow_path(future == NULL)) { in nxt_py_asgi_http_receive()
150 return nxt_py_asgi_set_result_soon(req, ctx_data, future, msg); in nxt_py_asgi_http_receive()
153 http->receive_future = future; in nxt_py_asgi_http_receive()
158 return future; in nxt_py_asgi_http_receive()
361 PyObject *body, *more_body, *future; in nxt_py_asgi_http_response_body() local
414 future = PyObject_CallObject(ctx_data->loop_create_future, in nxt_py_asgi_http_response_body()
416 if (nxt_slow_path(future == NULL)) { in nxt_py_asgi_http_response_body()
431 http->send_future = future; in nxt_py_asgi_http_response_body()
434 return future; in nxt_py_asgi_http_response_body()
470 PyObject *msg, *future; in nxt_py_asgi_http_emit_disconnect() local
486 future = http->receive_future; in nxt_py_asgi_http_emit_disconnect()
489 nxt_py_asgi_http_set_result(http, future, msg); in nxt_py_asgi_http_emit_disconnect()
496 nxt_py_asgi_http_set_result(nxt_py_asgi_http_t *http, PyObject *future, in nxt_py_asgi_http_set_result() argument
501 res = PyObject_CallMethodObjArgs(future, nxt_py_done_str, NULL); in nxt_py_asgi_http_set_result()
508 res = PyObject_CallMethodObjArgs(future, nxt_py_set_result_str, msg, in nxt_py_asgi_http_set_result()
520 Py_DECREF(future); in nxt_py_asgi_http_set_result()
527 PyObject *msg, *future; in nxt_py_asgi_http_data_handler() local
548 future = http->receive_future; in nxt_py_asgi_http_data_handler()
551 nxt_py_asgi_http_set_result(http, future, msg); in nxt_py_asgi_http_data_handler()
562 PyObject *future, *exc, *res; in nxt_py_asgi_http_drain() local
592 future = http->send_future; in nxt_py_asgi_http_drain()
595 nxt_py_asgi_http_set_result(http, future, Py_None); in nxt_py_asgi_http_drain()
612 future = http->send_future; in nxt_py_asgi_http_drain()
615 res = PyObject_CallMethodObjArgs(future, nxt_py_set_exception_str, exc, in nxt_py_asgi_http_drain()
623 Py_DECREF(future); in nxt_py_asgi_http_drain()
648 nxt_py_asgi_http_done(PyObject *self, PyObject *future) in nxt_py_asgi_http_done() argument
662 res = PyObject_CallMethodObjArgs(future, nxt_py_result_str, NULL); in nxt_py_asgi_http_done()