Home
last modified time | relevance | path

Searched refs:NXT_UNIT_OK (Results 1 – 25 of 28) sorted by relevance

12

/unit/src/test/
H A Dnxt_unit_websocket_chat.c51 int rc = NXT_UNIT_OK; in ws_chat_request_handler()
70 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in ws_chat_request_handler()
112 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in ws_chat_root()
119 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in ws_chat_root()
127 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in ws_chat_root()
133 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in ws_chat_root()
197 nxt_unit_request_done(req, NXT_UNIT_OK); in ws_chat_close_handler()
H A Dnxt_unit_websocket_echo.c22 rc = NXT_UNIT_OK; in ws_echo_request_handler()
31 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in ws_echo_request_handler()
80 nxt_unit_request_done(req, NXT_UNIT_OK); in ws_echo_websocket_handler()
H A Dnxt_unit_app_test.c101 return NXT_UNIT_OK; in ready_handler()
116 return NXT_UNIT_OK; in ready_handler()
159 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in greeting_app_request_handler()
166 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in greeting_app_request_handler()
172 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in greeting_app_request_handler()
177 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in greeting_app_request_handler()
/unit/src/java/
H A Dnxt_jni_OutputStream.c76 return NXT_UNIT_OK; in nxt_java_initOutputStream()
114 if (rc != NXT_UNIT_OK) { in nxt_java_OutputStream_flush_buf()
123 if (rc != NXT_UNIT_OK) { in nxt_java_OutputStream_flush_buf()
132 if (rc != NXT_UNIT_OK) { in nxt_java_OutputStream_flush_buf()
140 rc = NXT_UNIT_OK; in nxt_java_OutputStream_flush_buf()
207 if (rc != NXT_UNIT_OK) { in nxt_java_OutputStream_write()
H A Dnxt_jni_Response.c248 return NXT_UNIT_OK; in nxt_java_initResponse()
293 if (rc != NXT_UNIT_OK) { in nxt_java_Response_addHeader()
326 if (rc != NXT_UNIT_OK) { in nxt_java_get_response_info()
348 if (rc != NXT_UNIT_OK) { in nxt_java_get_response_info()
654 if (rc != NXT_UNIT_OK) { in nxt_java_Response_sendRedirect()
709 return NXT_UNIT_OK; in nxt_java_response_set_header()
752 if (rc != NXT_UNIT_OK) { in nxt_java_Response_setHeader()
780 if (rc != NXT_UNIT_OK) { in nxt_java_Response_removeHeader()
817 return NXT_UNIT_OK; in nxt_java_response_remove_header()
843 if (rc != NXT_UNIT_OK) { in nxt_java_Response_setIntHeader()
[all …]
H A Dnxt_jni_Thread.c56 return NXT_UNIT_OK; in nxt_java_initThread()
H A Dnxt_jni_HeaderNamesEnumeration.c72 return NXT_UNIT_OK; in nxt_java_initHeaderNamesEnumeration()
H A Dnxt_jni_HeadersEnumeration.c72 return NXT_UNIT_OK; in nxt_java_initHeadersEnumeration()
H A Dnxt_jni.c81 return NXT_UNIT_OK; in nxt_java_jni_init()
H A Dnxt_jni_Context.c86 return NXT_UNIT_OK; in nxt_java_initContext()
H A Dnxt_jni_Request.c245 if (res != NXT_UNIT_OK) { in nxt_java_initRequest()
250 if (res != NXT_UNIT_OK) { in nxt_java_initRequest()
254 return NXT_UNIT_OK; in nxt_java_initRequest()
807 nxt_unit_request_done(req, NXT_UNIT_OK); in nxt_java_Request_closeWs()
/unit/src/perl/
H A Dnxt_perl_psgi.c469 return NXT_UNIT_OK; in nxt_perl_psgi_io_init()
573 return NXT_UNIT_OK; in nxt_perl_psgi_ctx_init()
736 return NXT_UNIT_OK; in nxt_perl_psgi_add_str()
751 return NXT_UNIT_OK; in nxt_perl_psgi_add_value()
852 return NXT_UNIT_OK; in nxt_perl_psgi_result_head()
903 return NXT_UNIT_OK; in nxt_perl_psgi_result_body()
929 rc = NXT_UNIT_OK; in nxt_perl_psgi_result_body_ref()
986 return NXT_UNIT_OK; in nxt_perl_psgi_result_body_fh()
1069 return NXT_UNIT_OK; in nxt_perl_psgi_result_array()
1295 return NXT_UNIT_OK; in nxt_perl_psgi_ready_handler()
[all …]
/unit/src/
H A Dnxt_java.c346 if (rc != NXT_UNIT_OK) { in nxt_java_start()
352 if (rc != NXT_UNIT_OK) { in nxt_java_start()
374 if (rc != NXT_UNIT_OK) { in nxt_java_start()
380 if (rc != NXT_UNIT_OK) { in nxt_java_start()
386 if (rc != NXT_UNIT_OK) { in nxt_java_start()
392 if (rc != NXT_UNIT_OK) { in nxt_java_start()
398 if (rc != NXT_UNIT_OK) { in nxt_java_start()
622 return NXT_UNIT_OK; in nxt_java_ready_handler()
640 return NXT_UNIT_OK; in nxt_java_ready_handler()
694 return NXT_UNIT_OK; in nxt_java_init_threads()
[all …]
H A Dnxt_unit.c707 return NXT_UNIT_OK; in nxt_unit_ctx_init()
923 return NXT_UNIT_OK; in nxt_unit_read_env()
954 return NXT_UNIT_OK; in nxt_unit_ready()
1225 return NXT_UNIT_OK; in nxt_unit_process_new_port()
1265 return NXT_UNIT_OK; in nxt_unit_ctx_ready()
1395 return NXT_UNIT_OK; in nxt_unit_process_req_headers()
2721 rc = NXT_UNIT_OK; in nxt_unit_mmap_buf_send()
4528 rc = NXT_UNIT_OK; in nxt_unit_run()
4746 rc = NXT_UNIT_OK; in nxt_unit_process_pending_rbuf()
4846 rc = NXT_UNIT_OK; in nxt_unit_run_ctx()
[all …]
H A Dnxt_php_sapi.c258 nxt_unit_request_done(ctx->req, NXT_UNIT_OK); in PHP_FUNCTION()
1131 nxt_unit_request_done(ctx->req, NXT_UNIT_OK);
1171 if (nxt_fast_path(rc == NXT_UNIT_OK)) {
1199 if (nxt_slow_path(rc != NXT_UNIT_OK)) {
1219 if (nxt_slow_path(rc != NXT_UNIT_OK)) {
1245 if (nxt_slow_path(rc != NXT_UNIT_OK)) {
/unit/src/python/
H A Dnxt_python_wsgi.c184 != NXT_UNIT_OK)) in nxt_python_wsgi_init()
202 return NXT_UNIT_OK; in nxt_python_wsgi_init()
249 return NXT_UNIT_OK; in nxt_python_wsgi_ctx_data_alloc()
372 rc = NXT_UNIT_OK; in nxt_python_request_handler()
721 return NXT_UNIT_OK; in nxt_python_add_sptr()
766 return NXT_UNIT_OK; in nxt_python_add_field()
862 return NXT_UNIT_OK; in nxt_python_add_obj()
946 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_start_resp()
969 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_start_resp()
1078 return NXT_UNIT_OK; in nxt_python_str_buf()
[all …]
H A Dnxt_python.c267 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_python_start()
277 if (nxt_py_proto.startup(python_init.ctx_data) != NXT_UNIT_OK) { in nxt_python_start()
461 return NXT_UNIT_OK; in nxt_python_init_threads()
498 if (nxt_slow_path(res != NXT_UNIT_OK)) { in nxt_python_init_threads()
503 return NXT_UNIT_OK; in nxt_python_init_threads()
518 return NXT_UNIT_OK; in nxt_python_ready_handler()
538 return NXT_UNIT_OK; in nxt_python_ready_handler()
557 if (nxt_py_proto.startup(ti->ctx_data) != NXT_UNIT_OK) { in nxt_python_thread_func()
647 return NXT_UNIT_OK; in nxt_python_init_strings()
H A Dnxt_python_asgi_websocket.c110 return NXT_UNIT_OK; in nxt_py_asgi_websocket_init()
318 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_websocket_accept()
339 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_websocket_accept()
346 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_websocket_accept()
389 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_websocket_close()
396 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_websocket_close()
402 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_websocket_close()
479 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_websocket_send_frame()
1069 rc = NXT_UNIT_OK; in nxt_py_asgi_websocket_done()
1073 status_code = (rc == NXT_UNIT_OK) in nxt_py_asgi_websocket_done()
H A Dnxt_python_asgi_lifespan.c104 return NXT_UNIT_OK; in nxt_py_asgi_lifespan_startup()
292 if (nxt_slow_path(ret != NXT_UNIT_OK)) { in nxt_py_asgi_lifespan_shutdown()
299 return NXT_UNIT_OK; in nxt_py_asgi_lifespan_shutdown()
312 return NXT_UNIT_OK; in nxt_py_asgi_lifespan_target_shutdown()
334 return NXT_UNIT_OK; in nxt_py_asgi_lifespan_target_shutdown()
356 return NXT_UNIT_OK; in nxt_py_asgi_lifespan_target_shutdown()
H A Dnxt_python_asgi_http.c84 return NXT_UNIT_OK; in nxt_py_asgi_http_init()
330 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_http_response_start()
449 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_http_response_body()
597 return NXT_UNIT_OK; in nxt_py_asgi_http_drain()
673 rc = NXT_UNIT_OK; in nxt_py_asgi_http_done()
H A Dnxt_python_asgi.c146 if (nxt_slow_path(nxt_py_asgi_str_init() != NXT_UNIT_OK)) { in nxt_python_asgi_init()
197 return NXT_UNIT_OK; in nxt_python_asgi_init()
310 return NXT_UNIT_OK; in nxt_python_asgi_ctx_data_alloc()
371 return NXT_UNIT_OK; in nxt_python_asgi_run()
897 return NXT_UNIT_OK; in nxt_py_asgi_add_port()
962 rc = NXT_UNIT_OK; in nxt_py_asgi_add_reader()
1091 if (rc == NXT_UNIT_OK) { in nxt_py_asgi_port_read()
1215 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_add_field()
/unit/src/ruby/
H A Dnxt_ruby.c180 return NXT_UNIT_OK; in nxt_ruby_init_strings()
586 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_ruby_rack_env_create()
652 return NXT_UNIT_OK; in nxt_ruby_init_io()
815 return NXT_UNIT_OK; in nxt_ruby_read_request()
879 rc = NXT_UNIT_OK; in nxt_ruby_rack_result_headers()
881 headers_info.rc = NXT_UNIT_OK; in nxt_ruby_rack_result_headers()
1056 return NXT_UNIT_OK; in nxt_ruby_rack_result_body()
1299 return NXT_UNIT_OK; in nxt_ruby_ready_handler()
1321 return NXT_UNIT_OK; in nxt_ruby_ready_handler()
1403 return NXT_UNIT_OK; in nxt_ruby_init_threads()
[all …]
/unit/go/
H A Dport.go113 return C.NXT_UNIT_OK
122 return C.NXT_UNIT_OK
H A Drequest.go123 C.nxt_unit_request_done(c_req, C.NXT_UNIT_OK)
/unit/src/nodejs/unit-http/
H A Dunit.cpp64 if (rc != NXT_UNIT_OK) { in process_port_msg()
432 nxt_unit_request_done(req, NXT_UNIT_OK); in close_handler()
517 return NXT_UNIT_OK; in add_port()
817 if (ret != NXT_UNIT_OK) { in response_send_headers()
918 if (ret != NXT_UNIT_OK) { in response_send_headers()
977 if (ret == NXT_UNIT_OK) { in response_write()
991 ret = res_len < 0 ? -res_len : (int) NXT_UNIT_OK; in response_write()
994 if (ret != NXT_UNIT_OK) { in response_write()
1031 nxt_unit_request_done(req, NXT_UNIT_OK); in response_end()
1097 if (ret != NXT_UNIT_OK) { in websocket_send_frame()

12