adding timeoutexpired error handling

xtreemfs_client/div_util.py

@@ -88,8 +88,11 @@ def run_commands(commands, max_processes=200, print_errors=True):
 
     # for finished_process in running_processes:
     for finished_process in running_processes_map:
-        # try:
-        stdout, stderr = finished_process.communicate(timeout=10)
+        try:
+            stdout, stderr = finished_process.communicate(timeout=10)
+        except subprocess.TimeoutExpired:
+            finished_process.kill()
+            stdout, stderr = finished_process.communicate()
 
         finished_process = (finished_process.args,
                             (stdout, stderr),