Lines Matching refs:stream
594 uint32_t stream; in nxt_controller_conf_send() local
635 stream = nxt_port_rpc_register_handler(task, controller_port, in nxt_controller_conf_send()
638 if (nxt_slow_path(stream == 0)) { in nxt_controller_conf_send()
644 fd, stream, controller_port->id, b); in nxt_controller_conf_send()
647 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_conf_send()
1570 uint32_t stream; in nxt_controller_process_status() local
1590 stream = nxt_port_rpc_register_handler(task, controller_port, in nxt_controller_process_status()
1594 if (nxt_slow_path(stream == 0)) { in nxt_controller_process_status()
1599 -1, stream, controller_port->id, NULL); in nxt_controller_process_status()
1602 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_process_status()
2280 uint32_t stream; in nxt_controller_process_control() local
2337 stream = nxt_port_rpc_register_handler(task, controller_port, in nxt_controller_process_control()
2341 if (nxt_slow_path(stream == 0)) { in nxt_controller_process_control()
2346 -1, stream, 0, b); in nxt_controller_process_control()
2348 nxt_port_rpc_cancel(task, controller_port, stream); in nxt_controller_process_control()