Commit bdb41d04 authored by Joao Pedro Lopes's avatar Joao Pedro Lopes
Browse files
parent 1ade1e3d
Pipeline #3117813 passed with stages
in 11 minutes and 6 seconds
......@@ -46,6 +46,7 @@ DEFAULT_PARAMS = {
"target_qos": None,
"ipv4": False,
"ipv6": False,
"buffer_size": None,
}
......@@ -273,6 +274,13 @@ class JobSubmitter(Base):
type="string",
help="define the target QoS for this transfer for CDMI endpoints",
)
self.opt_parser.add_option(
"--buffer-size",
"--buff-size",
dest="buffer_size",
type=int,
help="TCP buffer size (expressed in bytes) that will be used for the given transfer job",
)
def validate(self):
self.checksum = None
......@@ -365,6 +373,7 @@ class JobSubmitter(Base):
ipv6=self.options.ipv6,
s3alternate=self.options.s3alternate,
target_qos=self.options.target_qos,
buffer_size=self.options.buffer_size,
)
def _do_submit(self, context):
......
......@@ -134,6 +134,7 @@ def new_job(
sid=None,
s3alternate=False,
nostreams=1,
buffer_size=None,
):
"""
Creates a new dictionary representing a job
......@@ -158,6 +159,7 @@ def new_job(
sid: Specific id given by the client
s3alternate: Use S3 alternate url schema
nostreams: Number of streams
buffer_size: Tcp buffer size (in bytes) that will be used for the given transfer-job
Returns:
An initialized dictionary representing a job
......@@ -193,6 +195,7 @@ def new_job(
sid=sid,
s3alternate=s3alternate,
nostreams=nostreams,
buffer_size=buffer_size,
)
job = dict(files=transfers, delete=deletion, params=params)
return job
......
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