/unit/src/ |
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()
|
H A D | nxt_http_request.c | 70 nxt_int_t ret; in nxt_http_init() local 72 ret = nxt_h1p_init(task); in nxt_http_init() 74 if (ret != NXT_OK) { in nxt_http_init() 75 return ret; in nxt_http_init() 85 nxt_int_t ret; in nxt_http_request_host() local 104 return ret; in nxt_http_request_host() 310 nxt_int_t ret; in nxt_http_request_start() local 353 if (ret <= 0) { in nxt_http_request_forward() 560 nxt_int_t ret; in nxt_http_request_action() local 635 nxt_int_t ret; in nxt_http_request_header_send() local [all …]
|
H A D | nxt_http_rewrite.c | 32 nxt_int_t ret; in nxt_http_rewrite() local 50 ret = nxt_tstr_query_init(&r->tstr_query, rtcf->tstr_state, in nxt_http_rewrite() 52 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_rewrite() 70 ret = nxt_http_parse_complex_target(&rp); in nxt_http_rewrite() 71 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_rewrite()
|
H A D | nxt_router.c | 355 return ret; in nxt_router_start() 361 return ret; in nxt_router_start() 1931 return ret; in nxt_router_conf_create() 3265 nxt_int_t ret; in nxt_router_engine_conf_create() local 3270 return ret; in nxt_router_engine_conf_create() 3276 return ret; in nxt_router_engine_conf_create() 3279 return ret; in nxt_router_engine_conf_create() 3287 nxt_int_t ret; in nxt_router_engine_conf_update() local 3292 return ret; in nxt_router_engine_conf_update() 3306 return ret; in nxt_router_engine_conf_update() [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_router_access_log.c | 71 nxt_int_t ret; in nxt_router_access_log_create() local 90 ret = nxt_conf_map_object(rtcf->mem_pool, value, in nxt_router_access_log_create() 94 if (ret != NXT_OK) { in nxt_router_access_log_create() 169 nxt_int_t ret; in nxt_router_access_log_writer() local 188 ret = nxt_tstr_query_init(&r->tstr_query, rtcf->tstr_state, in nxt_router_access_log_writer() 190 if (nxt_slow_path(ret != NXT_OK)) { in nxt_router_access_log_writer() 228 nxt_int_t ret; in nxt_router_access_log_open() local 258 ret = nxt_port_socket_write(task, main_port, NXT_PORT_MSG_ACCESS_LOG, -1, in nxt_router_access_log_open() 261 if (nxt_slow_path(ret != NXT_OK)) { in nxt_router_access_log_open() 358 nxt_int_t ret; in nxt_router_access_log_reopen_handler() local [all …]
|
H A D | nxt_http_return.c | 52 conf->status = nxt_conf_get_number(acf->ret); in nxt_http_return_init() 78 nxt_int_t ret; in nxt_http_return() local 128 ret = nxt_tstr_query_init(&r->tstr_query, rtcf->tstr_state, in nxt_http_return() 130 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_return() 179 nxt_int_t ret; in nxt_http_return_send_ready() local 189 ret = nxt_http_return_encode(r->mem_pool, &ctx->encoded, in nxt_http_return_send_ready() 191 if (nxt_slow_path(ret == NXT_ERROR)) { in nxt_http_return_send_ready()
|
H A D | nxt_application.c | 168 nxt_int_t ret; in nxt_discovery_start() local 214 nxt_int_t ret; in nxt_discovery_modules() local 231 if (ret != 0) { in nxt_discovery_modules() 246 if (ret != NXT_OK) { in nxt_discovery_modules() 340 nxt_int_t ret; in nxt_discovery_module() local 353 ret = NXT_ERROR; in nxt_discovery_module() 473 ret = NXT_OK; in nxt_discovery_module() 481 return ret; in nxt_discovery_module() 546 return ret; in nxt_proto_setup() 555 return ret; in nxt_proto_setup() [all …]
|
H A D | nxt_clone.c | 125 nxt_int_t ret, len; in nxt_clone_credential_map_set() local 181 ret = nxt_clone_credential_map_write(task, mapfile, pid, mapinfo); in nxt_clone_credential_map_set() 185 return ret; in nxt_clone_credential_map_set() 193 nxt_int_t ret; in nxt_clone_credential_map() local 216 ret = nxt_clone_credential_map_set(task, "uid_map", pid, app_creds->uid, in nxt_clone_credential_map() 220 if (nxt_slow_path(ret != NXT_OK)) { in nxt_clone_credential_map() 224 ret = nxt_clone_credential_setgroups(task, pid, rule); in nxt_clone_credential_map() 225 if (nxt_slow_path(ret != NXT_OK)) { in nxt_clone_credential_map() 230 ret = nxt_clone_credential_map_set(task, "gid_map", pid, app_creds->base_gid, in nxt_clone_credential_map() 234 if (nxt_slow_path(ret != NXT_OK)) { in nxt_clone_credential_map()
|
H A D | nxt_tstr.c | 183 nxt_int_t ret; in nxt_tstr_state_done() local 185 ret = nxt_js_compile(state->jcf); in nxt_tstr_state_done() 186 if (nxt_slow_path(ret != NXT_OK)) { in nxt_tstr_state_done() 253 nxt_int_t ret; in nxt_tstr_query() local 265 ret = nxt_var_interpreter(task, query->state, &query->cache->var, in nxt_tstr_query() 269 if (nxt_slow_path(ret != NXT_OK)) { in nxt_tstr_query() 276 ret = nxt_js_call(task, query->state->jcf, &query->cache->js, in nxt_tstr_query() 279 if (nxt_slow_path(ret != NXT_OK)) { in nxt_tstr_query()
|
H A D | nxt_event_conn_job_sendfile.c | 98 ssize_t ret; in nxt_event_conn_job_sendfile_handler() local 113 ret = c->io->old_sendbuf(c, b, jbs->limit); in nxt_event_conn_job_sendfile_handler() 115 if (ret == NXT_AGAIN) { in nxt_event_conn_job_sendfile_handler() 119 if (nxt_slow_path(ret == NXT_ERROR)) { in nxt_event_conn_job_sendfile_handler() 123 jbs->sent += ret; in nxt_event_conn_job_sendfile_handler() 124 jbs->limit -= ret; in nxt_event_conn_job_sendfile_handler() 126 b = nxt_sendbuf_update(b, ret); in nxt_event_conn_job_sendfile_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() 232 nxt_int_t ret; in nxt_http_static_iterate() local 308 nxt_int_t ret; in nxt_http_static_send_ready() local 363 if (ret == 0) { in nxt_http_static_send_ready() 401 ret = NXT_ERROR; in nxt_http_static_send_ready() 411 ret = NXT_OK; in nxt_http_static_send_ready() 437 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_static_send_ready() 508 ret = nxt_file_info(f, &fi); in nxt_http_static_send_ready() 509 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_static_send_ready() [all …]
|
H A D | nxt_conn_write.c | 19 ssize_t ret; in nxt_conn_io_write() local 58 ret = c->io->sendbuf(task, &sb); in nxt_conn_io_write() 63 if (ret < 0) { in nxt_conn_io_write() 68 sb.sent += ret; in nxt_conn_io_write() 69 sb.limit -= ret; in nxt_conn_io_write() 71 b = nxt_sendbuf_update(b, ret); in nxt_conn_io_write() 81 ret = NXT_AGAIN; in nxt_conn_io_write() 95 if (ret != NXT_ERROR) { in nxt_conn_io_write() 105 } else if (ret == NXT_AGAIN) { in nxt_conn_io_write() 121 if (ret == 0 || sb.sent != 0) { in nxt_conn_io_write() [all …]
|
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_poll_engine.c | 324 nxt_int_t ret, retval; in nxt_poll_commit_changes() local 343 if (nxt_fast_path(ret == NXT_OK)) { in nxt_poll_commit_changes() 352 if (nxt_fast_path(ret == NXT_OK)) { in nxt_poll_commit_changes() 359 ret = nxt_poll_set_delete(engine, ev->fd); in nxt_poll_commit_changes() 361 if (nxt_fast_path(ret == NXT_OK)) { in nxt_poll_commit_changes() 388 nxt_int_t ret; in nxt_poll_set_add() local 428 ret = nxt_lvlhsh_insert(&engine->u.poll.fd_hash, &lhq); in nxt_poll_set_add() 430 if (nxt_fast_path(ret == NXT_OK)) { in nxt_poll_set_add() 462 nxt_int_t ret; in nxt_poll_set_delete() local 473 ret = nxt_lvlhsh_delete(&engine->u.poll.fd_hash, &lhq); in nxt_poll_set_delete() [all …]
|
H A D | nxt_credential.c | 186 nxt_int_t ret; in nxt_credential_groups_get() local 213 ret = NXT_ERROR; in nxt_credential_groups_get() 230 ret = NXT_OK; in nxt_credential_groups_get() 265 ret = NXT_OK; in nxt_credential_groups_get() 271 ret = NXT_ERROR; in nxt_credential_groups_get() 278 return ret; in nxt_credential_groups_get()
|
H A D | nxt_fs_mount.c | 86 nxt_int_t ret; in nxt_fs_mount() local 192 ret = NXT_OK; in nxt_fs_mount() 196 ret = NXT_ERROR; in nxt_fs_mount() 203 return ret; in nxt_fs_mount()
|
H A D | nxt_file.c | 165 int ret; in nxt_file_read_ahead() local 168 ret = fcntl(file->fd, F_READAHEAD, (int) size); in nxt_file_read_ahead() 171 file->fd, size, ret); in nxt_file_read_ahead() 173 if (nxt_fast_path(ret != -1)) { in nxt_file_read_ahead() 227 int ret; in nxt_file_read_ahead() local 230 ret = fcntl(file->fd, F_RDAHEAD, 1); in nxt_file_read_ahead() 232 nxt_thread_log_debug("fcntl(%FD, F_RDAHEAD, 1): %d", file->fd, ret); in nxt_file_read_ahead() 234 if (nxt_fast_path(ret != -1)) { in nxt_file_read_ahead() 413 int ret; in nxt_file_rename() local 417 ret = rename((char *) old_name, (char *) new_name); in nxt_file_rename() [all …]
|
H A D | nxt_status.c | 16 nxt_int_t ret; in nxt_status_get() local 78 ret = nxt_conf_set_member_dup(apps, mp, &name, app_obj, i); in nxt_status_get() 79 if (nxt_slow_path(ret != NXT_OK)) { in nxt_status_get()
|
H A D | nxt_php_sapi.c | 376 nxt_int_t ret; in nxt_php_setup() local 458 nxt_int_t ret; in nxt_php_start() local 500 if (nxt_slow_path(ret != NXT_OK)) { in nxt_php_start() 502 return ret; in nxt_php_start() 529 nxt_int_t ret; in nxt_php_set_target() local 1044 nxt_int_t ret; in nxt_php_dynamic_request() local 1081 ret = stat(tpath, &sb); in nxt_php_dynamic_request() 1084 } else if (ret == -1) { in nxt_php_dynamic_request() 1121 if (nxt_slow_path(ret != NXT_OK)) { in nxt_php_dynamic_request() 1579 int ret; local [all …]
|
H A D | nxt_conn.h | 196 nxt_int_t ret; \ 199 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \ 202 (c)->tcp_nodelay = (ret == NXT_OK); \ 211 nxt_int_t ret; \ 213 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \ 216 (c)->tcp_nodelay = (ret == NXT_OK); \
|
H A D | nxt_semaphore.c | 199 nxt_int_t ret; in nxt_sem_post() local 205 ret = nxt_thread_cond_signal(&sem->cond); in nxt_sem_post() 211 return (nxt_thread_mutex_unlock(&sem->mutex) | ret); in nxt_sem_post()
|
/unit/src/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/ |
H A D | test_python_isolation_chroot.py | 27 ret = client.getjson(url='/?path=/app/python/ns_inspect') 29 assert ret['body']['FileExists'], 'application exists in rootfs'
|
/unit/src/python/ |
H A D | nxt_python.c | 80 nxt_int_t ret; in nxt_python3_init_config() local 83 ret = NXT_ERROR; in nxt_python3_init_config() 95 return ret; in nxt_python3_init_config() 119 ret = NXT_OK; in nxt_python3_init_config() 125 return ret; in nxt_python3_init_config() 154 nxt_int_t ret, n, i; in nxt_python_start() local 214 ret = nxt_python3_init_config(pep405); in nxt_python_start() 310 if (nxt_slow_path(ret != NXT_OK)) { in nxt_python_start() 525 int ret; in nxt_python_set_path() local 566 ret = PyList_Insert(sys, 0, path); in nxt_python_set_path() [all …]
|