Commit 7dcc6c62 authored by Aleksandr Konstantinov's avatar Aleksandr Konstantinov
Browse files

Reasonably increasing communication block size for partial HTTP PUT.

parent b80f7769
...@@ -85,7 +85,10 @@ namespace Arc { ...@@ -85,7 +85,10 @@ namespace Arc {
URL sessionurl = jobid; URL sessionurl = jobid;
sessionurl.AddOption("threads=3",false); sessionurl.AddOption("threads=3",false);
sessionurl.AddOption("encryption=optional",false); sessionurl.AddOption("encryption=optional",false);
if(arex_features) sessionurl.AddOption("httpputpartial=yes",false); if(arex_features) {
sessionurl.AddOption("httpputpartial=yes",false);
sessionurl.AddOption("blocksize=5242880",true);
}
if (!PutFiles(preparedjobdesc, sessionurl)) { if (!PutFiles(preparedjobdesc, sessionurl)) {
logger.msg(INFO, "Failed uploading local input files"); logger.msg(INFO, "Failed uploading local input files");
...@@ -177,7 +180,10 @@ namespace Arc { ...@@ -177,7 +180,10 @@ namespace Arc {
URL sessionurl = jobid; URL sessionurl = jobid;
sessionurl.AddOption("threads=3",false); sessionurl.AddOption("threads=3",false);
sessionurl.AddOption("encryption=optional",false); sessionurl.AddOption("encryption=optional",false);
if(arex_features) sessionurl.AddOption("httpputpartial=yes",false); if(arex_features) {
sessionurl.AddOption("httpputpartial=yes",false);
sessionurl.AddOption("blocksize=5242880",true);
}
if (!PutFiles(preparedjobdesc, sessionurl)) { if (!PutFiles(preparedjobdesc, sessionurl)) {
logger.msg(INFO, "Failed uploading local input files"); logger.msg(INFO, "Failed uploading local input files");
...@@ -293,6 +299,7 @@ namespace Arc { ...@@ -293,6 +299,7 @@ namespace Arc {
sessionurl.AddOption("threads=3",false); sessionurl.AddOption("threads=3",false);
sessionurl.AddOption("encryption=optional",false); sessionurl.AddOption("encryption=optional",false);
sessionurl.AddOption("httpputpartial=yes",false); // for A-REX sessionurl.AddOption("httpputpartial=yes",false); // for A-REX
sessionurl.AddOption("blocksize=5242880",true);
if (!PutFiles(preparedjobdesc, sessionurl)) { if (!PutFiles(preparedjobdesc, sessionurl)) {
logger.msg(INFO, "Failed uploading local input files"); logger.msg(INFO, "Failed uploading local input files");
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment