Home
last modified time | relevance | path

Searched refs:ret (Results 26 – 50 of 81) sorted by relevance

1234

/unit/src/
H A Dnxt_socket.c195 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 Dnxt_http_request.c70 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 Dnxt_http_rewrite.c32 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 Dnxt_router.c355 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 Dnxt_lvlhsh.c315 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 Dnxt_router_access_log.c71 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 Dnxt_http_return.c52 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 Dnxt_application.c168 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 Dnxt_clone.c125 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 Dnxt_tstr.c183 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 Dnxt_event_conn_job_sendfile.c98 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 Dnxt_http_static.c79 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 Dnxt_conn_write.c19 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 Dnxt_http_chunk_parse.c32 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 Dnxt_poll_engine.c324 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 Dnxt_credential.c186 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 Dnxt_fs_mount.c86 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 Dnxt_file.c165 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 Dnxt_status.c16 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 Dnxt_php_sapi.c376 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 Dnxt_conn.h196 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 Dnxt_semaphore.c199 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 Dnxt_sprintf_test.c45 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 Dtest_python_isolation_chroot.py27 ret = client.getjson(url='/?path=/app/python/ns_inspect')
29 assert ret['body']['FileExists'], 'application exists in rootfs'
/unit/src/python/
H A Dnxt_python.c80 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 …]

1234