Home
last modified time | relevance | path

Searched refs:future (Results 1 – 8 of 8) sorted by relevance

/unit/src/python/
H A Dnxt_python_asgi_http.c43 PyObject *future, PyObject *msg);
153 http->receive_future = future; in nxt_py_asgi_http_receive()
158 return future; in nxt_py_asgi_http_receive()
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()
520 Py_DECREF(future); in nxt_py_asgi_http_set_result()
548 future = http->receive_future; in nxt_py_asgi_http_data_handler()
592 future = http->send_future; in nxt_py_asgi_http_drain()
612 future = http->send_future; in nxt_py_asgi_http_drain()
[all …]
H A Dnxt_python_asgi_lifespan.c42 int v, int *sent, PyObject **future);
372 Py_DECREF(future); in nxt_py_asgi_lifespan_target_shutdown()
415 if (nxt_slow_path(future == NULL)) { in nxt_py_asgi_lifespan_receive()
439 Py_INCREF(future); in nxt_py_asgi_lifespan_receive()
440 lifespan->receive_future = future; in nxt_py_asgi_lifespan_receive()
442 return future; in nxt_py_asgi_lifespan_receive()
535 PyObject *future, *res; in nxt_py_asgi_lifespan_send_() local
544 future = *pfuture; in nxt_py_asgi_lifespan_send_()
557 Py_DECREF(future); in nxt_py_asgi_lifespan_send_()
627 Py_DECREF(future); in nxt_py_asgi_lifespan_done()
[all …]
H A Dnxt_python_asgi_websocket.c139 PyObject *future, *msg; in nxt_py_asgi_websocket_receive() local
167 if (nxt_slow_path(future == NULL)) { 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()
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()
664 Py_DECREF(future); in nxt_py_asgi_websocket_receive_fail()
[all …]
H A Dnxt_python_asgi.h46 nxt_py_asgi_ctx_data_t *ctx_data, PyObject *future, PyObject *result);
H A Dnxt_python_asgi.c1350 nxt_py_asgi_ctx_data_t *ctx_data, PyObject *future, PyObject *result) in nxt_py_asgi_set_result_soon() argument
1355 Py_DECREF(future); in nxt_py_asgi_set_result_soon()
1360 set_result = PyObject_GetAttrString(future, "set_result"); in nxt_py_asgi_set_result_soon()
1364 Py_CLEAR(future); in nxt_py_asgi_set_result_soon()
1372 Py_CLEAR(future); in nxt_py_asgi_set_result_soon()
1383 Py_CLEAR(future); in nxt_py_asgi_set_result_soon()
1396 return future; in nxt_py_asgi_set_result_soon()
/unit/src/java/nginx/unit/websocket/
H A DAsyncChannelWrapperSecure.java86 ReadTask readTask = new ReadTask(dst, future); in read()
90 return future; in read()
97 WrapperFuture<Integer,B> future = in read() local
126 return future; in write()
134 WrapperFuture<Long,B> future = in write() local
174 private final WrapperFuture<Long,?> future; field in AsyncChannelWrapperSecure.WriteTask
177 WrapperFuture<Long,?> future) { in WriteTask() argument
179 this.future = future; in WriteTask()
240 future.fail(e); in run()
253 this.future = future; in ReadTask()
[all …]
/unit/test/python/delayed/
H A Dasgi.py28 future = loop.create_future()
29 loop.call_later(n, future.set_result, None)
30 await future
/unit/
H A DREADME.md184 GitHub sheds some light on our current work and plans for the future.