Home
last modified time | relevance | path

Searched refs:rc (Results 1 – 25 of 26) sorted by relevance

12

/unit/src/test/
H A Dnxt_unit_websocket_chat.c51 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 Dnxt_unit_app_test.c123 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 Dnxt_unit_websocket_echo.c19 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 Dnxt_http_parse_test.c532 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 Dnxt_external.c68 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 Dnxt_java.c340 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 Dnxt_unit.c658 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 Dnxt_controller.c395 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 Dnxt_http_parse.c128 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 Dnxt_fs.c21 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 Dnxt_conf.c936 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 Dnxt_php_sapi.c1165 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 Dnxt_conn_write.c253 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 Dnxt_unit.h319 void nxt_unit_request_done(nxt_unit_request_info_t *req, int rc);
/unit/src/java/
H A Dnxt_jni_OutputStream.c107 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 Dnxt_jni_Response.c264 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 Dnxt_python_wsgi.c276 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 Dnxt_python_asgi_websocket.c256 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 Dnxt_python_asgi_http.c301 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 Dnxt_python.c70 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 Dnxt_python_asgi.c918 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 Dnxt_ruby.c411 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 Dnxt_perl_psgi.c783 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 Dnxt_cgo_lib.c21 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 Dunit.go148 rc := C.nxt_cgo_run(C.uintptr_t(h))
152 if rc != 0 {

12