From 0afc61c9e61d62d57225860458aecd78190d9e44 Mon Sep 17 00:00:00 2001 From: totoro Date: Fri, 24 May 2019 10:20:15 +0900 Subject: [PATCH] remove some debug comment and manage the raw_mode --- net_services/CXM_generic_protocol.anubis | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/net_services/CXM_generic_protocol.anubis b/net_services/CXM_generic_protocol.anubis index b4d3635..37fb8b5 100644 --- a/net_services/CXM_generic_protocol.anubis +++ b/net_services/CXM_generic_protocol.anubis @@ -197,7 +197,7 @@ public define Bool )= //create the target with target_file = tmp_path + "/" + f_ref.name, - println("NET_SERVICE get_file_ref for "+target_file); + //println("NET_SERVICE get_file_ref for "+target_file); with msg = message(_CXM_GET_FILE_REF), forget(add_message(msg, "GET_FILE_REF", to_Message(f_ref))); forget(mQ.add_Message_to_send(msg)); @@ -211,6 +211,7 @@ public define Bool error(_, _) then false, ok then false, //false because OK without result message is not allowed ok_msg(rmsg) then + //println("get_file_ref wait_for_reply _CXM_GET_FILE_REF OK"); with size = if find_string(rmsg, "SIZE") is {failure then f_ref.size, success(size_str) then if decimal_scan(size_str) is { failure then should_not_happen(0), success(_size_) then _size_}}, with mode = find_string(rmsg, "MODE", "NEW"), if mode = "APPEND" then @@ -219,6 +220,7 @@ public define Bool failure then println("can't create target file"+target_file);false, //nothing to write success(target) then with buffer = mQ.raw_mode_on(size), + //println("raw_more on buffer len "+length(buffer)+" buffer ["+to_string(buffer)+"]"); forget(flush(buffer, weaken(target))); if copy_file_to_Connection(mQ.get_connection(unique), file(target), size - length(buffer)) is { @@ -230,11 +232,14 @@ public define Bool if (Maybe(RWStream))file(target_file, append) is { failure then println("can't create target file"+target_file);false, //nothing to write - success(target) then + success(target) then + with buffer = mQ.raw_mode_on(size), + //println("raw_more on buffer len "+length(buffer)+" buffer ["+to_string(buffer)+"]"); + forget(flush(buffer, weaken(target))); if copy_file_to_Connection(mQ.get_connection(unique), file(target), size) is { - failure then false, - success(_) then true + failure then mQ.raw_mode_off(unique);false, + success(_) then mQ.raw_mode_off(unique);true } } } -- libgit2 0.21.4