/unit/src/ |
H A D | nxt_unit.c | 5892 ssize_t ret; in nxt_unit_port_send() local 5922 ret = nxt_unit_sendmsg(ctx, port->out_fd, &msg, in nxt_unit_port_send() 5927 (int) ret); in nxt_unit_port_send() 5930 ret = lib->callbacks.port_send(ctx, port, &msg, in nxt_unit_port_send() 5935 (int) ret); in nxt_unit_port_send() 5959 ret = lib->callbacks.port_send(ctx, port, buf, buf_size, in nxt_unit_port_send() 5965 (int) ret); in nxt_unit_port_send() 5968 ret = nxt_unit_sendmsg(ctx, port->out_fd, buf, buf_size, oob); in nxt_unit_port_send() 5972 (int) ret); in nxt_unit_port_send() 5975 return ret; in nxt_unit_port_send()
|
H A D | nxt_sockaddr.c | 190 int ret; in nxt_getsockname() local 197 ret = getsockname(s, &sockaddr.buf, &socklen); in nxt_getsockname() 199 if (nxt_fast_path(ret == 0)) { in nxt_getsockname() 728 nxt_int_t ret, port; in nxt_sockaddr_inet6_parse() local 774 ret = nxt_inet6_addr(&sa->u.sockaddr_in6.sin6_addr, start, end - start); in nxt_sockaddr_inet6_parse() 775 if (nxt_slow_path(ret != NXT_OK)) { in nxt_sockaddr_inet6_parse() 857 nxt_int_t ret; in nxt_job_sockaddr_parse() local 866 ret = nxt_job_sockaddr_unix_parse(jbs); in nxt_job_sockaddr_parse() 869 ret = nxt_job_sockaddr_inet6_parse(jbs); in nxt_job_sockaddr_parse() 872 ret = nxt_job_sockaddr_inet_parse(jbs); in nxt_job_sockaddr_parse() [all …]
|
H A D | nxt_port_socket.c | 735 nxt_int_t ret; in nxt_port_read_handler() local 764 ret = nxt_socket_msg_oob_get(&oob, msg.fd, in nxt_port_read_handler() 766 if (nxt_slow_path(ret != NXT_OK)) { in nxt_port_read_handler() 816 nxt_int_t ret; in nxt_port_queue_read_handler() local 916 ret = nxt_socket_msg_oob_get(&oob, msg.fd, in nxt_port_queue_read_handler() 918 if (nxt_slow_path(ret != NXT_OK)) { in nxt_port_queue_read_handler()
|
H A D | nxt_http_static.c | 79 nxt_str_t str, *ret; in nxt_http_static_init() local 121 if (nxt_slow_path(ret == NULL)) { in nxt_http_static_init() 228 nxt_int_t ret; in nxt_http_static_iterate() local 300 nxt_int_t ret; in nxt_http_static_send_ready() local 355 if (ret == 0) { in nxt_http_static_send_ready() 393 ret = NXT_ERROR; in nxt_http_static_send_ready() 403 ret = NXT_OK; in nxt_http_static_send_ready() 429 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_static_send_ready() 500 ret = nxt_file_info(f, &fi); in nxt_http_static_send_ready() 501 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_static_send_ready() [all …]
|
H A D | nxt_http_request.c | 68 nxt_int_t ret; in nxt_http_init() local 70 ret = nxt_h1p_init(task); in nxt_http_init() 72 if (ret != NXT_OK) { in nxt_http_init() 73 return ret; in nxt_http_init() 83 nxt_int_t ret; in nxt_http_request_host() local 102 return ret; in nxt_http_request_host() 302 nxt_int_t ret; in nxt_http_request_start() local 345 if (ret <= 0) { in nxt_http_request_forward() 410 nxt_int_t ret, i, len; in nxt_http_request_forward_client_ip() local 984 nxt_int_t ret; in nxt_http_cookies_parse() local [all …]
|
H A D | nxt_http_parse.c | 1186 nxt_int_t ret; in nxt_http_fields_hash() local 1206 ret = nxt_lvlhsh_insert(hash, &lhq); in nxt_http_fields_hash() 1208 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_fields_hash() 1262 nxt_int_t ret; in nxt_http_fields_process() local 1267 ret = nxt_http_field_process(field, hash, ctx); in nxt_http_fields_process() 1268 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_fields_process() 1269 return ret; in nxt_http_fields_process()
|
H A D | nxt_http.h | 224 nxt_conf_value_t *ret; member
|
H A D | nxt_conf.c | 440 nxt_int_t ret, index; in nxt_conf_get_path() local 448 ret = nxt_conf_path_next_token(&parse, &token); in nxt_conf_get_path() 449 if (nxt_slow_path(ret != NXT_OK)) { in nxt_conf_get_path() 800 nxt_int_t ret, index; in nxt_conf_op_compile() local 821 ret = nxt_conf_path_next_token(&parse, &token); in nxt_conf_op_compile() 822 if (nxt_slow_path(ret != NXT_OK)) { in nxt_conf_op_compile() 918 ret = nxt_conf_set_string_dup(&member->name, mp, &token); in nxt_conf_op_compile() 919 if (nxt_slow_path(ret != NXT_OK)) { in nxt_conf_op_compile()
|
H A D | nxt_router.c | 355 return ret; in nxt_router_start() 361 return ret; in nxt_router_start() 1796 return ret; in nxt_router_conf_create() 3055 nxt_int_t ret; in nxt_router_engine_conf_create() local 3060 return ret; in nxt_router_engine_conf_create() 3066 return ret; in nxt_router_engine_conf_create() 3069 return ret; in nxt_router_engine_conf_create() 3077 nxt_int_t ret; in nxt_router_engine_conf_update() local 3082 return ret; in nxt_router_engine_conf_update() 3096 return ret; in nxt_router_engine_conf_update() [all …]
|
H A D | nxt_http_route.c | 653 return ret; in nxt_http_action_init() 1606 ret = 1; in nxt_http_route_table() 1620 return ret; in nxt_http_route_table() 1872 ret = 0; in nxt_http_route_header() 1895 return ret; in nxt_http_route_header() 1920 ret = 0; in nxt_http_route_test_argument() 1945 return ret; in nxt_http_route_test_argument() 1998 ret = 0; in nxt_http_route_test_cookie() 2023 return ret; in nxt_http_route_test_cookie() 2034 ret = 1; in nxt_http_route_test_rule() [all …]
|
H A D | nxt_h1proto.c | 196 nxt_int_t ret; in nxt_h1p_init() local 207 return ret; in nxt_h1p_init() 561 ret = nxt_expect(NXT_DONE, ret); in nxt_h1p_conn_request_header_parse() 563 if (ret != NXT_AGAIN) { in nxt_h1p_conn_request_header_parse() 569 switch (ret) { in nxt_h1p_conn_request_header_parse() 594 status = ret; in nxt_h1p_conn_request_header_parse() 642 nxt_int_t ret; in nxt_h1p_header_process() local 660 return ret; in nxt_h1p_header_process() 699 return ret; in nxt_h1p_header_process() 2511 ret = nxt_expect(NXT_DONE, ret); in nxt_h1p_peer_header_read_done() [all …]
|
H A D | nxt_conf_validation.c | 549 ssize_t ret; in nxt_conf_vldt_ticket_key_element() local 565 if (ret != 48 && ret != 80) { in nxt_conf_vldt_ticket_key_element() 1211 nxt_int_t ret; in nxt_conf_validate() local 1215 return ret; in nxt_conf_validate() 1384 return ret; in nxt_conf_vldt_mtypes() 1398 return ret; in nxt_conf_vldt_mtypes_type() 1927 return ret; in nxt_conf_vldt_match_patterns() 2066 return ret; in nxt_conf_vldt_match_encoded_patterns() 2203 return ret; in nxt_conf_vldt_match_patterns_sets() 2757 return ret; in nxt_conf_vldt_targets() [all …]
|
H A D | nxt_var.c | 458 nxt_int_t ret; in nxt_var_query() local 487 ret = nxt_var_cache_add(&query->cache, index, value, mp); in nxt_var_query() 489 if (ret != NXT_OK) { in nxt_var_query() 490 if (nxt_slow_path(ret == NXT_ERROR)) { in nxt_var_query() 497 ret = nxt_var_index[index](task, value, query->ctx); in nxt_var_query() 498 if (nxt_slow_path(ret != NXT_OK)) { in nxt_var_query()
|
H A D | nxt_port_rpc.c | 191 nxt_int_t ret; in nxt_port_rpc_ex_set_peer() local 223 switch (ret) { in nxt_port_rpc_ex_set_peer() 258 nxt_int_t ret; in nxt_port_rpc_remove_from_peers() local 296 ret = NXT_OK; in nxt_port_rpc_remove_from_peers() 299 if (nxt_slow_path(ret != NXT_OK)) { in nxt_port_rpc_remove_from_peers() 311 nxt_int_t ret; in nxt_port_rpc_handler() local 332 if (ret != NXT_OK) { in nxt_port_rpc_handler() 371 nxt_int_t ret; in nxt_port_rpc_remove_peer() local 383 if (nxt_slow_path(ret != NXT_OK)) { in nxt_port_rpc_remove_peer() 462 nxt_int_t ret; in nxt_port_rpc_cancel() local [all …]
|
H A D | nxt_http_return.c | 49 conf->status = nxt_conf_get_number(acf->ret); in nxt_http_return_init() 75 nxt_int_t ret; in nxt_http_return() local 122 ret = nxt_var_query_init(&r->var_query, r, r->mem_pool); in nxt_http_return() 123 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_return() 172 nxt_int_t ret; in nxt_http_return_send_ready() local 182 ret = nxt_http_return_encode(r->mem_pool, &ctx->encoded, in nxt_http_return_send_ready() 184 if (nxt_slow_path(ret == NXT_ERROR)) { in nxt_http_return_send_ready()
|
H A D | nxt_openssl.c | 147 nxt_int_t ret; in nxt_openssl_library_init() local 220 nxt_int_t ret; in nxt_openssl_locks_init() local 460 ret = NXT_ERROR; 523 ret = NXT_OK; 540 return ret; 1193 if (ret == 0) { 1277 if (ret > 0) { 1350 if (ret > 0) { 1351 return ret; 1401 if (ret > 0) { [all …]
|
H A D | nxt_lvlhsh.c | 315 nxt_int_t ret; in nxt_lvlhsh_level_insert() local 341 return ret; in nxt_lvlhsh_level_insert() 351 nxt_int_t ret; in nxt_lvlhsh_bucket_insert() local 442 return ret; in nxt_lvlhsh_bucket_insert() 457 nxt_int_t ret; in nxt_lvlhsh_convert_bucket_to_level() local 516 nxt_int_t ret; in nxt_lvlhsh_level_convertion_insert() local 533 return ret; in nxt_lvlhsh_level_convertion_insert() 555 nxt_int_t ret; in nxt_lvlhsh_bucket_convertion_insert() local 592 return ret; in nxt_lvlhsh_bucket_convertion_insert() 649 nxt_int_t ret; in nxt_lvlhsh_level_delete() local [all …]
|
H A D | nxt_fastcgi_source.c | 199 nxt_int_t ret; in nxt_fastcgi_request_create() local 213 if (nxt_slow_path(ret != NXT_OK)) { in nxt_fastcgi_request_create() 247 if (nxt_slow_path(ret != NXT_OK)) { in nxt_fastcgi_request_create() 334 nxt_int_t ret; in nxt_fastcgi_next_param() local 346 ret = fs->request_create(fs); in nxt_fastcgi_next_param() 348 if (nxt_slow_path(ret != NXT_OK)) { in nxt_fastcgi_next_param() 349 return ret; in nxt_fastcgi_next_param() 465 nxt_int_t ret; in nxt_fastcgi_source_header_filter() local 494 if (nxt_fast_path(ret == NXT_DONE)) { in nxt_fastcgi_source_header_filter() 500 if (nxt_fast_path(ret != NXT_AGAIN)) { in nxt_fastcgi_source_header_filter() [all …]
|
H A D | nxt_fiber.c | 43 int ret; in nxt_fiber_create() local 109 ret = munmap(fib->stack - nxt_pagesize, fib->stack_size + nxt_pagesize); in nxt_fiber_create() 111 if (nxt_slow_path(ret != 0)) { in nxt_fiber_create()
|
H A D | nxt_http_chunk_parse.c | 32 nxt_int_t ret; in nxt_http_chunk_parse() local 59 ret = nxt_http_chunk_buffer(hcp, &tail, b); in nxt_http_chunk_parse() 61 if (ret == NXT_HTTP_CHUNK_MIDDLE) { in nxt_http_chunk_parse() 65 if (nxt_slow_path(ret == NXT_ERROR)) { in nxt_http_chunk_parse() 72 if (ret == NXT_HTTP_CHUNK_END_ON_BORDER) { in nxt_http_chunk_parse()
|
H A D | nxt_cache.c | 179 if (ret != NXT_OK) { in nxt_cache_query_locked() 228 if (ret == NXT_OK) { in nxt_cache_node_hold() 238 if (ret == NXT_ERROR) { in nxt_cache_node_hold() 457 return ret; in nxt_cache_update() 466 ssize_t ret; in nxt_cache_release() local 483 if (ret == 0) { in nxt_cache_release() 496 if (ret < 0) { in nxt_cache_release() 539 ret = 0; in nxt_cache_release_locked() 544 if (ret < 0) { in nxt_cache_release_locked() 545 return ret; in nxt_cache_release_locked() [all …]
|
H A D | nxt_main_process.c | 468 if (ret != NXT_OK) { in nxt_main_start_process_handler() 514 if (nxt_fast_path(ret == NXT_OK || ret == NXT_AGAIN)) { in nxt_main_start_process_handler() 517 if (ret == NXT_OK) { in nxt_main_start_process_handler() 699 nxt_int_t ret; in nxt_main_process_port_create() local 714 return ret; in nxt_main_process_port_create() 787 nxt_int_t ret; in nxt_main_process_sigusr1_handler() local 841 if (ret == NXT_OK) { in nxt_main_process_sigusr1_handler() 1065 if (ret == NXT_OK) { in nxt_main_port_socket_handler() 1415 if (ret == NXT_OK) { in nxt_main_port_modules_handler() 1455 nxt_int_t ret; in nxt_main_port_conf_store_handler() local [all …]
|
H A D | nxt_gnutls.c | 89 int ret; in nxt_gnutls_start() local 146 int ret; in nxt_gnutls_server_init() local 197 if (ret < 0) { in nxt_gnutls_server_init() 224 int ret; in nxt_gnutls_set_ciphers() local 234 switch (ret) { in nxt_gnutls_set_ciphers() 429 nxt_int_t ret; in nxt_gnutls_conn_handshake() local 453 if (ret == NXT_ERROR) { in nxt_gnutls_conn_handshake() 543 nxt_int_t ret; in nxt_gnutls_conn_io_send() local 566 return ret; in nxt_gnutls_conn_io_send() 634 int ret; in nxt_gnutls_conn_test_error() local [all …]
|
H A D | nxt_clone.c | 139 nxt_int_t ret, len; in nxt_clone_credential_map_set() local 195 ret = nxt_clone_credential_map_write(task, mapfile, pid, mapinfo); in nxt_clone_credential_map_set() 199 return ret; in nxt_clone_credential_map_set() 207 nxt_int_t ret; in nxt_clone_credential_map() local 230 ret = nxt_clone_credential_map_set(task, "uid_map", pid, app_creds->uid, in nxt_clone_credential_map() 234 if (nxt_slow_path(ret != NXT_OK)) { in nxt_clone_credential_map() 238 ret = nxt_clone_credential_setgroups(task, pid, rule); in nxt_clone_credential_map() 239 if (nxt_slow_path(ret != NXT_OK)) { in nxt_clone_credential_map() 244 ret = nxt_clone_credential_map_set(task, "gid_map", pid, app_creds->base_gid, in nxt_clone_credential_map() 248 if (nxt_slow_path(ret != NXT_OK)) { in nxt_clone_credential_map()
|
/unit/src/python/ |
H A D | nxt_python.c | 75 nxt_int_t ret, n, i; in nxt_python_start() local 220 ret = nxt_python_set_target(task, &targets->target[i], cv); in nxt_python_start() 221 if (nxt_slow_path(ret != NXT_OK)) { in nxt_python_start() 227 ret = nxt_python_set_target(task, &targets->target[0], app_conf->self); in nxt_python_start() 228 if (nxt_slow_path(ret != NXT_OK)) { in nxt_python_start() 396 int ret; in nxt_python_set_path() local 437 ret = PyList_Insert(sys, 0, path); in nxt_python_set_path() 441 if (nxt_slow_path(ret != 0)) { in nxt_python_set_path()
|