Lines Matching refs:rc

429     int              rc, queue_fd, shared_queue_fd;  in nxt_unit_init()  local
469 rc = nxt_unit_read_env(&ready_port, &router_port, &read_port, in nxt_unit_init()
473 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_init()
491 rc = nxt_unit_fd_blocking(router_port.out_fd); in nxt_unit_init()
492 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_init()
519 rc = nxt_unit_fd_blocking(read_port.in_fd); in nxt_unit_init()
520 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_init()
531 rc = nxt_unit_fd_blocking(ready_port.out_fd); in nxt_unit_init()
532 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_init()
557 rc = nxt_unit_ready(ctx, ready_port.out_fd, ready_stream, queue_fd); in nxt_unit_init()
558 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_init()
588 int rc; in nxt_unit_create() local
605 rc = pthread_mutex_init(&lib->mutex, NULL); in nxt_unit_create()
606 if (nxt_slow_path(rc != 0)) { in nxt_unit_create()
607 nxt_unit_alert(NULL, "failed to initialize mutex (%d)", rc); in nxt_unit_create()
632 rc = nxt_unit_ctx_init(lib, &lib->main_ctx, init->ctx_data); in nxt_unit_create()
633 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_create()
637 rc = nxt_unit_mmaps_init(&lib->incoming); in nxt_unit_create()
638 if (nxt_slow_path(rc != 0)) { in nxt_unit_create()
639 nxt_unit_alert(NULL, "failed to initialize mutex (%d)", rc); in nxt_unit_create()
644 rc = nxt_unit_mmaps_init(&lib->outgoing); in nxt_unit_create()
645 if (nxt_slow_path(rc != 0)) { in nxt_unit_create()
646 nxt_unit_alert(NULL, "failed to initialize mutex (%d)", rc); in nxt_unit_create()
673 int rc; in nxt_unit_ctx_init() local
678 rc = pthread_mutex_init(&ctx_impl->mutex, NULL); in nxt_unit_ctx_init()
679 if (nxt_slow_path(rc != 0)) { in nxt_unit_ctx_init()
680 nxt_unit_alert(NULL, "failed to initialize mutex (%d)", rc); in nxt_unit_ctx_init()
849 int rc; in nxt_unit_read_env() local
874 rc = version_length != nxt_length(NXT_VERSION) in nxt_unit_read_env()
877 if (nxt_slow_path(rc != 0)) { in nxt_unit_read_env()
887 rc = sscanf(vars, in nxt_unit_read_env()
901 if (nxt_slow_path(rc == EOF)) { in nxt_unit_read_env()
908 if (nxt_slow_path(rc != 16)) { in nxt_unit_read_env()
910 "found %d of %d in %s", NXT_UNIT_INIT_ENV, rc, 16, vars); in nxt_unit_read_env()
976 int rc; in nxt_unit_process_msg() local
989 rc = nxt_socket_msg_oob_get_fds(&rbuf->oob, recv_msg.fd); in nxt_unit_process_msg()
990 if (nxt_slow_path(rc != NXT_OK)) { in nxt_unit_process_msg()
992 rc = NXT_UNIT_ERROR; in nxt_unit_process_msg()
1001 rc = NXT_UNIT_OK; in nxt_unit_process_msg()
1007 rc = NXT_UNIT_ERROR; in nxt_unit_process_msg()
1029 rc = NXT_UNIT_ERROR; in nxt_unit_process_msg()
1037 rc = NXT_UNIT_ERROR; in nxt_unit_process_msg()
1042 rc = nxt_unit_mmap_read(ctx, &recv_msg, rbuf); in nxt_unit_process_msg()
1044 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_process_msg()
1045 if (rc == NXT_UNIT_AGAIN) { in nxt_unit_process_msg()
1057 rc = NXT_UNIT_OK; in nxt_unit_process_msg()
1073 rc = NXT_UNIT_OK; in nxt_unit_process_msg()
1077 rc = nxt_unit_process_new_port(ctx, &recv_msg); in nxt_unit_process_msg()
1081 rc = nxt_unit_ctx_ready(ctx); in nxt_unit_process_msg()
1093 rc = NXT_UNIT_ERROR; in nxt_unit_process_msg()
1097 rc = NXT_UNIT_OK; in nxt_unit_process_msg()
1105 rc = NXT_UNIT_ERROR; in nxt_unit_process_msg()
1109 rc = nxt_unit_incoming_mmap(ctx, port_msg->pid, recv_msg.fd[0]); in nxt_unit_process_msg()
1113 rc = nxt_unit_process_req_headers(ctx, &recv_msg, preq); in nxt_unit_process_msg()
1117 rc = nxt_unit_process_req_body(ctx, &recv_msg); in nxt_unit_process_msg()
1121 rc = nxt_unit_process_websocket(ctx, &recv_msg); in nxt_unit_process_msg()
1130 rc = NXT_UNIT_ERROR; in nxt_unit_process_msg()
1141 rc = NXT_UNIT_OK; in nxt_unit_process_msg()
1145 rc = nxt_unit_process_shm_ack(ctx); in nxt_unit_process_msg()
1152 rc = NXT_UNIT_ERROR; in nxt_unit_process_msg()
1170 if (nxt_fast_path(rc != NXT_UNIT_AGAIN)) { in nxt_unit_process_msg()
1177 return rc; in nxt_unit_process_msg()
2349 int rc; in nxt_unit_response_send() local
2378 rc = nxt_unit_mmap_buf_send(req, mmap_buf, 0); in nxt_unit_response_send()
2379 if (nxt_fast_path(rc == NXT_UNIT_OK)) { in nxt_unit_response_send()
2387 return rc; in nxt_unit_response_send()
2405 int rc; in nxt_unit_response_buf_alloc() local
2431 rc = nxt_unit_get_outgoing_buf(req->ctx, req->response_port, in nxt_unit_response_buf_alloc()
2434 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_buf_alloc()
2504 int rc; in nxt_unit_response_upgrade() local
2527 rc = nxt_unit_request_hash_add(req->ctx, req); in nxt_unit_response_upgrade()
2528 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_upgrade()
2567 int rc; in nxt_unit_buf_send() local
2593 rc = nxt_unit_mmap_buf_send(req, mmap_buf, 0); in nxt_unit_buf_send()
2594 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_buf_send()
2595 return rc; in nxt_unit_buf_send()
2608 int rc; in nxt_unit_buf_send_done() local
2616 rc = nxt_unit_mmap_buf_send(req, mmap_buf, 1); in nxt_unit_buf_send_done()
2617 if (nxt_slow_path(rc == NXT_UNIT_OK)) { in nxt_unit_buf_send_done()
2623 nxt_unit_request_done(req, rc); in nxt_unit_buf_send_done()
2637 int rc; in nxt_unit_mmap_buf_send() local
2663 rc = NXT_UNIT_ERROR; in nxt_unit_mmap_buf_send()
2736 rc = NXT_UNIT_OK; in nxt_unit_mmap_buf_send()
2742 return rc; in nxt_unit_mmap_buf_send()
2889 int rc; in nxt_unit_response_write_nb() local
2915 rc = nxt_unit_response_add_content(req, part_start, part_size); in nxt_unit_response_write_nb()
2916 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_write_nb()
2917 return -rc; in nxt_unit_response_write_nb()
2920 rc = nxt_unit_response_send(req); in nxt_unit_response_write_nb()
2921 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_write_nb()
2922 return -rc; in nxt_unit_response_write_nb()
2937 rc = nxt_unit_get_outgoing_buf(req->ctx, req->response_port, part_size, in nxt_unit_response_write_nb()
2939 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_write_nb()
2940 return -rc; in nxt_unit_response_write_nb()
2952 rc = nxt_unit_mmap_buf_send(req, &mmap_buf, 0); in nxt_unit_response_write_nb()
2953 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_write_nb()
2954 return -rc; in nxt_unit_response_write_nb()
2972 int rc; in nxt_unit_response_write_cb() local
2992 rc = nxt_unit_response_add_content(req, "", 0); in nxt_unit_response_write_cb()
2993 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_write_cb()
2996 return rc; in nxt_unit_response_write_cb()
3018 rc = nxt_unit_response_send(req); in nxt_unit_response_write_cb()
3019 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_write_cb()
3022 return rc; in nxt_unit_response_write_cb()
3036 rc = nxt_unit_get_outgoing_buf(req->ctx, req->response_port, in nxt_unit_response_write_cb()
3039 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_write_cb()
3040 return rc; in nxt_unit_response_write_cb()
3058 rc = nxt_unit_mmap_buf_send(req, &mmap_buf, 0); in nxt_unit_response_write_cb()
3059 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_response_write_cb()
3062 return rc; in nxt_unit_response_write_cb()
3258 nxt_unit_request_done(nxt_unit_request_info_t *req, int rc) in nxt_unit_request_done() argument
3267 nxt_unit_req_debug(req, "done: %d", rc); in nxt_unit_request_done()
3269 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_request_done()
3277 rc = nxt_unit_response_init(req, 200, 1, size); in nxt_unit_request_done()
3278 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_request_done()
3282 rc = nxt_unit_response_add_field(req, "Content-Type", in nxt_unit_request_done()
3285 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_request_done()
3306 msg.type = (rc == NXT_UNIT_OK) ? _NXT_PORT_MSG_DATA in nxt_unit_request_done()
3334 int i, rc; in nxt_unit_websocket_sendv() local
3352 rc = nxt_unit_get_outgoing_buf(req->ctx, req->response_port, in nxt_unit_websocket_sendv()
3355 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_websocket_sendv()
3356 return rc; in nxt_unit_websocket_sendv()
3386 rc = nxt_unit_mmap_buf_send(req, &mmap_buf, 0); in nxt_unit_websocket_sendv()
3388 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_websocket_sendv()
3389 return rc; in nxt_unit_websocket_sendv()
3395 rc = nxt_unit_get_outgoing_buf(req->ctx, req->response_port, in nxt_unit_websocket_sendv()
3398 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_websocket_sendv()
3399 return rc; in nxt_unit_websocket_sendv()
3408 rc = nxt_unit_mmap_buf_send(req, &mmap_buf, 0); in nxt_unit_websocket_sendv()
3411 return rc; in nxt_unit_websocket_sendv()
3747 int i, fd, rc; in nxt_unit_new_mmap() local
3800 rc = nxt_unit_send_mmap(ctx, port, fd); in nxt_unit_new_mmap()
3801 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_new_mmap()
4001 int rc; in nxt_unit_incoming_mmap() local
4054 rc = NXT_UNIT_ERROR; in nxt_unit_incoming_mmap()
4064 rc = NXT_UNIT_OK; in nxt_unit_incoming_mmap()
4085 return rc; in nxt_unit_incoming_mmap()
4502 int rc; in nxt_unit_process_find() local
4508 rc = nxt_lvlhsh_delete(&lib->processes, &lhq); in nxt_unit_process_find()
4511 rc = nxt_lvlhsh_find(&lib->processes, &lhq); in nxt_unit_process_find()
4514 if (rc == NXT_OK) { in nxt_unit_process_find()
4536 int rc; in nxt_unit_run() local
4543 rc = NXT_UNIT_OK; in nxt_unit_run()
4546 rc = nxt_unit_run_once_impl(ctx); in nxt_unit_run()
4548 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_unit_run()
4556 return rc; in nxt_unit_run()
4563 int rc; in nxt_unit_run_once() local
4567 rc = nxt_unit_run_once_impl(ctx); in nxt_unit_run_once()
4571 return rc; in nxt_unit_run_once()
4578 int rc; in nxt_unit_run_once_impl() local
4586 rc = nxt_unit_read_buf(ctx, rbuf); in nxt_unit_run_once_impl()
4587 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_run_once_impl()
4590 return rc; in nxt_unit_run_once_impl()
4593 rc = nxt_unit_process_msg(ctx, rbuf, NULL); in nxt_unit_run_once_impl()
4594 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_unit_run_once_impl()
4598 rc = nxt_unit_process_pending_rbuf(ctx); in nxt_unit_run_once_impl()
4599 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_unit_run_once_impl()
4605 return rc; in nxt_unit_run_once_impl()
4739 int rc; in nxt_unit_process_pending_rbuf() local
4761 rc = NXT_UNIT_OK; in nxt_unit_process_pending_rbuf()
4765 if (nxt_fast_path(rc != NXT_UNIT_ERROR)) { in nxt_unit_process_pending_rbuf()
4766 rc = nxt_unit_process_msg(&ctx_impl->ctx, rbuf, NULL); in nxt_unit_process_pending_rbuf()
4778 return rc; in nxt_unit_process_pending_rbuf()
4853 int rc; in nxt_unit_run_ctx() local
4861 rc = NXT_UNIT_OK; in nxt_unit_run_ctx()
4866 rc = NXT_UNIT_ERROR; in nxt_unit_run_ctx()
4872 rc = nxt_unit_ctx_port_recv(ctx, ctx_impl->read_port, rbuf); in nxt_unit_run_ctx()
4873 if (rc == NXT_UNIT_AGAIN) { in nxt_unit_run_ctx()
4877 rc = nxt_unit_process_msg(ctx, rbuf, NULL); in nxt_unit_run_ctx()
4878 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_unit_run_ctx()
4882 rc = nxt_unit_process_pending_rbuf(ctx); in nxt_unit_run_ctx()
4883 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_unit_run_ctx()
4892 return rc; in nxt_unit_run_ctx()
4955 int rc; in nxt_unit_run_shared() local
4963 rc = NXT_UNIT_OK; in nxt_unit_run_shared()
4968 rc = NXT_UNIT_ERROR; in nxt_unit_run_shared()
4974 rc = nxt_unit_shared_port_recv(ctx, lib->shared_port, rbuf); in nxt_unit_run_shared()
4975 if (rc == NXT_UNIT_AGAIN) { in nxt_unit_run_shared()
4979 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_unit_run_shared()
4984 rc = nxt_unit_process_msg(ctx, rbuf, NULL); in nxt_unit_run_shared()
4985 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_unit_run_shared()
4992 return rc; in nxt_unit_run_shared()
4999 int rc; in nxt_unit_dequeue_request() local
5019 rc = nxt_unit_app_queue_recv(ctx, lib->shared_port, rbuf); in nxt_unit_dequeue_request()
5020 if (rc != NXT_UNIT_OK) { in nxt_unit_dequeue_request()
5038 int rc; in nxt_unit_process_port_msg() local
5042 rc = nxt_unit_process_port_msg_impl(ctx, port); in nxt_unit_process_port_msg()
5046 return rc; in nxt_unit_process_port_msg()
5053 int rc; in nxt_unit_process_port_msg_impl() local
5069 rc = nxt_unit_shared_port_recv(ctx, port, rbuf); in nxt_unit_process_port_msg_impl()
5072 rc = nxt_unit_ctx_port_recv(ctx, port, rbuf); in nxt_unit_process_port_msg_impl()
5075 if (rc != NXT_UNIT_OK) { in nxt_unit_process_port_msg_impl()
5077 return rc; in nxt_unit_process_port_msg_impl()
5080 rc = nxt_unit_process_msg(ctx, rbuf, NULL); in nxt_unit_process_port_msg_impl()
5081 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_unit_process_port_msg_impl()
5085 rc = nxt_unit_process_pending_rbuf(ctx); in nxt_unit_process_port_msg_impl()
5086 if (nxt_slow_path(rc == NXT_UNIT_ERROR)) { in nxt_unit_process_port_msg_impl()
5092 return rc; in nxt_unit_process_port_msg_impl()
5106 int rc, queue_fd; in nxt_unit_ctx_alloc() local
5123 rc = nxt_unit_ctx_init(lib, new_ctx, data); in nxt_unit_ctx_alloc()
5124 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_ctx_alloc()
5158 rc = nxt_unit_send_port(&new_ctx->ctx, lib->router_port, port, queue_fd); in nxt_unit_ctx_alloc()
5159 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_ctx_alloc()
5275 int rc, port_sockets[2]; in nxt_unit_create_port() local
5282 rc = socketpair(AF_UNIX, NXT_UNIX_SOCKET, 0, port_sockets); in nxt_unit_create_port()
5283 if (nxt_slow_path(rc != 0)) { in nxt_unit_create_port()
5434 int rc, ready; in nxt_unit_add_port() local
5553 rc = nxt_unit_port_hash_add(&lib->ports, &new_port->port); in nxt_unit_add_port()
5554 if (nxt_slow_path(rc != NXT_UNIT_OK)) { in nxt_unit_add_port()
5908 nxt_int_t rc; in nxt_unit_port_send() local
5919 rc = nxt_port_queue_send(port_impl->queue, buf, buf_size, &notify); in nxt_unit_port_send()
5920 if (nxt_slow_path(rc != NXT_OK)) { in nxt_unit_port_send()
5961 rc = nxt_port_queue_send(port_impl->queue, &msg.type, 1, &notify); in nxt_unit_port_send()
5962 if (nxt_slow_path(rc != NXT_OK)) { in nxt_unit_port_send()