[XrdEc] Reader: use bundled close.

xrootd · Jan 21, 2021 · 0c7e885 · 0c7e885
1 parent 0d3ff07
commit 0c7e885
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 1 deletion.
diff --git a/src/XrdCl/XrdClFileStateHandler.cc b/src/XrdCl/XrdClFileStateHandler.cc
@@ -712,6 +712,7 @@ namespace XrdCl
     pFollowRedirects( true ),
     pUseVirtRedirector( true ),
     pIsChannelEncrypted( false ),
+    pAllowBundledClose( false ),
     pReOpenHandler( 0 )
   {
     pFileHandle = new uint8_t[4];

diff --git a/src/XrdCl/XrdClZipArchive.hh b/src/XrdCl/XrdClZipArchive.hh
@@ -274,6 +274,14 @@ namespace XrdCl
         return openstage == Done;
       }
 
+      //-----------------------------------------------------------------------
+      //! Set property on the underlying File object
+      //-----------------------------------------------------------------------
+      inline bool SetProperty( const std::string &name, const std::string &value )
+      {
+        return archive.SetProperty( name, value );
+      }
+
     private:
 
       //-----------------------------------------------------------------------

diff --git a/src/XrdEc/XrdEcReader.cc b/src/XrdEc/XrdEcReader.cc
@@ -552,7 +552,11 @@ namespace XrdEc
     {
       auto &zipptr = itr->second;
       if( zipptr->IsOpen() )
-        closes.emplace_back( XrdCl::CloseArchive( *zipptr ) >> [zipptr]( XrdCl::XRootDStatus& ){ } );
+      {
+        zipptr->SetProperty( "BundledClose", "true");
+        closes.emplace_back( XrdCl::CloseArchive( *zipptr ) >>
+                             [zipptr]( XrdCl::XRootDStatus& ){ } );
+      }
     }
 
     // if there is nothing to close just schedule the handler