Lines Matching refs:data

76         timer.data = this;  in process_port_msg()
110 return (port_data_t *) handle->data; in get()
124 port_data_t *data; in timer_callback() local
126 data = get(handle); in timer_callback()
128 data->scheduled = false; in timer_callback()
129 if (data->stopped) { in timer_callback()
133 data->process_port_msg(); in timer_callback()
140 port_data_t *data; in delete_data() local
142 data = get(handle); in delete_data()
144 if (--data->ref_count <= 0) { in delete_data()
145 delete data; in delete_data()
268 unit_init.data = obj; in create_server()
306 obj = reinterpret_cast<Unit *>(req->unit->data); in request_handler_cb()
317 memset(req->data, 0, sizeof(req_data_t)); in request_handler()
349 obj = reinterpret_cast<Unit *>(ws->req->unit->data); in websocket_handler_cb()
361 req_data = (req_data_t *) ws->req->data; in websocket_handler()
392 obj = reinterpret_cast<Unit *>(req->unit->data); in close_handler_cb()
404 req_data = (req_data_t *) req->data; in close_handler()
441 obj = reinterpret_cast<Unit *>(ctx->unit->data); in shm_ack_handler_cb()
476 port_data_t *data; in add_port() local
486 obj = reinterpret_cast<Unit *>(ctx->unit->data); in add_port()
494 data = new port_data_t(ctx, port); in add_port()
496 err = uv_poll_init(loop, &data->poll, port->in_fd); in add_port()
499 delete data; in add_port()
503 err = uv_poll_start(&data->poll, UV_READABLE, in add_port()
507 delete data; in add_port()
511 port->data = data; in add_port()
513 data->ref_count++; in add_port()
514 data->poll.data = data; in add_port()
524 port_data_t *data; in remove_port() local
526 if (port->data != NULL && ctx != NULL) { in remove_port()
527 data = (port_data_t *) port->data; in remove_port()
529 data->stop(); in remove_port()
539 obj = reinterpret_cast<Unit *>(ctx->unit->data); in quit_cb()
656 req_data = (req_data_t *) req->data; in create_socket()
678 req_data = (req_data_t *) req->data; in create_request()
696 req_data = (req_data_t *) req->data; in create_response()
707 void *data; in create_websocket_frame() local
731 buffer = create_buffer((size_t) ws->content_length, &data); in create_websocket_frame()
732 nxt_unit_websocket_read(ws, data, ws->content_length); in create_websocket_frame()
743 void *data; in request_read() local
769 buffer = napi.create_buffer((size_t) wm, &data); in request_read()
770 nxt_unit_request_read(req, data, wm); in request_read()
1020 req_data = (req_data_t *) req->data; in response_end()
1125 req_data = (req_data_t *) req->data; in websocket_set_sock()