1 2/* 3 * Copyright (C) Max Romanov 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#ifndef _NXT_PORT_RPC_H_INCLUDED_ 8#define _NXT_PORT_RPC_H_INCLUDED_ 9 10 11typedef void (*nxt_port_rpc_handler_t)(nxt_task_t *task, 12 nxt_port_recv_msg_t *msg, void *data); 13
| 1 2/* 3 * Copyright (C) Max Romanov 4 * Copyright (C) NGINX, Inc. 5 */ 6 7#ifndef _NXT_PORT_RPC_H_INCLUDED_ 8#define _NXT_PORT_RPC_H_INCLUDED_ 9 10 11typedef void (*nxt_port_rpc_handler_t)(nxt_task_t *task, 12 nxt_port_recv_msg_t *msg, void *data); 13
|
14uint32_t nxt_port_rpc_register_handler(nxt_task_t *task, nxt_port_t *port, 15 nxt_port_rpc_handler_t ready_handler, nxt_port_rpc_handler_t error_handler, 16 nxt_pid_t peer, void *data); 17void *nxt_port_rpc_register_handler_ex(nxt_task_t *task, nxt_port_t *port, 18 nxt_port_rpc_handler_t ready_handler, nxt_port_rpc_handler_t error_handler, 19 size_t ex_size); 20 21uint32_t nxt_port_rpc_ex_stream(void *ex);
--- 12 unchanged lines hidden --- | 16uint32_t nxt_port_rpc_register_handler(nxt_task_t *task, nxt_port_t *port, 17 nxt_port_rpc_handler_t ready_handler, nxt_port_rpc_handler_t error_handler, 18 nxt_pid_t peer, void *data); 19void *nxt_port_rpc_register_handler_ex(nxt_task_t *task, nxt_port_t *port, 20 nxt_port_rpc_handler_t ready_handler, nxt_port_rpc_handler_t error_handler, 21 size_t ex_size); 22 23uint32_t nxt_port_rpc_ex_stream(void *ex);
--- 12 unchanged lines hidden --- |