Anubis / Xlib

Commit 54906678d08d2a7ab773eee6ab95cdd77c7da2d6

Authored by Cédric RICARD
1 parent 90f8df96

Configurable timeout for netservice client

Showing 1 changed file with 4 additions and 2 deletions   Show diff stats
Inline Side-by-side
calexium_lib/net_services/CXM_generic_client.anubis
  Show/Hide comments   View file @5490667
@@ -66,12 +66,13 @@ define Maybe($T) @@ -66,12 +66,13 @@ define Maybe($T)
66 generic_handler 66 generic_handler
67 ( 67 (
68 MessageQueue queue, 68 MessageQueue queue,
  69 + Int32 timeout,
69 Message msg_to_send, 70 Message msg_to_send,
70 (Message) -> Maybe($T) handler, 71 (Message) -> Maybe($T) handler,
71 (String) -> One logger 72 (String) -> One logger
72 )= 73 )=
73 queue.add_Message_to_send(msg_to_send); 74 queue.add_Message_to_send(msg_to_send);
74 - if queue.get_next_received_Message(10) is 75 + if queue.get_next_received_Message(timeout) is
75 { 76 {
76 timeout then logger("["+queue.get_name(unique)+"]: receive timeout");failure, 77 timeout then logger("["+queue.get_name(unique)+"]: receive timeout");failure,
77 closed then logger("["+queue.get_name(unique)+"]: socket closed");failure, 78 closed then logger("["+queue.get_name(unique)+"]: socket closed");failure,
@@ -95,12 +96,13 @@ define Maybe($T) @@ -95,12 +96,13 @@ define Maybe($T)
95 public define (MessageQueue) -> Maybe($T) 96 public define (MessageQueue) -> Maybe($T)
96 make_generic_handler 97 make_generic_handler
97 ( 98 (
  99 + Int32 timeout,
98 Message msg_to_send, 100 Message msg_to_send,
99 (Message) -> Maybe($T) handler, 101 (Message) -> Maybe($T) handler,
100 (String) -> One logger 102 (String) -> One logger
101 ) = 103 ) =
102 (MessageQueue queue) |-> 104 (MessageQueue queue) |->
103 - generic_handler(queue, msg_to_send, handler, logger). 105 + generic_handler(queue, timeout, msg_to_send, handler, logger).
104 106
105 define Maybe($T) 107 define Maybe($T)
106 generic_request_for_service 108 generic_request_for_service