parser.add_argument("--skipattr", default=False, action="store_true", help=str_help)
arguments = parser.parse_args()
if arguments.multiplicity < 1:
- print "Multiplicity", arguments.multiplicity, "is not positive."
+ print("Multiplicity", arguments.multiplicity, "is not positive.")
raise SystemExit(1)
# TODO: Are sanity checks (such as asnumber>=0) required?
return arguments
:return: true if no remaining data to send
"""
# We assume there is a msg_out to send and socket is writable.
- # print "going to send", repr(self.msg_out)
self.timer.snapshot()
bytes_sent = self.socket.send(self.msg_out)
# Forget the part of message that was sent.
for t in thread_args:
thread.start_new_thread(job, (t, rpcqueue, storage))
except Exception:
- print "Error: unable to start thread."
+ print("Error: unable to start thread.")
raise SystemExit(2)
if arguments.usepeerip: