summaryrefslogtreecommitdiffhomepage
path: root/src/nxt_port_rpc.c (follow)
AgeCommit message (Collapse)AuthorFilesLines
2019-02-25RPC error message size fixed.Max Romanov1-1/+1
In case of RPC error, special error message passed to handler. Field 'size' expected to be 0 in this case because in contains fake empty buffer.
2018-04-05Style.Valentin Bartenev1-0/+2
2018-04-04Style: capitalized letters in hexadecimal literals.Valentin Bartenev1-1/+1
2018-03-29Using nxt_lvlhsh_peek() and nxt_lvlhsh_retrieve().Igor Sysoev1-6/+1
2018-03-21Triggering RPC error for all handlers on port close.Max Romanov1-0/+38
This is required to avoid crashes and memory leaks on Unit exit.
2018-03-21Registered RPC handlers affects port use counters.Max Romanov1-0/+8
Service process port gets closed and released by runtime on process exit, but there can be active RPC handlers, which uses port structure.
2018-01-24Fixed formatting in nxt_sprintf() and logging.Sergey Kandaurov1-1/+1
2017-12-27Rescheduling of pending request after configured timeout.Max Romanov1-4/+0
New optional configuration parameter introduced: limits.reschedule_timeout. Default value 1 second. In the case when request is written to the port socket 'in advance', it is called 'pending'. On every completed request, the head of pending request is checked against reschedule timeout. If this request waiting for execution longer than timeout, it is cancelled, new port selected for this request.
2017-12-27Fixing application timeout.Max Romanov1-18/+37
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.
2017-09-15Introducing application timeout.Max Romanov1-73/+188
2017-09-06Style fixes.Igor Sysoev1-6/+10
2017-08-11RPC: peer pid special value -1 may be used if pid is unknown.Max Romanov1-36/+43
2017-08-02Port RPC interface introduced.Max Romanov1-0/+314
Usage: 1. Register handlers in incoming port with nxt_port_rpc_register_handler(). 2. Use return value as a stream identifier for next nxt_port_socket_write().