Lines Matching refs:future

69 static PyObject *nxt_py_asgi_websocket_done(PyObject *self, PyObject *future);
139 PyObject *future, *msg; in nxt_py_asgi_websocket_receive() local
166 future = PyObject_CallObject(ctx_data->loop_create_future, NULL); in nxt_py_asgi_websocket_receive()
167 if (nxt_slow_path(future == NULL)) { in nxt_py_asgi_websocket_receive()
180 return nxt_py_asgi_set_result_soon(ws->req, ctx_data, future, msg); in nxt_py_asgi_websocket_receive()
186 return nxt_py_asgi_set_result_soon(ws->req, ctx_data, future, msg); in nxt_py_asgi_websocket_receive()
192 return nxt_py_asgi_set_result_soon(ws->req, ctx_data, future, msg); in nxt_py_asgi_websocket_receive()
195 ws->receive_future = future; in nxt_py_asgi_websocket_receive()
198 return future; in nxt_py_asgi_websocket_receive()
630 PyObject *future, *res; in nxt_py_asgi_websocket_receive_done() local
632 future = ws->receive_future; in nxt_py_asgi_websocket_receive_done()
635 res = PyObject_CallMethodObjArgs(future, nxt_py_set_result_str, msg, NULL); in nxt_py_asgi_websocket_receive_done()
642 Py_DECREF(future); in nxt_py_asgi_websocket_receive_done()
651 PyObject *future, *res; in nxt_py_asgi_websocket_receive_fail() local
653 future = ws->receive_future; in nxt_py_asgi_websocket_receive_fail()
656 res = PyObject_CallMethodObjArgs(future, nxt_py_set_exception_str, exc, in nxt_py_asgi_websocket_receive_fail()
664 Py_DECREF(future); in nxt_py_asgi_websocket_receive_fail()
1043 nxt_py_asgi_websocket_done(PyObject *self, PyObject *future) in nxt_py_asgi_websocket_done() argument
1058 res = PyObject_CallMethodObjArgs(future, nxt_py_result_str, NULL); in nxt_py_asgi_websocket_done()