Home
last modified time | relevance | path

Searched refs:pm (Results 1 – 3 of 3) sorted by relevance

/unit/test/java/websockets_mirror/
H A Dapp.java54 public void echoPongMessage(PongMessage pm) { in echoPongMessage() argument
/unit/src/
H A Dnxt_port_socket.c18 static uint8_t nxt_port_enqueue_buf(nxt_task_t *task, nxt_port_msg_t *pm,
169 nxt_port_msg_t pm; in nxt_port_socket_write2() member
195 qmsg.pm = msg.port_msg; in nxt_port_socket_write2()
197 qmsg_size = sizeof(qmsg.pm); in nxt_port_socket_write2()
200 qmsg_size += nxt_port_enqueue_buf(task, &qmsg.pm, qmsg.buf, b); in nxt_port_socket_write2()
210 if (qmsg.pm.mmap) { in nxt_port_socket_write2()
269 nxt_port_enqueue_buf(nxt_task_t *task, nxt_port_msg_t *pm, void *qbuf, in nxt_port_enqueue_buf() argument
293 pm->mmap = 1; in nxt_port_enqueue_buf()
H A Dnxt_router.c5045 nxt_port_msg_t pm; in nxt_router_app_prepare_request() member
5090 msg.pm.stream = req_rpc_data->stream; in nxt_router_app_prepare_request()
5091 msg.pm.pid = reply_port->pid; in nxt_router_app_prepare_request()
5092 msg.pm.reply_port = reply_port->id; in nxt_router_app_prepare_request()
5093 msg.pm.type = NXT_PORT_MSG_REQ_HEADERS; in nxt_router_app_prepare_request()
5094 msg.pm.last = 0; in nxt_router_app_prepare_request()
5095 msg.pm.mmap = 1; in nxt_router_app_prepare_request()
5096 msg.pm.nf = 0; in nxt_router_app_prepare_request()
5097 msg.pm.mf = 0; in nxt_router_app_prepare_request()