Commit 8a602714 authored by Felix Seibert's avatar Felix Seibert
Browse files

slightly changing debug log output

parent d1540eb2
...@@ -237,8 +237,13 @@ class OSDManager(object): ...@@ -237,8 +237,13 @@ class OSDManager(object):
for process in processes: for process in processes:
# check the return code. if it is one, the replica could not be deleted, so we try again later. # check the return code. if it is one, the replica could not be deleted, so we try again later.
if process[2] == 1: if process[2] != 0:
errored_deletions.append(process[0]) errored_deletions.append(process[0])
print("errored command: ")
print("command: " + process[0])
print("stdoud: " + process[1][0])
print("stderr: " + process[1][1])
print("retcode: " + str(process[2]))
if len(errored_deletions) == 0: if len(errored_deletions) == 0:
break break
......
...@@ -43,8 +43,8 @@ def run_commands(commands, max_processes=200): ...@@ -43,8 +43,8 @@ def run_commands(commands, max_processes=200):
if (len(running_processes) >= max_processes): if (len(running_processes) >= max_processes):
os.wait() os.wait()
running_processes.difference_update([p for p in running_processes if p.poll() is not None]) running_processes.difference_update([p for p in running_processes if p.poll() is not None])
print("running procs: " + str(len(running_processes)) + " all procs: " + str(len(all_processes)) + #print("running procs: " + str(len(running_processes)) + " all procs: " + str(len(all_processes)) +
" commands: " + str(len(commands))) # " commands: " + str(len(commands)))
for p in running_processes: for p in running_processes:
p.wait() p.wait()
......
Supports Markdown
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