[#543] Fix issue with parallel downloads to a directory

Add get/put test for large files

irods/manager/data_object_manager.py

@@ -142,7 +142,7 @@ def _download(self, obj, local_path, num_threads, **options):
             with self.open(obj, 'r', returned_values = data_open_returned_values_, **options) as o:
                 if self.should_parallelize_transfer (num_threads, o, open_options = options.items()):
                     f.close()
-                    if not self.parallel_get( (obj,o), local_path, num_threads = num_threads,
+                    if not self.parallel_get( (obj,o), local_file, num_threads = num_threads,
                                               target_resource_name = options.get(kw.RESC_NAME_KW,''),
                                               data_open_returned_values = data_open_returned_values_):
                         raise RuntimeError("parallel get failed")

irods/test/data_obj_test.py

@@ -1304,7 +1304,15 @@ def test_get_replica_size(self):
             resource.remove()
 
 
-    def test_obj_put_get(self):
+    def test_obj_put_get_small(self):
+        # Test put/get with 16M binary file that will be transferred with a single thread.
+        self._check_obj_put_get(1024 * 1024 * 16)
+
+    def test_obj_put_get_large(self):
+        # Test put/get with binary file that is large enough to trigger parallel transfers.
+        self._check_obj_put_get(data_object_manager.MAXIMUM_SINGLE_THREADED_TRANSFER_SIZE + 1)
+
+    def _check_obj_put_get(self, file_size):
         # Can't do one step open/create with older servers
         if self.sess.server_version <= (4, 1, 4):
             self.skipTest('For iRODS 4.1.5 and newer')
@@ -1315,9 +1323,9 @@ def test_obj_put_get(self):
         test_file = os.path.join(test_dir, filename)
         collection = self.coll.path
 
-        # make random 16M binary file
+        # make random binary file
         with open(test_file, 'wb') as f:
-            f.write(os.urandom(1024 * 1024 * 16))
+            f.write(os.urandom(file_size))
 
         # compute file checksum
         digest = self.sha256_checksum(test_file)