Lines Matching refs:msg

43     PyObject *future, PyObject *msg);
115 PyObject *msg, *future; in nxt_py_asgi_http_receive() local
126 msg = nxt_py_asgi_new_msg(req, nxt_py_http_disconnect_str); in nxt_py_asgi_http_receive()
129 msg = nxt_py_asgi_http_read_msg(http); in nxt_py_asgi_http_receive()
132 if (nxt_slow_path(msg == NULL)) { in nxt_py_asgi_http_receive()
143 Py_DECREF(msg); in nxt_py_asgi_http_receive()
149 if (msg != Py_None) { 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()
156 Py_DECREF(msg); in nxt_py_asgi_http_receive()
167 PyObject *msg, *body; in nxt_py_asgi_http_read_msg() local
207 msg = nxt_py_asgi_new_msg(req, nxt_py_http_request_str); in nxt_py_asgi_http_read_msg()
208 if (nxt_slow_path(msg == NULL)) { in nxt_py_asgi_http_read_msg()
226 SET_ITEM(msg, body, body) in nxt_py_asgi_http_read_msg()
230 SET_ITEM(msg, more_body, Py_True) in nxt_py_asgi_http_read_msg()
237 return msg; in nxt_py_asgi_http_read_msg()
246 Py_DECREF(msg); in nxt_py_asgi_http_read_msg()
477 PyObject *msg, *future; in nxt_py_asgi_http_emit_disconnect() local
483 msg = nxt_py_asgi_new_msg(http->req, nxt_py_http_disconnect_str); in nxt_py_asgi_http_emit_disconnect()
484 if (nxt_slow_path(msg == NULL)) { in nxt_py_asgi_http_emit_disconnect()
488 if (msg == Py_None) { in nxt_py_asgi_http_emit_disconnect()
489 Py_DECREF(msg); in nxt_py_asgi_http_emit_disconnect()
496 nxt_py_asgi_http_set_result(http, future, msg); in nxt_py_asgi_http_emit_disconnect()
498 Py_DECREF(msg); in nxt_py_asgi_http_emit_disconnect()
504 PyObject *msg) in nxt_py_asgi_http_set_result() argument
515 res = PyObject_CallMethodObjArgs(future, nxt_py_set_result_str, msg, in nxt_py_asgi_http_set_result()
534 PyObject *msg, *future; in nxt_py_asgi_http_data_handler() local
545 msg = nxt_py_asgi_http_read_msg(http); in nxt_py_asgi_http_data_handler()
546 if (nxt_slow_path(msg == NULL)) { in nxt_py_asgi_http_data_handler()
550 if (msg == Py_None) { in nxt_py_asgi_http_data_handler()
551 Py_DECREF(msg); in nxt_py_asgi_http_data_handler()
558 nxt_py_asgi_http_set_result(http, future, msg); in nxt_py_asgi_http_data_handler()
560 Py_DECREF(msg); in nxt_py_asgi_http_data_handler()