Home
last modified time | relevance | path

Searched refs:ret (Results 51 – 75 of 81) sorted by relevance

1234

/unit/src/
H A Dnxt_upstream.c23 nxt_int_t ret; in nxt_upstreams_create() local
61 ret = nxt_upstream_round_robin_create(task, tmcf, upcf, in nxt_upstreams_create()
63 if (nxt_slow_path(ret != NXT_OK)) { in nxt_upstreams_create()
H A Dnxt_var.c115 nxt_int_t ret; in nxt_var_ref_get() local
155 ret = nxt_http_unknown_var_ref(mp, ref, name); in nxt_var_ref_get()
156 if (nxt_slow_path(ret != NXT_OK)) { in nxt_var_ref_get()
221 nxt_int_t ret; in nxt_var_cache_value() local
248 ret = nxt_lvlhsh_insert(&cache->hash, &lhq); in nxt_var_cache_value()
249 if (nxt_slow_path(ret == NXT_ERROR)) { in nxt_var_cache_value()
253 if (ret == NXT_DECLINED) { in nxt_var_cache_value()
259 ret = ref->handler(task, value, ctx, ref->data); in nxt_var_cache_value()
260 if (nxt_slow_path(ret != NXT_OK)) { in nxt_var_cache_value()
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_job.c114 nxt_int_t ret; in nxt_job_start() local
121 ret = nxt_thread_pool_post(job->thread_pool, &job->work); in nxt_job_start()
123 if (ret == NXT_OK) { in nxt_job_start()
H A Dnxt_thread_pool.c61 nxt_int_t ret; in nxt_thread_pool_init() local
76 ret = NXT_OK; in nxt_thread_pool_init()
103 ret = NXT_ERROR; in nxt_thread_pool_init()
110 return ret; in nxt_thread_pool_init()
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_http_set_headers.c97 nxt_int_t ret; in nxt_http_set_headers() local
136 ret = nxt_tstr_query_init(&r->tstr_query, rtcf->tstr_state, in nxt_http_set_headers()
138 if (nxt_slow_path(ret != NXT_OK)) { in nxt_http_set_headers()
H A Dnxt_h1proto.c196 nxt_int_t ret; in nxt_h1p_init() local
207 return ret; in nxt_h1p_init()
562 ret = nxt_expect(NXT_DONE, ret); in nxt_h1p_conn_request_header_parse()
564 if (ret != NXT_AGAIN) { in nxt_h1p_conn_request_header_parse()
570 switch (ret) { in nxt_h1p_conn_request_header_parse()
604 status = ret; in nxt_h1p_conn_request_header_parse()
652 nxt_int_t ret; in nxt_h1p_header_process() local
670 return ret; in nxt_h1p_header_process()
709 return ret; in nxt_h1p_header_process()
2522 ret = nxt_expect(NXT_DONE, ret); in nxt_h1p_peer_header_read_done()
[all …]
H A Dnxt_controller.c178 nxt_int_t ret, num; in nxt_controller_prefork() local
199 if (ret == NXT_OK) { in nxt_controller_prefork()
205 if (ret == NXT_OK) { in nxt_controller_prefork()
244 nxt_int_t ret; in nxt_controller_file_read() local
254 if (ret == NXT_OK) { in nxt_controller_file_read()
316 nxt_int_t ret; in nxt_controller_start() local
326 if (nxt_slow_path(ret != NXT_OK)) { in nxt_controller_start()
380 ret = nxt_conf_validate(&vldt); in nxt_controller_start()
384 if (ret == NXT_DECLINED) { in nxt_controller_start()
1697 nxt_int_t ret; in nxt_controller_process_cert() local
[all …]
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_listen_socket.c39 int ret; in nxt_listen_socket_create() local
167 ret = connect(ts, &orig_sa->u.sockaddr, orig_sa->socklen); in nxt_listen_socket_create()
173 if (ret == 0) { in nxt_listen_socket_create()
H A Dnxt_sockaddr.c186 int ret; in nxt_getsockname() local
193 ret = getsockname(s, &sockaddr.buf, &socklen); in nxt_getsockname()
195 if (nxt_fast_path(ret == 0)) { in nxt_getsockname()
649 nxt_int_t ret, port; in nxt_sockaddr_inet6_parse() local
695 ret = nxt_inet6_addr(&sa->u.sockaddr_in6.sin6_addr, start, end - start); in nxt_sockaddr_inet6_parse()
696 if (nxt_slow_path(ret != NXT_OK)) { in nxt_sockaddr_inet6_parse()
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_http_parse.c1186 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 Dnxt_pollset_engine.c383 nxt_int_t ret, retval; in nxt_pollset_commit_changes() local
423 ret = nxt_pollset_write(engine, write_changes, n); in nxt_pollset_commit_changes()
425 if (nxt_slow_path(ret != NXT_OK)) { in nxt_pollset_commit_changes()
441 ret = nxt_fd_event_hash_add(&engine->u.pollset.fd_hash, ev->fd, ev); in nxt_pollset_commit_changes()
443 if (nxt_slow_path(ret != NXT_OK)) { in nxt_pollset_commit_changes()
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_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()
H A Dnxt_http_js.c165 njs_int_t ret; in nxt_http_js_ext_get_args() local
178 ret = njs_vm_query_string_parse(vm, r->args->start, in nxt_http_js_ext_get_args()
181 if (ret == NJS_ERROR) { in nxt_http_js_ext_get_args()
/unit/src/test/
H A Dnxt_lvlhsh_test.c96 nxt_int_t ret; in nxt_lvlhsh_test_delete() local
105 ret = nxt_lvlhsh_delete(lh, &lhq); in nxt_lvlhsh_test_delete()
107 if (ret != NXT_OK) { in nxt_lvlhsh_test_delete()
112 return ret; in nxt_lvlhsh_test_delete()
/unit/auto/
H A Dshmem22 int ret;
32 ret = (access(name, F_OK) == 0);
35 return ret;
/unit/src/python/
H A Dnxt_python_asgi_lifespan.c139 nxt_py_asgi_lifespan_t *lifespan, *ret; in nxt_py_asgi_lifespan_target_startup() local
153 ret = NULL; in nxt_py_asgi_lifespan_target_startup()
232 ret = lifespan; in nxt_py_asgi_lifespan_target_startup()
299 ret = lifespan; in nxt_py_asgi_lifespan_target_startup()
317 return (PyObject *) ret; in nxt_py_asgi_lifespan_target_startup()
324 nxt_int_t i, ret; in nxt_py_asgi_lifespan_shutdown() local
333 ret = nxt_py_asgi_lifespan_target_shutdown(lifespan); in nxt_py_asgi_lifespan_shutdown()
334 if (nxt_slow_path(ret != NXT_UNIT_OK)) { in nxt_py_asgi_lifespan_shutdown()
/unit/src/nodejs/unit-http/
H A Dunit.cpp790 int ret; in response_send_headers() local
824 if (ret != NXT_UNIT_OK) { in response_send_headers()
924 ret = nxt_unit_response_send(req); in response_send_headers()
925 if (ret != NXT_UNIT_OK) { in response_send_headers()
937 int ret; in response_write() local
983 ret = nxt_unit_buf_send(buf); in response_write()
984 if (ret == NXT_UNIT_OK) { in response_write()
998 ret = res_len < 0 ? -res_len : (int) NXT_UNIT_OK; in response_write()
1001 if (ret != NXT_UNIT_OK) { in response_write()
1047 int ret, iovec_len; in websocket_send_frame() local
[all …]
H A Dhttp_server.js110 const ret = Object.create(null);
118 ret[key] = this.headers[key][1];
122 return ret;
/unit/src/wasm/
H A Dnxt_wasm.c201 nxt_int_t ret; in nxt_wasm_start() local
208 ret = nxt_unit_default_init(task, &wasm_init, conf); in nxt_wasm_start()
209 if (nxt_slow_path(ret != NXT_OK)) { in nxt_wasm_start()
211 return ret; in nxt_wasm_start()
/unit/test/
H A Dtest_python_isolation.py75 ret = client.getjson(url='/?path=/app/python/ns_inspect')
77 assert ret['body']['FileExists'], 'application exists in rootfs'

1234