From e7a0634a718ca1f2379f4694c17ef4219f5538fa Mon Sep 17 00:00:00 2001 From: Max Romanov Date: Fri, 23 Jun 2017 19:20:08 +0300 Subject: Application-side message processing. Usage on the router side: nxt_app_wmsg_t wmsg; nxt_app_parse_ctx_t parse_ctx; nxt_app_http_req_init(task, &parse_ctx); /* parse incoming request data */ if (nxt_app_http_req_parse(task, &parse_ctx, buf) == NXT_DONE) { /* choose app */ nxt_app = nxt_select_app(... &parse_ctx.r ...); /* find port */ wmsg.port = nxt_get_app_port(... nxt_app ...); wmsg.buf = &wmsg.write; /* fill write message buffer in shared mem */ nxt_app->prepare_msg(task, &parse_ctx.r, &wmsg); /* send message to app for processing */ nxt_port_socket_write(task, wmsg.port, NXT_PORT_MSG_DATA, -1, 0, 0, wmsg.write); } --- src/nxt_master_process.h | 1 + 1 file changed, 1 insertion(+) (limited to 'src/nxt_master_process.h') diff --git a/src/nxt_master_process.h b/src/nxt_master_process.h index 46c570be..ff84ca9f 100644 --- a/src/nxt_master_process.h +++ b/src/nxt_master_process.h @@ -17,6 +17,7 @@ nxt_int_t nxt_router_start(nxt_task_t *task, nxt_runtime_t *rt); extern nxt_port_handler_t nxt_worker_process_port_handlers[]; +extern nxt_port_handler_t nxt_app_process_port_handlers[]; extern const nxt_sig_event_t nxt_master_process_signals[]; extern const nxt_sig_event_t nxt_worker_process_signals[]; -- cgit