Home
last modified time | relevance | path

Searched refs:rc (Results 1 – 25 of 28) sorted by last modified time

12

/unit/src/wasm-wasi-component/src/
H A Dlib.rs137 let rc = match func() { in handle_result()
144 return rc; in handle_result()
520 let rc = bindings::nxt_unit_response_write( in response_write()
525 assert_eq!(rc, 0); in response_write()
531 let rc = bindings::nxt_unit_response_init( in init_response()
537 assert_eq!(rc, 0); in init_response()
543 let rc = bindings::nxt_unit_response_add_field( in add_field()
550 assert_eq!(rc, 0); in add_field()
556 let rc = bindings::nxt_unit_response_send(self.info); in send_response()
557 assert_eq!(rc, 0); in send_response()
/unit/src/python/
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
455 rc = nxt_unit_response_send(http->req); in nxt_py_asgi_http_response_body()
456 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_py_asgi_http_response_body()
657 int rc; in nxt_py_asgi_http_done() local
675 rc = NXT_UNIT_ERROR; in nxt_py_asgi_http_done()
680 rc = NXT_UNIT_OK; in nxt_py_asgi_http_done()
683 nxt_unit_request_done(http->req, rc); in nxt_py_asgi_http_done()
H A Dnxt_python_wsgi.c283 int rc; in nxt_python_wsgi_run() local
290 rc = nxt_unit_run(ctx); in nxt_python_wsgi_run()
294 return rc; in nxt_python_wsgi_run()
310 int rc; in nxt_python_request_handler() local
342 rc = NXT_UNIT_ERROR; in nxt_python_request_handler()
595 int rc; in nxt_python_get_environ() local
1083 int rc; in nxt_python_response_add_field() local
1124 return rc; in nxt_python_response_add_field()
1153 int rc; in nxt_py_write() local
1382 int rc; in nxt_python_write() local
[all …]
H A Dnxt_python_asgi.c1028 int rc; in nxt_py_asgi_add_reader() local
1044 rc = NXT_UNIT_ERROR; in nxt_py_asgi_add_reader()
1072 rc = NXT_UNIT_OK; in nxt_py_asgi_add_reader()
1085 return rc; in nxt_py_asgi_add_reader()
1137 int rc; in nxt_py_asgi_shm_ack_handler() local
1146 rc = nxt_py_asgi_http_drain(lnk); in nxt_py_asgi_shm_ack_handler()
1147 if (rc == NXT_UNIT_AGAIN) { in nxt_py_asgi_shm_ack_handler()
1159 int rc; in nxt_py_asgi_port_read() local
1201 if (rc == NXT_UNIT_OK) { in nxt_py_asgi_port_read()
1307 int rc; in nxt_py_asgi_add_field() local
[all …]
H A Dnxt_python.c149 int rc; in nxt_python_start() local
338 rc = nxt_python_asgi_init(&python_init, &nxt_py_proto); in nxt_python_start()
341 rc = nxt_python_wsgi_init(&python_init, &nxt_py_proto); in nxt_python_start()
344 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_python_start()
348 rc = nxt_py_proto.ctx_data_alloc(&python_init.ctx_data, 1); in nxt_python_start()
349 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_python_start()
353 rc = nxt_python_init_threads(c); in nxt_python_start()
354 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_python_start()
369 rc = nxt_py_proto.run(unit_ctx); in nxt_python_start()
379 exit(rc); in nxt_python_start()
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 …]
/unit/src/
H A Dnxt_conn_write.c260 int rc = sendfile(fd, s, pos, &sent, NULL, 0); in nxt_sendfile() local
262 res = (rc == 0 || sent > 0) ? sent : -1; in nxt_sendfile()
268 int rc = sendfile(fd, s, pos, size, NULL, &sent, 0); in nxt_sendfile() local
270 res = (rc == 0 || sent > 0) ? sent : -1; in nxt_sendfile()
H A Dnxt_http_js.c195 njs_int_t rc; in nxt_http_js_ext_get_header() local
207 if (rc != NJS_OK) { in nxt_http_js_ext_get_header()
232 njs_int_t rc; in nxt_http_js_ext_keys_header() local
237 if (rc != NJS_OK) { in nxt_http_js_ext_keys_header()
254 if (rc != NJS_OK) { in nxt_http_js_ext_keys_header()
268 njs_int_t rc; in nxt_http_js_ext_get_cookie() local
281 if (rc != NJS_OK) { in nxt_http_js_ext_get_cookie()
319 if (rc != NJS_OK) { in nxt_http_js_ext_keys_cookie()
344 if (rc != NJS_OK) { in nxt_http_js_ext_keys_cookie()
357 njs_int_t rc; in nxt_http_js_ext_get_var() local
[all …]
H A Dnxt_conf.c961 nxt_int_t rc; in nxt_conf_clone() local
971 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_clone()
1027 nxt_int_t rc; in nxt_conf_copy_array() local
1071 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_copy_array()
1127 nxt_int_t rc; in nxt_conf_copy_object() local
1171 rc = nxt_conf_copy_value(mp, NULL, in nxt_conf_copy_object()
1175 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_copy_object()
1183 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_copy_object()
1499 nxt_int_t rc; in nxt_conf_json_parse_object() local
1560 if (nxt_slow_path(rc != NXT_OK)) { in nxt_conf_json_parse_object()
[all …]
H A Dnxt_php_sapi.c1295 int rc; local
1300 rc = nxt_unit_response_write(ctx->req, str, str_length);
1301 if (nxt_fast_path(rc == NXT_UNIT_OK)) {
1313 int rc, fields_count; local
1328 rc = nxt_unit_response_init(req, 200, 0, 0);
1329 if (nxt_slow_path(rc != NXT_UNIT_OK)) {
1348 rc = nxt_unit_response_init(req, status, fields_count, resp_size);
1349 if (nxt_slow_path(rc != NXT_UNIT_OK)) {
1374 rc = nxt_unit_response_send(req);
1375 if (nxt_slow_path(rc != NXT_UNIT_OK)) {
H A Dnxt_unit.h319 void nxt_unit_request_done(nxt_unit_request_info_t *req, int rc);
H A Dnxt_controller.c427 nxt_int_t rc; in nxt_controller_send_current_conf() local
596 nxt_int_t rc; in nxt_controller_conf_send() local
646 if (nxt_slow_path(rc != NXT_OK)) { in nxt_controller_conf_send()
778 nxt_int_t rc; in nxt_controller_conn_read() local
796 if (rc == NXT_AGAIN) { in nxt_controller_conn_read()
1271 nxt_int_t rc; in nxt_controller_process_config() local
1367 switch (rc) { in nxt_controller_process_config()
1399 if (rc == NXT_DECLINED) { in nxt_controller_process_config()
1447 if (rc != NXT_OK) { in nxt_controller_process_config()
1571 nxt_int_t rc; in nxt_controller_process_status() local
[all …]
H A Dnxt_unit.c673 int rc; in nxt_unit_ctx_init() local
1177 return rc; in nxt_unit_process_msg()
2387 return rc; in nxt_unit_response_send()
2742 return rc; in nxt_unit_mmap_buf_send()
3411 return rc; in nxt_unit_websocket_sendv()
4085 return rc; in nxt_unit_incoming_mmap()
4556 return rc; in nxt_unit_run()
4563 int rc; in nxt_unit_run_once() local
4571 return rc; in nxt_unit_run_once()
4605 return rc; in nxt_unit_run_once_impl()
[all …]
H A Dnxt_http_parse.c126 nxt_int_t rc; in nxt_http_parse_request() local
133 rc = rp->handler(rp, &b->pos, b->free); in nxt_http_parse_request()
134 } while (rc == NXT_OK); in nxt_http_parse_request()
136 return rc; in nxt_http_parse_request()
143 nxt_int_t rc; in nxt_http_parse_fields() local
151 } while (rc == NXT_OK); in nxt_http_parse_fields()
153 return rc; in nxt_http_parse_fields()
162 nxt_int_t rc; in nxt_http_parse_request_line() local
246 if (nxt_slow_path(rc != NXT_OK)) { in nxt_http_parse_request_line()
247 return rc; in nxt_http_parse_request_line()
[all …]
H A Dnxt_fs_mount.c18 int rc; in nxt_fs_mount() local
65 rc = mount((const char *) mnt->src, (const char *) mnt->dst, fsname, flags, in nxt_fs_mount()
68 if (nxt_slow_path(rc < 0)) { in nxt_fs_mount()
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 …]
/unit/src/nodejs/unit-http/
H A Dunit.cpp60 int rc, err; in process_port_msg() local
62 rc = nxt_unit_process_port_msg(ctx, port); in process_port_msg()
64 if (rc != NXT_UNIT_OK) { in process_port_msg()
/unit/src/ruby/
H A Dnxt_ruby.c409 exit(rc); in nxt_ruby_start()
551 int rc; in nxt_ruby_rack_env_create() local
851 rc = NXT_UNIT_OK; in nxt_ruby_rack_result_headers()
867 return rc; in nxt_ruby_rack_result_headers()
873 return rc; in nxt_ruby_rack_result_headers()
970 rc = &headers_info->rc; in nxt_ruby_hash_add()
1053 *rc = NXT_UNIT_ERROR; in nxt_ruby_hash_add()
1062 int rc; in nxt_ruby_rack_result_body() local
1080 return rc; in nxt_ruby_rack_result_body()
1161 rc = fstat(fd, &finfo); in nxt_ruby_rack_result_body_file_write()
[all …]
/unit/src/java/
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()
655 if (rc != NXT_UNIT_OK) { in nxt_java_Response_sendRedirect()
753 if (rc != NXT_UNIT_OK) { in nxt_java_Response_setHeader()
781 if (rc != NXT_UNIT_OK) { in nxt_java_Response_removeHeader()
826 int value_len, rc; in nxt_java_Response_setIntHeader() local
844 if (rc != NXT_UNIT_OK) { in nxt_java_Response_setIntHeader()
1029 int rc; in nxt_java_Response_setContentType() local
[all …]
/unit/src/test/
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_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 …]
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_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()
/unit/src/perl/
H A Dnxt_perl_psgi.c784 int rc; in nxt_perl_psgi_result_head() local
837 return rc; in nxt_perl_psgi_result_head()
849 return rc; in nxt_perl_psgi_result_head()
863 int rc; in nxt_perl_psgi_result_body() local
913 int rc; in nxt_perl_psgi_result_body_ref() local
930 rc = NXT_UNIT_OK; in nxt_perl_psgi_result_body_ref()
966 return rc; in nxt_perl_psgi_result_body_ref()
1026 int rc; in nxt_perl_psgi_result_array() local
1186 exit(rc); in nxt_perl_psgi_start()
1344 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()

12