Home
last modified time | relevance | path

Searched refs:outgoing (Results 1 – 4 of 4) sorted by relevance

/unit/src/
H A Dnxt_http_websocket.c70 buf = nxt_port_mmap_get_buf(task, &req_rpc_data->app->outgoing, in nxt_http_websocket_client()
H A Dnxt_router.h150 nxt_port_mmaps_t outgoing; member
H A Dnxt_unit.c373 nxt_unit_mmaps_t outgoing; member
643 nxt_unit_mmaps_init(&lib->outgoing); in nxt_unit_create()
778 nxt_unit_mmaps_destroy(&lib->outgoing); in nxt_unit_lib_release()
3488 pthread_mutex_lock(&lib->outgoing.mutex); in nxt_unit_mmap_get()
3492 outgoing_size = lib->outgoing.size; in nxt_unit_mmap_get()
3596 pthread_mutex_unlock(&lib->outgoing.mutex); in nxt_unit_mmap_get()
3740 mm = nxt_unit_mmap_at(&lib->outgoing, lib->outgoing.size); in nxt_unit_new_mmap()
3768 hdr->id = lib->outgoing.size - 1; in nxt_unit_new_mmap()
3783 pthread_mutex_unlock(&lib->outgoing.mutex); in nxt_unit_new_mmap()
3797 pthread_mutex_lock(&lib->outgoing.mutex); in nxt_unit_new_mmap()
[all …]
H A Dnxt_router.c1781 nxt_thread_mutex_create(&app->outgoing.mutex); in nxt_router_conf_create()
5194 nxt_port_mmaps_destroy(&app->outgoing, 1); in nxt_router_free_app()
5196 nxt_thread_mutex_destroy(&app->outgoing.mutex); in nxt_router_free_app()
5559 out = nxt_port_mmap_get_buf(task, &app->outgoing, in nxt_router_prepare_msg()
5745 buf = nxt_port_mmap_get_buf(task, &app->outgoing, free_size); in nxt_router_prepare_msg()
5933 mmaps = &port->app->outgoing; in nxt_router_get_mmap_handler()