fix: duplicate closing files(OpenAtomFoundation#2304) (OpenAtomFoundation#2311)

chengyu-l · liuchengyu · web-flow · commit 77e87bb72572 · 2024-01-15T21:03:51.000+08:00
Co-authored-by: liuchengyu &lt;liuchengyu@360.cn&gt;
diff --git a/src/rsync_client.cc b/src/rsync_client.cc
@@ -166,7 +166,7 @@ Status RsyncClient::CopyRemoteFile(const std::string& filename, int index) {
     while (retries < max_retries_) {
       if (state_.load() != RUNNING) {
         break;
-        }
+      }
       size_t copy_file_begin_time = pstd::NowMicros();
       size_t count = Throttle::GetInstance().ThrottledByThroughput(kBytesPerRequest);
       if (count == 0) {
@@ -227,12 +227,7 @@ Status RsyncClient::CopyRemoteFile(const std::string& filename, int index) {
         s = writer->Fsync();
         if (!s.ok()) {
             return s;
-        }
-        s = writer->Close();
-        if (!s.ok()) {
-            return s;
-        }
-        writer.reset();
+        } 
         mu_.lock();
         meta_table_[filename] = "";
         mu_.unlock();
