Commit 27bccd14a1a0c2ced9bdc1eab4e18a9e5aecf884
1 parent
e6388e8b
remove some debug comment
Showing
1 changed file
with
6 additions
and
7 deletions
Show diff stats
net_services/CXM_generic_protocol.anubis
| @@ -246,17 +246,16 @@ public define Bool | @@ -246,17 +246,16 @@ public define Bool | ||
| 246 | MessageQueue mQ, | 246 | MessageQueue mQ, |
| 247 | Message msg, | 247 | Message msg, |
| 248 | )= | 248 | )= |
| 249 | - println("NET_SERVICE send_file_ref received *"); | 249 | + //println("NET_SERVICE send_file_ref received *"); |
| 250 | if *msg.what = _CXM_GET_FILE_REF then | 250 | if *msg.what = _CXM_GET_FILE_REF then |
| 251 | if find_message(msg, "GET_FILE_REF") is { | 251 | if find_message(msg, "GET_FILE_REF") is { |
| 252 | failure then println("NET_SERVICE send_file_ref: can't find GET_FILE_REF message"); false, | 252 | failure then println("NET_SERVICE send_file_ref: can't find GET_FILE_REF message"); false, |
| 253 | success(file_ref_obj_msg) then | 253 | success(file_ref_obj_msg) then |
| 254 | - println("NET_SERVICE send_file_ref: GET_FILE_REF message found"); | ||
| 255 | if (Maybe(File_ref))from_Message(file_ref_obj_msg) is | 254 | if (Maybe(File_ref))from_Message(file_ref_obj_msg) is |
| 256 | { | 255 | { |
| 257 | failure then println("NET_SERVICE send_file_ref: can't extract GET_FILE_REF message");false, | 256 | failure then println("NET_SERVICE send_file_ref: can't extract GET_FILE_REF message");false, |
| 258 | success(f_ref) then | 257 | success(f_ref) then |
| 259 | - println("NET_SERVICE send_file_ref: GET_FILE_REF message File_ref extracted\n"+dump(file_ref_obj_msg)); | 258 | + //println("NET_SERVICE send_file_ref: GET_FILE_REF message File_ref extracted\n"+dump(file_ref_obj_msg)); |
| 260 | //create the target | 259 | //create the target |
| 261 | with source_file = f_ref.path + "/" + f_ref.name, | 260 | with source_file = f_ref.path + "/" + f_ref.name, |
| 262 | with msg = message(0), | 261 | with msg = message(0), |
| @@ -265,16 +264,16 @@ public define Bool | @@ -265,16 +264,16 @@ public define Bool | ||
| 265 | println("source_file = "+source_file); | 264 | println("source_file = "+source_file); |
| 266 | println("size = "+size); | 265 | println("size = "+size); |
| 267 | forget(add_string(msg, "MODE", "NEW")); | 266 | forget(add_string(msg, "MODE", "NEW")); |
| 268 | - println("add MODE ok"); | ||
| 269 | forget(add_string(msg, "SIZE", to_String(size))); | 267 | forget(add_string(msg, "SIZE", to_String(size))); |
| 270 | - println("add SIZE ok"); | ||
| 271 | - println("NET_SERVICE send_file_ref: reply message \n"+dump(msg)); | 268 | + |
| 269 | + //println("NET_SERVICE send_file_ref: reply message \n"+dump(msg)); | ||
| 272 | if (Maybe(RStream))file(source_file, read) is | 270 | if (Maybe(RStream))file(source_file, read) is |
| 273 | { | 271 | { |
| 274 | failure then println("NET_SERVICE send_file_ref: can't open source file"+source_file);false, //nothing to write | 272 | failure then println("NET_SERVICE send_file_ref: can't open source file"+source_file);false, //nothing to write |
| 275 | success(source) then | 273 | success(source) then |
| 276 | - println("NET_SERVICE send_file_ref send ack file size "+size); | 274 | + //println("NET_SERVICE send_file_ref send ack file size "+size); |
| 277 | send_ACK_ok(mQ, _CXM_GET_FILE_REF, msg); | 275 | send_ACK_ok(mQ, _CXM_GET_FILE_REF, msg); |
| 276 | + //println("call flush_wait"); | ||
| 278 | mQ.flush_wait(unique); | 277 | mQ.flush_wait(unique); |
| 279 | if copy_file_to_Connection(file(source), mQ.get_connection(unique), size) is | 278 | if copy_file_to_Connection(file(source), mQ.get_connection(unique), size) is |
| 280 | { | 279 | { |