| /unit/src/python/ |
| H A D | nxt_python_asgi_lifespan.c | 137 PyObject *scope, *res, *py_task, *receive, *send, *done; in nxt_py_asgi_lifespan_target_startup() local
155 receive = PyObject_GetAttrString((PyObject *) lifespan, "receive"); in nxt_py_asgi_lifespan_target_startup()
156 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_lifespan_target_startup()
162 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_lifespan_target_startup()
168 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_lifespan_target_startup()
218 scope, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup()
248 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_lifespan_target_startup()
313 Py_DECREF(receive); in nxt_py_asgi_lifespan_target_startup()
|
| H A D | nxt_python_asgi.c | 452 PyObject *scope, *res, *task, *receive, *send, *done, *asgi; in nxt_py_asgi_request_handler() local
472 receive = PyObject_GetAttrString(asgi, "receive"); in nxt_py_asgi_request_handler()
473 if (nxt_slow_path(receive == NULL)) { in nxt_py_asgi_request_handler()
536 scope, receive, send, NULL); in nxt_py_asgi_request_handler()
563 res = PyObject_CallFunctionObjArgs(stage2, receive, send, NULL); in nxt_py_asgi_request_handler()
620 Py_DECREF(receive); in nxt_py_asgi_request_handler()
|
| /unit/test/python/lifespan/empty/ |
| H A D | asgi.py | 4 async def handler(prefix, scope, receive, send): argument
11 message = await receive()
32 async def application(scope, receive, send): argument
33 return await handler('', scope, receive, send)
36 async def application2(scope, receive, send): argument
37 return await handler('app2_', scope, receive, send)
|
| /unit/test/python/threading/ |
| H A D | asgi.py | 27 async def application(scope, receive, send): argument
|
| /unit/test/python/prefix/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
|
| /unit/test/python/targets/ |
| H A D | asgi.py | 1 async def application_201(scope, receive, send): argument
13 async def application_200(scope, receive, send): argument
25 async def application_prefix(scope, receive, send): argument
48 async def legacy_app_http_200(receive, send): argument
58 def legacy_application_201(scope, receive=None, send=None): argument
64 async def legacy_app_http_201(receive, send): argument
|
| /unit/test/python/204_no_content/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
|
| /unit/test/python/threads/ |
| H A D | asgi.py | 5 async def application(scope, receive, send): argument
|
| /unit/test/python/websockets/mirror/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
4 m = await receive()
|
| /unit/test/python/websockets/subprotocol/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
5 m = await receive()
|
| /unit/test/python/variables/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
6 m = await receive()
|
| /unit/test/python/query_string/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
|
| /unit/test/python/server_port/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
|
| /unit/test/python/legacy_force/ |
| H A D | asgi.py | 1 def application(scope, receive=None, send=None): argument
4 if receive == None and send == None:
8 return app_http(receive, send)
11 async def app_http(receive, send): argument
|
| /unit/test/python/mirror/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
6 m = await receive()
|
| /unit/test/python/legacy/ |
| H A D | asgi.py | 7 async def app_http(receive, send): argument
|
| /unit/test/python/delayed/ |
| H A D | asgi.py | 4 async def application(scope, receive, send): argument
9 m = await receive()
|
| /unit/test/python/empty/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
|
| /unit/test/python/lifespan/failed/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
4 message = await receive()
|
| /unit/test/python/lifespan/error/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
|
| /unit/test/python/lifespan/error_auto/ |
| H A D | asgi.py | 1 async def application(scope, receive, send): argument
|