[XrdCl] Add XRD_USEPGWRTRD envar that enables in-fly error correction…

… of corrupted pages.
xrootd · Nov 23, 2021 · 3119972 · 3119972
1 parent bff9954
commit 3119972
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 3 deletions.
diff --git a/docs/man/xrdcp.1 b/docs/man/xrdcp.1
@@ -621,6 +621,11 @@ XRD_CPRETRYPOLICY
 Copy job retry policy, either force or retry (default: force).
 .RE
 
+XRD_CPUSEPGWRTRD
+.RS 5
+Enable in-fly error correction of corrupted pages (default: 1).
+.RE
+
 .SH RETURN CODES
 .RE
 \fB50\fR  : generic error (e.g. config, internal, data, OS, command line option)

diff --git a/src/XrdCl/XrdClClassicCopyJob.cc b/src/XrdCl/XrdClClassicCopyJob.cc
@@ -744,7 +744,7 @@ namespace
         pMaxNbConn = val - 1; // account for the control stream
 
         val = XrdCl::DefaultCpUsePgWrtRd;
-        XrdCl::DefaultEnv::GetEnv()->GetInt( "UsePgWrtRd", val );
+        XrdCl::DefaultEnv::GetEnv()->GetInt( "CpUsePgWrtRd", val );
         pUsePgRead = !url->IsLocalFile() && ( val == 1 );
       }
 
@@ -1229,7 +1229,7 @@ namespace
         pChunkSize( chunkSize ), pDone( false )
       {
         int val = XrdCl::DefaultCpUsePgWrtRd;
-        XrdCl::DefaultEnv::GetEnv()->GetInt( "UsePgWrtRd", val );
+        XrdCl::DefaultEnv::GetEnv()->GetInt( "CpUsePgWrtRd", val );
         pUsePgRead = !url->IsLocalFile() && ( val == 1 );
       }
 
@@ -1691,7 +1691,7 @@ namespace
         pParallel( parallelChunks ), pSize( -1 )
       {
         int val = XrdCl::DefaultCpUsePgWrtRd;
-        XrdCl::DefaultEnv::GetEnv()->GetInt( "UsePgWrtRd", val );
+        XrdCl::DefaultEnv::GetEnv()->GetInt( "CpUsePgWrtRd", val );
         pUsePgWrt = !url.IsLocalFile() && ( val == 1 );
       }
 

diff --git a/src/XrdCl/XrdClDefaultEnv.cc b/src/XrdCl/XrdClDefaultEnv.cc
@@ -305,6 +305,7 @@ namespace XrdCl
     REGISTER_VAR_INT( varsInt, "RetryWrtAtLBLimit",       DefaultRetryWrtAtLBLimit       );
     REGISTER_VAR_INT( varsInt, "XRateThreshold",          DefaultXRateThreshold          );
     REGISTER_VAR_INT( varsInt, "CpRetry",                 DefaultCpRetry                 );
+    REGISTER_VAR_INT( varsInt, "CpUsePgWrtRd",            DefaultCpUsePgWrtRd            );
 
     REGISTER_VAR_STR( varsStr, "ClientMonitor",           DefaultClientMonitor           );
     REGISTER_VAR_STR( varsStr, "ClientMonitorParam",      DefaultClientMonitorParam      );