/unit/src/ |
H A D | nxt_upstream.c | 23 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 D | nxt_var.c | 115 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 D | nxt_conn_close.c | 21 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 D | nxt_job.c | 114 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 D | nxt_thread_pool.c | 61 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 D | nxt_conn.c | 134 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 D | nxt_http_set_headers.c | 97 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 D | nxt_h1proto.c | 196 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 D | nxt_controller.c | 178 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 D | nxt_epoll_engine.c | 611 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 D | nxt_listen_socket.c | 39 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 D | nxt_sockaddr.c | 186 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 D | nxt_eventport_engine.c | 299 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 D | nxt_http_parse.c | 1186 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 D | nxt_pollset_engine.c | 383 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 D | nxt_devpoll_engine.c | 397 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 D | nxt_fiber.c | 43 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 D | nxt_http_js.c | 165 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 D | nxt_lvlhsh_test.c | 96 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 D | shmem | 22 int ret; 32 ret = (access(name, F_OK) == 0); 35 return ret;
|
/unit/src/python/ |
H A D | nxt_python_asgi_lifespan.c | 139 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 D | unit.cpp | 790 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 D | http_server.js | 110 const ret = Object.create(null); 118 ret[key] = this.headers[key][1]; 122 return ret;
|
/unit/src/wasm/ |
H A D | nxt_wasm.c | 201 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 D | test_python_isolation.py | 75 ret = client.getjson(url='/?path=/app/python/ns_inspect') 77 assert ret['body']['FileExists'], 'application exists in rootfs'
|