FilesExpand file tree

master

/

peerEmulationTest.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

14 lines (11 loc) · 595 Bytes

master

/

peerEmulationTest.py

Copy path

Top

File metadata and controls

• Code
• Blame

14 lines (11 loc) · 595 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

from services.network_services.peerTLSInterface import PeerTLSInterface

import concurrent.futures

if __name__ == '__main__':

buffers = dict()

with concurrent.futures.ThreadPoolExecutor() as executor:

for i in range(7):

ob = PeerTLSInterface(threadPoolExecutor = executor, remoteAddress = '192.168.0.103', localPort= 11111+i)

fut = executor.submit(ob.connectToRemoteClient, networkPassword='P@ssw0rd', localRedundancyCount=2)

buffers[fut] = i

for fut in concurrent.futures.as_completed(buffers):

print(buffers[fut], 'completer')