Commit 787b867787a0a148f0192421b5df18989de41456

Authored by Cédric RICARD
1 parent 0af19e25

Fix for TIMESTAMP field handling

calexium_lib/net_services/CXM_generic_client.anubis
@@ -62,7 +62,7 @@ public define Maybe(NetServiceAnswer) @@ -62,7 +62,7 @@ public define Maybe(NetServiceAnswer)
62 } 62 }
63 }. 63 }.
64 64
65 -define Maybe($T) 65 +public define Maybe($T)
66 generic_handler 66 generic_handler
67 ( 67 (
68 MessageQueue queue, 68 MessageQueue queue,
@@ -131,7 +131,7 @@ define Maybe($T) @@ -131,7 +131,7 @@ define Maybe($T)
131 { 131 {
132 failure then logger("["+queue.get_name(unique)+"]: requesting service RESULT not found");failure, 132 failure then logger("["+queue.get_name(unique)+"]: requesting service RESULT not found");failure,
133 success(result) then 133 success(result) then
134 - with timestamp = if find_string(msg, "TIMESTAMP") is 134 + with timestamp = if find_string(result, "TIMESTAMP") is
135 { 135 {
136 failure then logger("["+queue.get_name(unique)+"]: requesting service TIMESTAMP not found"); "", 136 failure then logger("["+queue.get_name(unique)+"]: requesting service TIMESTAMP not found"); "",
137 success(timestamp) then timestamp 137 success(timestamp) then timestamp
calexium_lib/net_services/CXM_generic_protocol.anubis
@@ -17,7 +17,7 @@ read calexium_lib/CXM_message_constants.anubis @@ -17,7 +17,7 @@ read calexium_lib/CXM_message_constants.anubis
17 public define Int32 _CXM_OK = 0. 17 public define Int32 _CXM_OK = 0.
18 public define Int32 _CXM_ERROR = 1. 18 public define Int32 _CXM_ERROR = 1.
19 public define Int32 _CXM_UNKNOW_CMD = 2. 19 public define Int32 _CXM_UNKNOW_CMD = 2.
20 -public define Int32 _CXM_UNKNOW_SERVICE = 2. 20 +public define Int32 _CXM_UNKNOW_SERVICE = 3.
21 21
22 public type ProtocolResult: 22 public type ProtocolResult:
23 failure, 23 failure,
calexium_lib/web/CXM_multihost_http_server.anubis
@@ -2070,7 +2070,7 @@ define One @@ -2070,7 +2070,7 @@ define One
2070 with nr = length(ba), // get the number of bytes read 2070 with nr = length(ba), // get the number of bytes read
2071 if reliable_write(connection,ba) is 2071 if reliable_write(connection,ba) is
2072 { 2072 {
2073 - failure then log_journal_msg(desc,"Cannot write into connection.\n"), 2073 + failure then log_journal_msg(desc,"Cannot write into connection delirering '"+filename+"' (sent="+sent+"; size="+size+"; current="+nr+").\n"),
2074 success(nw) then 2074 success(nw) then
2075 send_file_body(desc,connection,file,size,sent+nw,filename) 2075 send_file_body(desc,connection,file,size,sent+nw,filename)
2076 } 2076 }