busrt 0.5.5

Local and network IPC bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

import sys
sys.path.insert(0, '..')
import asyncio
import busrt_async
import threading
import time
import random
from tqdm import tqdm

iters = 100_000
workers = 1

cnt = 0


async def on_frame(frame):
    global cnt
    cnt += 1


async def test(w, iters):
    try:
        global cnt
        payload = b'\x01' * 10
        name = f'test{random.randint(0,1000_000)}-{w}'
        path = '/tmp/busrt.sock'
        # path = 'localhost:9924'
        bus = busrt_async.client.Client(path, name)
        bus.on_frame = on_frame
        await bus.connect()
        print(f'Connected to {path}')
        for i in range(iters):
            frame = busrt_async.client.Frame(payload,
                                             tp=busrt_async.client.OP_MESSAGE)
            frame.qos = 2
            b = await bus.send('y', frame)
            if not await b.wait_completed(timeout=1):
                raise TimeoutError
            # await asyncio.sleep(0.0000001)
            cnt += 1
        # await bus.disconnect()
    except Exception as e:
        import traceback
        traceback.print_exc()


async def main():
    started = time.perf_counter()
    for w in range(workers):
        asyncio.ensure_future(test(w, int(iters / workers)))
    await asyncio.sleep(0.01)
    with tqdm(total=iters) as pbar:
        prev = 0
        while cnt < iters:
            await asyncio.sleep(0.01)
            pbar.update(cnt - prev)
            prev = cnt
    pbar.update(iters)
    elapsed = time.perf_counter() - started
    speed = round(iters / elapsed)
    print(speed, 'iters/s')
    print(f'{round(1_000_000/speed)} us per iter')


asyncio.run(main())
time.sleep(1)