remove some debug comment and manage the raw_mode

David RENÉ
1 parent 27bccd14
Showing 1 changed file with 9 additions and 4 deletions Show diff stats
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
             }
         }
   }