/unit/src/ |
H A D | nxt_process.c | 159 return ret; in nxt_process_init_start() 188 ret = NXT_ERROR; in nxt_process_start() 205 ret = NXT_ERROR; in nxt_process_start() 213 ret = NXT_AGAIN; in nxt_process_start() 224 ret = NXT_OK; in nxt_process_start() 242 return ret; in nxt_process_start() 424 return ret; in nxt_process_setup() 474 return ret; in nxt_process_do_start() 484 nxt_int_t ret; in nxt_process_whoami() local 685 nxt_int_t ret; in nxt_process_core_setup() 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_pcre2.c | 27 nxt_int_t ret; in nxt_regex_compile() local 60 ret = pcre2_get_error_message(errcode, (PCRE2_UCHAR *) err->msg, in nxt_regex_compile() 62 if (ret < 0) { in nxt_regex_compile() 74 ret = pcre2_get_error_message(errcode, (PCRE2_UCHAR *) err->msg, in nxt_regex_compile() 76 if (ret < 0) { in nxt_regex_compile() 136 nxt_int_t ret; in nxt_regex_match() local 139 ret = pcre2_match(re->code, (PCRE2_SPTR) subject, length, 0, 0, match, in nxt_regex_match() 142 if (nxt_slow_path(ret < PCRE2_ERROR_NOMATCH)) { in nxt_regex_match() 144 if (pcre2_get_error_message(ret, errptr, ERR_BUF_SIZE) < 0) { in nxt_regex_match() 147 "using \"%V\"", ret, length, subject, in nxt_regex_match() [all …]
|
H A D | nxt_fd_event.c | 35 nxt_int_t ret; in nxt_fd_event_hash_add() local 43 ret = nxt_lvlhsh_insert(lvlhsh, &lhq); in nxt_fd_event_hash_add() 45 if (nxt_fast_path(ret == NXT_OK)) { in nxt_fd_event_hash_add() 58 nxt_int_t ret; in nxt_fd_event_hash_get() local 64 ret = nxt_lvlhsh_find(lvlhsh, &lhq); in nxt_fd_event_hash_get() 66 if (nxt_fast_path(ret == NXT_OK)) { in nxt_fd_event_hash_get() 80 nxt_int_t ret; in nxt_fd_event_hash_delete() local 86 ret = nxt_lvlhsh_delete(lvlhsh, &lhq); in nxt_fd_event_hash_delete() 88 if (nxt_slow_path(ret != NXT_OK)) { in nxt_fd_event_hash_delete()
|
H A D | nxt_http_route_addr.c | 21 nxt_int_t ret, cidr_prefix; in nxt_http_route_addr_pattern_parse() local 94 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_route_addr_pattern_parse() 104 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_route_addr_pattern_parse() 183 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_route_addr_pattern_parse() 279 if (nxt_slow_path(ret < 0 || ret > 65535)) { in nxt_http_route_addr_pattern_parse() 283 base->port.start = ret; in nxt_http_route_addr_pattern_parse() 286 if (nxt_slow_path(ret < base->port.start || ret > 65535)) { in nxt_http_route_addr_pattern_parse() 290 base->port.end = ret; in nxt_http_route_addr_pattern_parse() 294 if (nxt_slow_path(ret < 0 || ret > 65535)) { in nxt_http_route_addr_pattern_parse() 298 base->port.start = ret; in nxt_http_route_addr_pattern_parse() [all …]
|
H A D | nxt_http_route.c | 655 return ret; in nxt_http_action_init() 1671 ret = 1; in nxt_http_route_table() 1685 return ret; in nxt_http_route_table() 1937 ret = 0; in nxt_http_route_header() 1960 return ret; in nxt_http_route_header() 1985 ret = 0; in nxt_http_route_test_argument() 2010 return ret; in nxt_http_route_test_argument() 2064 ret = 0; in nxt_http_route_test_cookie() 2089 return ret; in nxt_http_route_test_cookie() 2100 ret = 1; in nxt_http_route_test_rule() [all …]
|
H A D | nxt_conf_validation.c | 521 ssize_t ret; in nxt_conf_vldt_ticket_key_element() local 537 if (ret != 48 && ret != 80) { in nxt_conf_vldt_ticket_key_element() 1180 nxt_int_t ret; in nxt_conf_validate() local 1184 return ret; in nxt_conf_validate() 1353 return ret; in nxt_conf_vldt_mtypes() 1367 return ret; in nxt_conf_vldt_mtypes_type() 1896 return ret; in nxt_conf_vldt_match_patterns() 2035 return ret; in nxt_conf_vldt_match_encoded_patterns() 2172 return ret; in nxt_conf_vldt_match_patterns_sets() 2704 return ret; in nxt_conf_vldt_targets() [all …]
|
H A D | nxt_isolation.c | 80 return ret; in nxt_isolation_main_prefork() 95 return ret; in nxt_isolation_main_prefork() 126 return ret; in nxt_isolation_main_prefork() 146 return ret; in nxt_isolation_main_prefork() 206 nxt_int_t ret; in nxt_isolation_set_namespaces() local 231 nxt_int_t ret; in nxt_isolation_set_creds() local 761 nxt_int_t ret; in nxt_isolation_change_root() local 781 return ret; in nxt_isolation_change_root() 854 ret = NXT_ERROR; in nxt_isolation_make_private_mount() 975 ret = NXT_OK; in nxt_isolation_make_private_mount() [all …]
|
H A D | nxt_cyassl.c | 43 int ret, const char *fmt, ...); 297 int ret; in nxt_cyassl_conn_handshake() local 318 if (ret == 0) { in nxt_cyassl_conn_handshake() 341 int ret; in nxt_cyassl_conn_io_read() local 369 if (ret > 0) { in nxt_cyassl_conn_io_read() 371 b->mem.free += ret; in nxt_cyassl_conn_io_read() 411 int ret; in nxt_cyassl_conn_io_send() local 422 if (ret <= 0) { in nxt_cyassl_conn_io_send() 433 if (ret > 0) { in nxt_cyassl_conn_io_send() 434 return ret; in nxt_cyassl_conn_io_send() [all …]
|
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_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_main.c | 17 nxt_int_t ret; in main() local 27 ret = nxt_runtime_create(&nxt_main_task); in main() 29 if (ret != NXT_OK) { in main()
|
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_cert.c | 122 if (ret == 0) { in nxt_cert_bio() 369 nxt_int_t ret; in nxt_cert_info_save() local 425 nxt_int_t ret; in nxt_cert_info_get() local 434 if (ret != NXT_OK) { in nxt_cert_info_get() 500 nxt_int_t ret; in nxt_cert_details() local 743 nxt_int_t ret; in nxt_cert_alt_names_details() local 803 if (ret == NXT_OK) { in nxt_cert_info_delete() 808 return ret; in nxt_cert_info_delete() 820 nxt_int_t ret; in nxt_cert_store_load() local 957 nxt_int_t ret; [all …]
|
H A D | nxt_buf_filter.c | 35 nxt_int_t ret; in nxt_buf_filter() local 103 ret = NXT_OK; in nxt_buf_filter() 115 ret = f->run->filter_sync_last(f); in nxt_buf_filter() 117 f->done = (ret == NXT_OK); in nxt_buf_filter() 120 if (nxt_fast_path(ret == NXT_OK)) { in nxt_buf_filter() 132 ret = f->run->filter_process(f); in nxt_buf_filter() 134 if (nxt_fast_path(ret == NXT_OK)) { in nxt_buf_filter() 150 if (nxt_slow_path(ret == NXT_ERROR)) { in nxt_buf_filter() 257 nxt_int_t ret; in nxt_buf_filter_file_read() local 288 if (nxt_fast_path(ret == NXT_OK)) { in nxt_buf_filter_file_read() [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_pcre.c | 122 int ret; in nxt_regex_match() local 124 ret = pcre_exec(re->code, re->extra, (const char *) subject, length, 0, 0, in nxt_regex_match() 126 if (nxt_slow_path(ret < PCRE_ERROR_NOMATCH)) { in nxt_regex_match() 129 ret, length, subject, &re->pattern); in nxt_regex_match() 134 return (ret != PCRE_ERROR_NOMATCH); in nxt_regex_match()
|
H A D | nxt_runtime.c | 50 nxt_int_t ret; in nxt_runtime_create() local 100 if (nxt_slow_path(ret != NXT_OK)) { in nxt_runtime_create() 318 nxt_int_t ret; in nxt_runtime_thread_pools() local 377 nxt_int_t ret; in nxt_runtime_initial_start() local 404 if (ret != NXT_OK) { in nxt_runtime_initial_start() 410 if (ret != NXT_OK) { in nxt_runtime_initial_start() 1208 nxt_int_t ret; in nxt_runtime_log_file_add() local 1247 nxt_int_t ret; in nxt_runtime_log_files_create() local 1255 if (ret != NXT_OK) { in nxt_runtime_log_files_create() 1270 nxt_int_t ret; in nxt_runtime_listen_sockets_create() local [all …]
|
H A D | nxt_socket.c | 195 nxt_int_t ret; in nxt_socket_connect() local 223 ret = NXT_DECLINED; in nxt_socket_connect() 232 ret = NXT_ERROR; in nxt_socket_connect() 237 ret = NXT_ERROR; in nxt_socket_connect() 243 return ret; in nxt_socket_connect() 320 int ret, err; in nxt_socket_error() local 329 ret = getsockopt(s, SOL_SOCKET, SO_ERROR, (void *) &err, &len); in nxt_socket_error() 331 if (nxt_slow_path(ret == -1)) { in nxt_socket_error()
|
/unit/src/test/ |
H A D | nxt_strverscmp_test.c | 21 nxt_int_t ret; in nxt_strverscmp_test() local 57 ret = nxt_strverscmp((u_char *) tests[i].v1, (u_char *) tests[i].v2); in nxt_strverscmp_test() 62 if (ret < 0) { in nxt_strverscmp_test() 69 if (ret == 0) { in nxt_strverscmp_test() 76 if (ret > 0) { in nxt_strverscmp_test() 85 tests[i].v1, tests[i].res, tests[i].v2, ret); in nxt_strverscmp_test()
|
H A D | nxt_base64_test.c | 13 ssize_t ret; in nxt_base64_test() local 73 ret = nxt_base64_decode(NULL, tests[i].enc.start, tests[i].enc.length); in nxt_base64_test() 75 if (ret == NXT_ERROR && tests[i].dec.start == NULL) { in nxt_base64_test() 79 if ((size_t) ret != tests[i].dec.length) { in nxt_base64_test() 83 &tests[i].enc, ret, tests[i].dec.length); in nxt_base64_test() 87 ret = nxt_base64_decode(buf, tests[i].enc.start, tests[i].enc.length); in nxt_base64_test() 89 if (!nxt_str_eq(&tests[i].dec, buf, (size_t) ret)) { in nxt_base64_test()
|
H A D | nxt_clone_test.c | 430 nxt_int_t ret; in nxt_clone_creds_test() local 464 ret = nxt_clone_test_mappings(task, mp, &ctx, &testcases[i]); in nxt_clone_creds_test() 466 if (ret != NXT_OK) { in nxt_clone_creds_test() 471 ret = NXT_OK; in nxt_clone_creds_test() 479 return ret; in nxt_clone_creds_test() 487 nxt_int_t ret; in nxt_clone_test_mappings() local 496 ret = nxt_clone_test_parse_map(task, &tc->map_data, &map); in nxt_clone_test_mappings() 497 if (ret != NXT_OK) { in nxt_clone_test_mappings() 535 nxt_int_t ret; in nxt_clone_test_map_assert() local 538 ret = nxt_clone_vldt_credential_uidmap(task, map, &tc->creds); in nxt_clone_test_map_assert() [all …]
|
H A D | nxt_utf8_file_name_test.c | 46 nxt_int_t ret; in nxt_utf8_file_name_test() local 112 ret = nxt_file_open(&task, &uc_file, NXT_FILE_WRONLY, NXT_FILE_TRUNCATE, in nxt_utf8_file_name_test() 114 if (ret != NXT_OK) { in nxt_utf8_file_name_test() 124 ret = nxt_file_open(&task, &lc_file, NXT_FILE_RDONLY, NXT_FILE_OPEN, in nxt_utf8_file_name_test() 127 if (ret == NXT_OK) { in nxt_utf8_file_name_test()
|
H A D | nxt_sprintf_test.c | 45 nxt_int_t ret; in nxt_sprintf_test() local 55 ret = nxt_sprintf_test_double(buf, end, double_test[i].format, in nxt_sprintf_test() 59 if (ret == NXT_OK) { in nxt_sprintf_test()
|
/unit/test/python/ns_inspect/ |
H A D | wsgi.py | 13 ret = { 19 ret['FileExists'] = os.path.exists(d.get('path')[0]) 21 out = json.dumps(ret)
|