From bef2ec483eaa525da770c024069b31320b63977e Mon Sep 17 00:00:00 2001 From: Max Romanov Date: Wed, 27 Dec 2017 17:47:18 +0300 Subject: Fixing application timeout. Application timeout limits maximum time of worker response in processing particular request. Not including the time required to start worker, time in request queue etc. --- src/nxt_port.h | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'src/nxt_port.h') diff --git a/src/nxt_port.h b/src/nxt_port.h index cf30bc92..74d37dcb 100644 --- a/src/nxt_port.h +++ b/src/nxt_port.h @@ -168,6 +168,7 @@ struct nxt_port_s { uint32_t app_pending_responses; uint32_t app_responses; + nxt_queue_t pending_requests; nxt_port_handler_t handler; nxt_port_handler_t *data; @@ -265,4 +266,9 @@ nxt_int_t nxt_port_post(nxt_task_t *task, nxt_port_t *port, nxt_port_post_handler_t handler, void *data); void nxt_port_use(nxt_task_t *task, nxt_port_t *port, int i); +nxt_inline void nxt_port_inc_use(nxt_port_t *port) +{ + nxt_atomic_fetch_add(&port->use_count, 1); +} + #endif /* _NXT_PORT_H_INCLUDED_ */ -- cgit