Home
last modified time | relevance | path

Searched refs:ret (Results 1 – 25 of 76) sorted by path

1234

/unit/auto/
H A Dshmem22 int ret;
32 ret = (access(name, F_OK) == 0);
35 return ret;
/unit/src/nodejs/unit-http/
H A Dhttp_server.js101 const ret = Object.create(null);
109 ret[key] = this.headers[key][1];
113 return ret;
H A Dunit.cpp783 int ret; in response_send_headers() local
817 if (ret != NXT_UNIT_OK) { in response_send_headers()
917 ret = nxt_unit_response_send(req); in response_send_headers()
918 if (ret != NXT_UNIT_OK) { in response_send_headers()
930 int ret; in response_write() local
976 ret = nxt_unit_buf_send(buf); in response_write()
977 if (ret == NXT_UNIT_OK) { in response_write()
991 ret = res_len < 0 ? -res_len : (int) NXT_UNIT_OK; in response_write()
994 if (ret != NXT_UNIT_OK) { in response_write()
1040 int ret, iovec_len; in websocket_send_frame() local
[all …]
/unit/src/
H A Dnxt_application.c161 nxt_int_t ret; in nxt_discovery_start() local
207 nxt_int_t ret; in nxt_discovery_modules() local
224 if (ret != 0) { in nxt_discovery_modules()
239 if (ret != NXT_OK) { in nxt_discovery_modules()
333 nxt_int_t ret; in nxt_discovery_module() local
346 ret = NXT_ERROR; in nxt_discovery_module()
466 ret = NXT_OK; in nxt_discovery_module()
474 return ret; in nxt_discovery_module()
539 return ret; in nxt_proto_setup()
548 return ret; in nxt_proto_setup()
[all …]
H A Dnxt_buf_filter.c35 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 Dnxt_cache.c179 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 Dnxt_cert.c122 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 Dnxt_clone.c139 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()
H A Dnxt_conf.c440 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 Dnxt_conf_validation.c549 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 Dnxt_conn.c134 int ret; in nxt_conn_local_addr() local
169 ret = getsockname(c->socket.fd, &sa->u.sockaddr, &socklen); in nxt_conn_local_addr()
170 if (nxt_slow_path(ret != 0)) { in nxt_conn_local_addr()
H A Dnxt_conn.h195 nxt_int_t ret; \
198 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \
201 (c)->tcp_nodelay = (ret == NXT_OK); \
210 nxt_int_t ret; \
212 ret = nxt_socket_setsockopt(task, (c)->socket.fd, IPPROTO_TCP, \
215 (c)->tcp_nodelay = (ret == NXT_OK); \
H A Dnxt_conn_close.c21 int ret; in nxt_conn_close() local
45 ret = setsockopt(c->socket.fd, SOL_SOCKET, SO_LINGER, &linger_off, in nxt_conn_close()
48 if (nxt_slow_path(ret != 0)) { in nxt_conn_close()
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_controller.c160 nxt_int_t ret, num; in nxt_controller_prefork() local
181 if (ret == NXT_OK) { in nxt_controller_prefork()
187 if (ret == NXT_OK) { in nxt_controller_prefork()
219 nxt_int_t ret; in nxt_controller_file_read() local
229 if (ret == NXT_OK) { in nxt_controller_file_read()
291 nxt_int_t ret; in nxt_controller_start() local
301 if (nxt_slow_path(ret != NXT_OK)) { in nxt_controller_start()
348 ret = nxt_conf_validate(&vldt); in nxt_controller_start()
350 if (nxt_slow_path(ret != NXT_OK)) { in nxt_controller_start()
352 if (ret == NXT_DECLINED) { in nxt_controller_start()
[all …]
H A Dnxt_credential.c183 nxt_int_t ret; in nxt_credential_groups_get() local
210 ret = NXT_ERROR; in nxt_credential_groups_get()
227 ret = NXT_OK; in nxt_credential_groups_get()
262 ret = NXT_OK; in nxt_credential_groups_get()
268 ret = NXT_ERROR; in nxt_credential_groups_get()
275 return ret; in nxt_credential_groups_get()
H A Dnxt_cyassl.c43 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 Dnxt_devpoll_engine.c397 nxt_int_t ret, retval; in nxt_devpoll_commit_changes() local
438 ret = nxt_devpoll_write(engine, write_changes, n); in nxt_devpoll_commit_changes()
440 if (nxt_slow_path(ret != NXT_OK)) { in nxt_devpoll_commit_changes()
456 ret = nxt_fd_event_hash_add(&engine->u.devpoll.fd_hash, ev->fd, ev); in nxt_devpoll_commit_changes()
458 if (nxt_slow_path(ret != NXT_OK)) { in nxt_devpoll_commit_changes()
H A Dnxt_epoll_engine.c611 int ret; in nxt_epoll_commit_changes() local
629 ret = epoll_ctl(engine->u.epoll.fd, change->op, ev->fd, &change->event); in nxt_epoll_commit_changes()
631 if (nxt_slow_path(ret != 0)) { in nxt_epoll_commit_changes()
756 int ret; in nxt_epoll_enable_post() local
777 ret = nxt_fd_nonblocking(&engine->task, engine->u.epoll.eventfd.fd); in nxt_epoll_enable_post()
778 if (nxt_slow_path(ret != NXT_OK)) { in nxt_epoll_enable_post()
793 ret = epoll_ctl(engine->u.epoll.fd, EPOLL_CTL_ADD, in nxt_epoll_enable_post()
796 if (nxt_fast_path(ret == 0)) { in nxt_epoll_enable_post()
849 size_t ret; in nxt_epoll_signal() local
859 ret = write(engine->u.epoll.eventfd.fd, &event, sizeof(uint64_t)); in nxt_epoll_signal()
[all …]
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_eventport_engine.c299 int ret, port; in nxt_eventport_commit_changes() local
321 ret = port_associate(port, PORT_SOURCE_FD, in nxt_eventport_commit_changes()
324 if (nxt_fast_path(ret == 0)) { in nxt_eventport_commit_changes()
334 ret = port_dissociate(port, PORT_SOURCE_FD, ev->fd); in nxt_eventport_commit_changes()
336 if (nxt_fast_path(ret == 0)) { in nxt_eventport_commit_changes()
H A Dnxt_fastcgi_record_parse.c24 nxt_int_t ret, stream; in nxt_fastcgi_record_parse() local
73 ret = nxt_fastcgi_buffer(fp, &tail[stream], b); in nxt_fastcgi_record_parse()
75 if (ret == NXT_FASTCGI_DATA_MIDDLE) { in nxt_fastcgi_record_parse()
79 if (nxt_slow_path(ret == NXT_ERROR)) { in nxt_fastcgi_record_parse()
91 if (ret == NXT_FASTCGI_DATA_END_ON_BORDER) { in nxt_fastcgi_record_parse()
H A Dnxt_fastcgi_source.c199 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 Dnxt_fd_event.c35 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 Dnxt_fiber.c43 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()

1234