Compare commits
2 Commits
Transphase
...
Transphase
| Author | SHA1 | Date | |
|---|---|---|---|
| 6db4849939 | |||
| 260e29fbf6 |
@@ -168,7 +168,7 @@ async def main():
|
||||
await send_encrypted_msg(ws, k, (msgtype, peer_group_id, role, "", "", "", "", ""))
|
||||
bar = None
|
||||
f = None
|
||||
i = 1
|
||||
i = 0
|
||||
number_of_chunks = None
|
||||
while True:
|
||||
if number_of_chunks is not None and i > number_of_chunks:
|
||||
@@ -192,8 +192,8 @@ async def main():
|
||||
f.write(msg["chunk"])
|
||||
else:
|
||||
f.write(msg["chunk"])
|
||||
i += 1
|
||||
msgtype = "proceed"
|
||||
i += 1 # This increment has to happen before we try to send the confirmation message
|
||||
await send_encrypted_msg(ws, k, (msgtype, peer_group_id, role, "", "", "", "", "")) # request the next chunk from sender
|
||||
bar.suffix = "%(percent).1f%% complete - %(eta_td)s remaining " + str(i) + "/" + str(number_of_chunks) + " msg sent"
|
||||
bar.next()
|
||||
|
||||
Reference in New Issue
Block a user