/unit/src/test/ |
H A D | nxt_unit_websocket_chat.c | 51 int rc = NXT_UNIT_OK; in ws_chat_request_handler() local 60 rc = ws_chat_root(req); in ws_chat_request_handler() 96 nxt_unit_request_done(req, rc); in ws_chat_request_handler() 103 int rc; in ws_chat_root() local 112 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in ws_chat_root() 113 return rc; in ws_chat_root() 116 rc = nxt_unit_response_add_field(req, in ws_chat_root() 120 return rc; in ws_chat_root() 123 rc = nxt_unit_response_add_field(req, in ws_chat_root() 128 return rc; in ws_chat_root() [all …]
|
H A D | nxt_unit_app_test.c | 123 int rc; in worker() local 133 rc = nxt_unit_run(ctx); in worker() 139 return (void *) (intptr_t) rc; in worker() 146 int rc; in greeting_app_request_handler() local 159 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in greeting_app_request_handler() 163 rc = nxt_unit_response_add_field(req, in greeting_app_request_handler() 166 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in greeting_app_request_handler() 176 rc = nxt_unit_response_send(req); in greeting_app_request_handler() 206 rc = NXT_UNIT_ERROR; in greeting_app_request_handler() 267 rc = nxt_unit_buf_send(buf); in greeting_app_request_handler() [all …]
|
H A D | nxt_unit_websocket_echo.c | 19 int rc; in ws_echo_request_handler() local 22 rc = NXT_UNIT_OK; in ws_echo_request_handler() 30 rc = nxt_unit_response_init(req, 101, 0, 0); in ws_echo_request_handler() 31 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in ws_echo_request_handler() 43 rc = nxt_unit_response_init(req, 404, 0, 0); in ws_echo_request_handler() 47 nxt_unit_request_done(req, rc); in ws_echo_request_handler()
|
H A D | nxt_http_parse_test.c | 532 nxt_int_t rc; in nxt_http_parse_test() local 540 rc = nxt_http_fields_hash(&nxt_http_test_fields_hash, in nxt_http_parse_test() 543 if (rc != NXT_OK) { in nxt_http_parse_test() 567 if (rc != test->result) { in nxt_http_parse_test() 609 if (rc != NXT_OK) { in nxt_http_parse_test() 634 nxt_int_t rc; in nxt_http_parse_test_run() local 645 rc = nxt_http_parse_request(rp, &buf); in nxt_http_parse_test_run() 646 } while (buf.free < buf.end && rc == NXT_AGAIN); in nxt_http_parse_test_run() 648 return rc; in nxt_http_parse_test_run() 799 nxt_int_t rc; in nxt_http_parse_test_fields() local [all …]
|
/unit/src/ |
H A D | nxt_external.c | 68 nxt_int_t rc; in nxt_external_start() local 90 if (nxt_slow_path(rc != NXT_OK)) { in nxt_external_start() 95 if (nxt_slow_path(rc != NXT_OK)) { in nxt_external_start() 99 rc = nxt_external_fd_no_cloexec(task, my_port->pair[0]); in nxt_external_start() 100 if (nxt_slow_path(rc != NXT_OK)) { in nxt_external_start() 104 rc = nxt_external_fd_no_cloexec(task, my_port->pair[1]); in nxt_external_start() 105 if (nxt_slow_path(rc != NXT_OK)) { in nxt_external_start() 110 if (nxt_slow_path(rc != NXT_OK)) { in nxt_external_start() 115 if (nxt_slow_path(rc != NXT_OK)) { in nxt_external_start() 144 rc = setenv(NXT_UNIT_INIT_ENV, (char *) buf, 1); in nxt_external_start() [all …]
|
H A D | nxt_java.c | 340 if (rc != JNI_OK) { in nxt_java_start() 346 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() 447 rc = nxt_unit_run(ctx); in nxt_java_start() 461 exit(rc); in nxt_java_start() 647 int rc; in nxt_java_thread_func() local [all …]
|
H A D | nxt_unit.c | 658 int rc; in nxt_unit_ctx_init() local 1163 return rc; in nxt_unit_process_msg() 2372 return rc; in nxt_unit_response_send() 2728 return rc; in nxt_unit_mmap_buf_send() 3399 return rc; in nxt_unit_websocket_sendv() 4076 return rc; in nxt_unit_incoming_mmap() 4548 return rc; in nxt_unit_run() 4555 int rc; in nxt_unit_run_once() local 4563 return rc; in nxt_unit_run_once() 4597 return rc; in nxt_unit_run_once_impl() [all …]
|
H A D | nxt_controller.c | 395 nxt_int_t rc; in nxt_controller_send_current_conf() local 563 nxt_int_t rc; in nxt_controller_conf_send() local 613 if (nxt_slow_path(rc != NXT_OK)) { in nxt_controller_conf_send() 737 nxt_int_t rc; in nxt_controller_conn_read() local 755 if (rc == NXT_AGAIN) { in nxt_controller_conn_read() 1158 nxt_int_t rc; in nxt_controller_process_config() local 1254 switch (rc) { in nxt_controller_process_config() 1286 if (rc == NXT_DECLINED) { in nxt_controller_process_config() 1334 if (rc != NXT_OK) { in nxt_controller_process_config() 1369 if (rc == NXT_DECLINED) { in nxt_controller_process_config() [all …]
|
H A D | nxt_http_parse.c | 128 nxt_int_t rc; in nxt_http_parse_request() local 135 rc = rp->handler(rp, &b->pos, b->free); in nxt_http_parse_request() 136 } while (rc == NXT_OK); in nxt_http_parse_request() 138 return rc; in nxt_http_parse_request() 145 nxt_int_t rc; in nxt_http_parse_fields() local 153 } while (rc == NXT_OK); in nxt_http_parse_fields() 155 return rc; in nxt_http_parse_fields() 164 nxt_int_t rc; in nxt_http_parse_request_line() local 248 if (nxt_slow_path(rc != NXT_OK)) { in nxt_http_parse_request_line() 249 return rc; in nxt_http_parse_request_line() [all …]
|
H A D | nxt_fs.c | 21 int rc; in nxt_fs_mount() local 68 rc = mount((const char *) mnt->src, (const char *) mnt->dst, fsname, flags, in nxt_fs_mount() 71 if (nxt_slow_path(rc < 0)) { in nxt_fs_mount()
|
H A D | nxt_conf.c | 936 nxt_int_t rc; in nxt_conf_clone() local 946 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_clone() 1002 nxt_int_t rc; in nxt_conf_copy_array() local 1046 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_copy_array() 1102 nxt_int_t rc; in nxt_conf_copy_object() local 1146 rc = nxt_conf_copy_value(mp, NULL, in nxt_conf_copy_object() 1150 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_copy_object() 1158 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_copy_object() 1474 nxt_int_t rc; in nxt_conf_json_parse_object() local 1535 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_json_parse_object() [all …]
|
H A D | nxt_php_sapi.c | 1165 int rc; local 1170 rc = nxt_unit_response_write(ctx->req, str, str_length); 1171 if (nxt_fast_path(rc == NXT_UNIT_OK)) { 1183 int rc, fields_count; local 1198 rc = nxt_unit_response_init(req, 200, 0, 0); 1199 if (nxt_slow_path(rc != NXT_UNIT_OK)) { 1218 rc = nxt_unit_response_init(req, status, fields_count, resp_size); 1219 if (nxt_slow_path(rc != NXT_UNIT_OK)) { 1244 rc = nxt_unit_response_send(req); 1245 if (nxt_slow_path(rc != NXT_UNIT_OK)) {
|
H A D | nxt_conn_write.c | 253 int rc = sendfile(fd, s, pos, &sent, NULL, 0); in nxt_sendfile() local 255 res = (rc == 0 || sent > 0) ? sent : -1; in nxt_sendfile() 261 int rc = sendfile(fd, s, pos, size, NULL, &sent, 0); in nxt_sendfile() local 263 res = (rc == 0 || sent > 0) ? sent : -1; in nxt_sendfile()
|
H A D | nxt_unit.h | 319 void nxt_unit_request_done(nxt_unit_request_info_t *req, int rc);
|
/unit/src/java/ |
H A D | nxt_jni_OutputStream.c | 107 int rc; in nxt_java_OutputStream_flush_buf() local 114 if (rc != NXT_UNIT_OK) { in nxt_java_OutputStream_flush_buf() 117 return rc; in nxt_java_OutputStream_flush_buf() 122 rc = nxt_unit_response_send(req); in nxt_java_OutputStream_flush_buf() 123 if (rc != NXT_UNIT_OK) { in nxt_java_OutputStream_flush_buf() 126 return rc; 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() 143 return rc; in nxt_java_OutputStream_flush_buf() 178 int rc; in nxt_java_OutputStream_write() local [all …]
|
H A D | nxt_jni_Response.c | 264 int rc; in nxt_java_Response_addHeader() local 293 if (rc != NXT_UNIT_OK) { in nxt_java_Response_addHeader() 306 int rc; in nxt_java_get_response_info() local 326 if (rc != NXT_UNIT_OK) { in nxt_java_get_response_info() 654 if (rc != NXT_UNIT_OK) { in nxt_java_Response_sendRedirect() 752 if (rc != NXT_UNIT_OK) { in nxt_java_Response_setHeader() 780 if (rc != NXT_UNIT_OK) { in nxt_java_Response_removeHeader() 825 int value_len, rc; in nxt_java_Response_setIntHeader() local 843 if (rc != NXT_UNIT_OK) { in nxt_java_Response_setIntHeader() 1028 int rc; in nxt_java_Response_setContentType() local [all …]
|
/unit/src/python/ |
H A D | nxt_python_wsgi.c | 276 int rc; in nxt_python_wsgi_run() local 283 rc = nxt_unit_run(ctx); in nxt_python_wsgi_run() 287 return rc; in nxt_python_wsgi_run() 303 int rc; in nxt_python_request_handler() local 332 rc = NXT_UNIT_ERROR; in nxt_python_request_handler() 585 int rc; in nxt_python_get_environ() local 1015 int rc; in nxt_python_response_add_field() local 1056 return rc; in nxt_python_response_add_field() 1085 int rc; in nxt_py_write() local 1314 int rc; in nxt_python_write() local [all …]
|
H A D | nxt_python_asgi_websocket.c | 256 int rc; in nxt_py_asgi_websocket_accept() local 318 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_websocket_accept() 345 rc = nxt_unit_response_send(ws->req); in nxt_py_asgi_websocket_accept() 361 int rc; in nxt_py_asgi_websocket_close() local 419 int rc; in nxt_py_asgi_websocket_send_frame() local 673 int rc; in nxt_py_asgi_websocket_suspend_frame() local 1045 int rc; in nxt_py_asgi_websocket_done() local 1064 rc = NXT_UNIT_ERROR; in nxt_py_asgi_websocket_done() 1069 rc = NXT_UNIT_OK; in nxt_py_asgi_websocket_done() 1073 status_code = (rc == NXT_UNIT_OK) in nxt_py_asgi_websocket_done() [all …]
|
H A D | nxt_python_asgi_http.c | 301 int rc; in nxt_py_asgi_http_response_start() local 327 rc = nxt_unit_response_init(http->req, PyLong_AsLong(status), in nxt_py_asgi_http_response_start() 330 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_http_response_start() 358 int rc; in nxt_py_asgi_http_response_body() local 448 rc = nxt_unit_response_send(http->req); in nxt_py_asgi_http_response_body() 449 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_http_response_body() 650 int rc; in nxt_py_asgi_http_done() local 668 rc = NXT_UNIT_ERROR; in nxt_py_asgi_http_done() 673 rc = NXT_UNIT_OK; in nxt_py_asgi_http_done() 676 nxt_unit_request_done(http->req, rc); in nxt_py_asgi_http_done()
|
H A D | nxt_python.c | 70 int rc; in nxt_python_start() local 256 rc = nxt_python_asgi_init(&python_init, &nxt_py_proto); in nxt_python_start() 259 rc = nxt_python_wsgi_init(&python_init, &nxt_py_proto); in nxt_python_start() 262 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_python_start() 266 rc = nxt_py_proto.ctx_data_alloc(&python_init.ctx_data, 1); in nxt_python_start() 267 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_python_start() 271 rc = nxt_python_init_threads(c); in nxt_python_start() 272 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_python_start() 287 rc = nxt_py_proto.run(unit_ctx); in nxt_python_start() 297 exit(rc); in nxt_python_start()
|
H A D | nxt_python_asgi.c | 918 int rc; in nxt_py_asgi_add_reader() local 934 rc = NXT_UNIT_ERROR; in nxt_py_asgi_add_reader() 962 rc = NXT_UNIT_OK; in nxt_py_asgi_add_reader() 975 return rc; in nxt_py_asgi_add_reader() 1027 int rc; in nxt_py_asgi_shm_ack_handler() local 1036 rc = nxt_py_asgi_http_drain(lnk); in nxt_py_asgi_shm_ack_handler() 1037 if (rc == NXT_UNIT_AGAIN) { in nxt_py_asgi_shm_ack_handler() 1049 int rc; in nxt_py_asgi_port_read() local 1091 if (rc == NXT_UNIT_OK) { in nxt_py_asgi_port_read() 1197 int rc; in nxt_py_asgi_add_field() local [all …]
|
/unit/src/ruby/ |
H A D | nxt_ruby.c | 411 exit(rc); in nxt_ruby_start() 579 int rc; in nxt_ruby_rack_env_create() local 879 rc = NXT_UNIT_OK; in nxt_ruby_rack_result_headers() 895 return rc; in nxt_ruby_rack_result_headers() 901 return rc; in nxt_ruby_rack_result_headers() 970 rc = &headers_info->rc; in nxt_ruby_hash_add() 1010 *rc = NXT_UNIT_ERROR; in nxt_ruby_hash_add() 1019 int rc; in nxt_ruby_rack_result_body() local 1037 return rc; in nxt_ruby_rack_result_body() 1118 rc = fstat(fd, &finfo); in nxt_ruby_rack_result_body_file_write() [all …]
|
/unit/src/perl/ |
H A D | nxt_perl_psgi.c | 783 int rc; in nxt_perl_psgi_result_head() local 836 return rc; in nxt_perl_psgi_result_head() 848 return rc; in nxt_perl_psgi_result_head() 862 int rc; in nxt_perl_psgi_result_body() local 912 int rc; in nxt_perl_psgi_result_body_ref() local 929 rc = NXT_UNIT_OK; in nxt_perl_psgi_result_body_ref() 965 return rc; in nxt_perl_psgi_result_body_ref() 1025 int rc; in nxt_perl_psgi_result_array() local 1185 exit(rc); in nxt_perl_psgi_start() 1343 strerror(rc), rc); in nxt_perl_psgi_init_threads() [all …]
|
/unit/go/ |
H A D | nxt_cgo_lib.c | 21 int rc; in nxt_cgo_run() local 42 rc = nxt_unit_run_ctx(ctx); in nxt_cgo_run() 46 return rc; in nxt_cgo_run()
|
H A D | unit.go | 148 rc := C.nxt_cgo_run(C.uintptr_t(h)) 152 if rc != 0 {
|