MQTT Python client bench

Results / sub_filters_fixed

sub_filters_fixed

The same, dispatched to 100 per-filter callbacks (message_callback_add)?

sub · QoS 1 · 256 B · 2,000 msgs/s · MQTTv311 · 1,000 topics · 100 filter callbacks · how it is wired

clientvalidp50 ↓p99 ↓p99.9 ↓max ↓CPU / msg ↓peak RSS ↓ctx sw / 1k ↓
paho 2.1.0 sync3/3
129 µs

run 1 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15994 / 15994
CPU user / sys per msg81.9 µs / 14.4 µs
CPU (share of a core)19.3 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.20 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,997
broker received ($SYS)19,997
broker sent ($SYS)19,997
broker dropped ($SYS)0
client received19,997
in window: offered / received15998 / 15998
CPU user / sys per msg43.1 µs / 55.0 µs
CPU (share of a core)19.7 %
threads3
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19997; peer wrote 19997
  • broker_confirms_deliveries: broker sent 19997; client received 19997
  • no_loss: broker acknowledged 19997 from the peer; client received 19997; broker dropped 0
  • offered_rate_held: peer wrote 15998 of 16000 offered in the window
  • client_kept_up: client received 15998 of 15998 in the window
  • callbacks_matched: 19997 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.14 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,993
broker received ($SYS)19,993
broker sent ($SYS)19,993
broker dropped ($SYS)0
client received19,993
in window: offered / received15995 / 15995
CPU user / sys per msg61.3 µs / 37.5 µs
CPU (share of a core)19.8 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19993; peer wrote 19993
  • broker_confirms_deliveries: broker sent 19993; client received 19993
  • no_loss: broker acknowledged 19993 from the peer; client received 19993; broker dropped 0
  • offered_rate_held: peer wrote 15995 of 16000 offered in the window
  • client_kept_up: client received 15995 of 15995 in the window
  • callbacks_matched: 19993 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.50 cores busy outside the client, peer and broker
225 µs

run 1 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15994 / 15994
CPU user / sys per msg81.9 µs / 14.4 µs
CPU (share of a core)19.3 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.20 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,997
broker received ($SYS)19,997
broker sent ($SYS)19,997
broker dropped ($SYS)0
client received19,997
in window: offered / received15998 / 15998
CPU user / sys per msg43.1 µs / 55.0 µs
CPU (share of a core)19.7 %
threads3
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19997; peer wrote 19997
  • broker_confirms_deliveries: broker sent 19997; client received 19997
  • no_loss: broker acknowledged 19997 from the peer; client received 19997; broker dropped 0
  • offered_rate_held: peer wrote 15998 of 16000 offered in the window
  • client_kept_up: client received 15998 of 15998 in the window
  • callbacks_matched: 19997 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.14 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,993
broker received ($SYS)19,993
broker sent ($SYS)19,993
broker dropped ($SYS)0
client received19,993
in window: offered / received15995 / 15995
CPU user / sys per msg61.3 µs / 37.5 µs
CPU (share of a core)19.8 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19993; peer wrote 19993
  • broker_confirms_deliveries: broker sent 19993; client received 19993
  • no_loss: broker acknowledged 19993 from the peer; client received 19993; broker dropped 0
  • offered_rate_held: peer wrote 15995 of 16000 offered in the window
  • client_kept_up: client received 15995 of 15995 in the window
  • callbacks_matched: 19993 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.50 cores busy outside the client, peer and broker
1,999 µs

run 1 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15994 / 15994
CPU user / sys per msg81.9 µs / 14.4 µs
CPU (share of a core)19.3 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.20 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,997
broker received ($SYS)19,997
broker sent ($SYS)19,997
broker dropped ($SYS)0
client received19,997
in window: offered / received15998 / 15998
CPU user / sys per msg43.1 µs / 55.0 µs
CPU (share of a core)19.7 %
threads3
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19997; peer wrote 19997
  • broker_confirms_deliveries: broker sent 19997; client received 19997
  • no_loss: broker acknowledged 19997 from the peer; client received 19997; broker dropped 0
  • offered_rate_held: peer wrote 15998 of 16000 offered in the window
  • client_kept_up: client received 15998 of 15998 in the window
  • callbacks_matched: 19997 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.14 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,993
broker received ($SYS)19,993
broker sent ($SYS)19,993
broker dropped ($SYS)0
client received19,993
in window: offered / received15995 / 15995
CPU user / sys per msg61.3 µs / 37.5 µs
CPU (share of a core)19.8 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19993; peer wrote 19993
  • broker_confirms_deliveries: broker sent 19993; client received 19993
  • no_loss: broker acknowledged 19993 from the peer; client received 19993; broker dropped 0
  • offered_rate_held: peer wrote 15995 of 16000 offered in the window
  • client_kept_up: client received 15995 of 15995 in the window
  • callbacks_matched: 19993 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.50 cores busy outside the client, peer and broker
6,079 µs

run 1 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15994 / 15994
CPU user / sys per msg81.9 µs / 14.4 µs
CPU (share of a core)19.3 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.20 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,997
broker received ($SYS)19,997
broker sent ($SYS)19,997
broker dropped ($SYS)0
client received19,997
in window: offered / received15998 / 15998
CPU user / sys per msg43.1 µs / 55.0 µs
CPU (share of a core)19.7 %
threads3
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19997; peer wrote 19997
  • broker_confirms_deliveries: broker sent 19997; client received 19997
  • no_loss: broker acknowledged 19997 from the peer; client received 19997; broker dropped 0
  • offered_rate_held: peer wrote 15998 of 16000 offered in the window
  • client_kept_up: client received 15998 of 15998 in the window
  • callbacks_matched: 19997 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.14 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,993
broker received ($SYS)19,993
broker sent ($SYS)19,993
broker dropped ($SYS)0
client received19,993
in window: offered / received15995 / 15995
CPU user / sys per msg61.3 µs / 37.5 µs
CPU (share of a core)19.8 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19993; peer wrote 19993
  • broker_confirms_deliveries: broker sent 19993; client received 19993
  • no_loss: broker acknowledged 19993 from the peer; client received 19993; broker dropped 0
  • offered_rate_held: peer wrote 15995 of 16000 offered in the window
  • client_kept_up: client received 15995 of 15995 in the window
  • callbacks_matched: 19993 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.50 cores busy outside the client, peer and broker
98.5 µs

run 1 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15994 / 15994
CPU user / sys per msg81.9 µs / 14.4 µs
CPU (share of a core)19.3 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.20 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,997
broker received ($SYS)19,997
broker sent ($SYS)19,997
broker dropped ($SYS)0
client received19,997
in window: offered / received15998 / 15998
CPU user / sys per msg43.1 µs / 55.0 µs
CPU (share of a core)19.7 %
threads3
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19997; peer wrote 19997
  • broker_confirms_deliveries: broker sent 19997; client received 19997
  • no_loss: broker acknowledged 19997 from the peer; client received 19997; broker dropped 0
  • offered_rate_held: peer wrote 15998 of 16000 offered in the window
  • client_kept_up: client received 15998 of 15998 in the window
  • callbacks_matched: 19997 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.14 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,993
broker received ($SYS)19,993
broker sent ($SYS)19,993
broker dropped ($SYS)0
client received19,993
in window: offered / received15995 / 15995
CPU user / sys per msg61.3 µs / 37.5 µs
CPU (share of a core)19.8 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19993; peer wrote 19993
  • broker_confirms_deliveries: broker sent 19993; client received 19993
  • no_loss: broker acknowledged 19993 from the peer; client received 19993; broker dropped 0
  • offered_rate_held: peer wrote 15995 of 16000 offered in the window
  • client_kept_up: client received 15995 of 15995 in the window
  • callbacks_matched: 19993 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.50 cores busy outside the client, peer and broker
26.0 MiB

run 1 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15994 / 15994
CPU user / sys per msg81.9 µs / 14.4 µs
CPU (share of a core)19.3 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.20 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,997
broker received ($SYS)19,997
broker sent ($SYS)19,997
broker dropped ($SYS)0
client received19,997
in window: offered / received15998 / 15998
CPU user / sys per msg43.1 µs / 55.0 µs
CPU (share of a core)19.7 %
threads3
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19997; peer wrote 19997
  • broker_confirms_deliveries: broker sent 19997; client received 19997
  • no_loss: broker acknowledged 19997 from the peer; client received 19997; broker dropped 0
  • offered_rate_held: peer wrote 15998 of 16000 offered in the window
  • client_kept_up: client received 15998 of 15998 in the window
  • callbacks_matched: 19997 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.14 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,993
broker received ($SYS)19,993
broker sent ($SYS)19,993
broker dropped ($SYS)0
client received19,993
in window: offered / received15995 / 15995
CPU user / sys per msg61.3 µs / 37.5 µs
CPU (share of a core)19.8 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19993; peer wrote 19993
  • broker_confirms_deliveries: broker sent 19993; client received 19993
  • no_loss: broker acknowledged 19993 from the peer; client received 19993; broker dropped 0
  • offered_rate_held: peer wrote 15995 of 16000 offered in the window
  • client_kept_up: client received 15995 of 15995 in the window
  • callbacks_matched: 19993 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.50 cores busy outside the client, peer and broker
0

run 1 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15994 / 15994
CPU user / sys per msg81.9 µs / 14.4 µs
CPU (share of a core)19.3 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.20 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,997
broker received ($SYS)19,997
broker sent ($SYS)19,997
broker dropped ($SYS)0
client received19,997
in window: offered / received15998 / 15998
CPU user / sys per msg43.1 µs / 55.0 µs
CPU (share of a core)19.7 %
threads3
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19997; peer wrote 19997
  • broker_confirms_deliveries: broker sent 19997; client received 19997
  • no_loss: broker acknowledged 19997 from the peer; client received 19997; broker dropped 0
  • offered_rate_held: peer wrote 15998 of 16000 offered in the window
  • client_kept_up: client received 15998 of 15998 in the window
  • callbacks_matched: 19997 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.14 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,993
broker received ($SYS)19,993
broker sent ($SYS)19,993
broker dropped ($SYS)0
client received19,993
in window: offered / received15995 / 15995
CPU user / sys per msg61.3 µs / 37.5 µs
CPU (share of a core)19.8 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19993; peer wrote 19993
  • broker_confirms_deliveries: broker sent 19993; client received 19993
  • no_loss: broker acknowledged 19993 from the peer; client received 19993; broker dropped 0
  • offered_rate_held: peer wrote 15995 of 16000 offered in the window
  • client_kept_up: client received 15995 of 15995 in the window
  • callbacks_matched: 19993 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.11 of its core
  • host_quiet: 0.50 cores busy outside the client, peer and broker
mqttium 1.1.0 asyncio3/3
217 µs

run 1 · valid

C source sent19,992
broker received ($SYS)19,992
broker sent ($SYS)19,992
broker dropped ($SYS)0
client received19,992
in window: offered / received15994 / 15994
CPU user / sys per msg133 µs / 28.1 µs
CPU (share of a core)32.2 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19992; peer wrote 19992
  • broker_confirms_deliveries: broker sent 19992; client received 19992
  • no_loss: broker acknowledged 19992 from the peer; client received 19992; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19992 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15997 / 15997
CPU user / sys per msg116 µs / 42.5 µs
CPU (share of a core)31.7 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15997 of 16000 offered in the window
  • client_kept_up: client received 15997 of 15997 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.28 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,995
broker received ($SYS)19,995
broker sent ($SYS)19,995
broker dropped ($SYS)0
client received19,995
in window: offered / received15996 / 15996
CPU user / sys per msg137 µs / 20.0 µs
CPU (share of a core)31.4 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19995; peer wrote 19995
  • broker_confirms_deliveries: broker sent 19995; client received 19995
  • no_loss: broker acknowledged 19995 from the peer; client received 19995; broker dropped 0
  • offered_rate_held: peer wrote 15996 of 16000 offered in the window
  • client_kept_up: client received 15996 of 15996 in the window
  • callbacks_matched: 19995 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker
303 µs

run 1 · valid

C source sent19,992
broker received ($SYS)19,992
broker sent ($SYS)19,992
broker dropped ($SYS)0
client received19,992
in window: offered / received15994 / 15994
CPU user / sys per msg133 µs / 28.1 µs
CPU (share of a core)32.2 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19992; peer wrote 19992
  • broker_confirms_deliveries: broker sent 19992; client received 19992
  • no_loss: broker acknowledged 19992 from the peer; client received 19992; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19992 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15997 / 15997
CPU user / sys per msg116 µs / 42.5 µs
CPU (share of a core)31.7 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15997 of 16000 offered in the window
  • client_kept_up: client received 15997 of 15997 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.28 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,995
broker received ($SYS)19,995
broker sent ($SYS)19,995
broker dropped ($SYS)0
client received19,995
in window: offered / received15996 / 15996
CPU user / sys per msg137 µs / 20.0 µs
CPU (share of a core)31.4 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19995; peer wrote 19995
  • broker_confirms_deliveries: broker sent 19995; client received 19995
  • no_loss: broker acknowledged 19995 from the peer; client received 19995; broker dropped 0
  • offered_rate_held: peer wrote 15996 of 16000 offered in the window
  • client_kept_up: client received 15996 of 15996 in the window
  • callbacks_matched: 19995 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker
1,475 µs

run 1 · valid

C source sent19,992
broker received ($SYS)19,992
broker sent ($SYS)19,992
broker dropped ($SYS)0
client received19,992
in window: offered / received15994 / 15994
CPU user / sys per msg133 µs / 28.1 µs
CPU (share of a core)32.2 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19992; peer wrote 19992
  • broker_confirms_deliveries: broker sent 19992; client received 19992
  • no_loss: broker acknowledged 19992 from the peer; client received 19992; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19992 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15997 / 15997
CPU user / sys per msg116 µs / 42.5 µs
CPU (share of a core)31.7 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15997 of 16000 offered in the window
  • client_kept_up: client received 15997 of 15997 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.28 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,995
broker received ($SYS)19,995
broker sent ($SYS)19,995
broker dropped ($SYS)0
client received19,995
in window: offered / received15996 / 15996
CPU user / sys per msg137 µs / 20.0 µs
CPU (share of a core)31.4 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19995; peer wrote 19995
  • broker_confirms_deliveries: broker sent 19995; client received 19995
  • no_loss: broker acknowledged 19995 from the peer; client received 19995; broker dropped 0
  • offered_rate_held: peer wrote 15996 of 16000 offered in the window
  • client_kept_up: client received 15996 of 15996 in the window
  • callbacks_matched: 19995 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker
4,684 µs

run 1 · valid

C source sent19,992
broker received ($SYS)19,992
broker sent ($SYS)19,992
broker dropped ($SYS)0
client received19,992
in window: offered / received15994 / 15994
CPU user / sys per msg133 µs / 28.1 µs
CPU (share of a core)32.2 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19992; peer wrote 19992
  • broker_confirms_deliveries: broker sent 19992; client received 19992
  • no_loss: broker acknowledged 19992 from the peer; client received 19992; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19992 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15997 / 15997
CPU user / sys per msg116 µs / 42.5 µs
CPU (share of a core)31.7 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15997 of 16000 offered in the window
  • client_kept_up: client received 15997 of 15997 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.28 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,995
broker received ($SYS)19,995
broker sent ($SYS)19,995
broker dropped ($SYS)0
client received19,995
in window: offered / received15996 / 15996
CPU user / sys per msg137 µs / 20.0 µs
CPU (share of a core)31.4 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19995; peer wrote 19995
  • broker_confirms_deliveries: broker sent 19995; client received 19995
  • no_loss: broker acknowledged 19995 from the peer; client received 19995; broker dropped 0
  • offered_rate_held: peer wrote 15996 of 16000 offered in the window
  • client_kept_up: client received 15996 of 15996 in the window
  • callbacks_matched: 19995 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker
159 µs

run 1 · valid

C source sent19,992
broker received ($SYS)19,992
broker sent ($SYS)19,992
broker dropped ($SYS)0
client received19,992
in window: offered / received15994 / 15994
CPU user / sys per msg133 µs / 28.1 µs
CPU (share of a core)32.2 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19992; peer wrote 19992
  • broker_confirms_deliveries: broker sent 19992; client received 19992
  • no_loss: broker acknowledged 19992 from the peer; client received 19992; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19992 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15997 / 15997
CPU user / sys per msg116 µs / 42.5 µs
CPU (share of a core)31.7 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15997 of 16000 offered in the window
  • client_kept_up: client received 15997 of 15997 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.28 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,995
broker received ($SYS)19,995
broker sent ($SYS)19,995
broker dropped ($SYS)0
client received19,995
in window: offered / received15996 / 15996
CPU user / sys per msg137 µs / 20.0 µs
CPU (share of a core)31.4 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19995; peer wrote 19995
  • broker_confirms_deliveries: broker sent 19995; client received 19995
  • no_loss: broker acknowledged 19995 from the peer; client received 19995; broker dropped 0
  • offered_rate_held: peer wrote 15996 of 16000 offered in the window
  • client_kept_up: client received 15996 of 15996 in the window
  • callbacks_matched: 19995 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker
26.8 MiB

run 1 · valid

C source sent19,992
broker received ($SYS)19,992
broker sent ($SYS)19,992
broker dropped ($SYS)0
client received19,992
in window: offered / received15994 / 15994
CPU user / sys per msg133 µs / 28.1 µs
CPU (share of a core)32.2 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19992; peer wrote 19992
  • broker_confirms_deliveries: broker sent 19992; client received 19992
  • no_loss: broker acknowledged 19992 from the peer; client received 19992; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19992 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15997 / 15997
CPU user / sys per msg116 µs / 42.5 µs
CPU (share of a core)31.7 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15997 of 16000 offered in the window
  • client_kept_up: client received 15997 of 15997 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.28 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,995
broker received ($SYS)19,995
broker sent ($SYS)19,995
broker dropped ($SYS)0
client received19,995
in window: offered / received15996 / 15996
CPU user / sys per msg137 µs / 20.0 µs
CPU (share of a core)31.4 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19995; peer wrote 19995
  • broker_confirms_deliveries: broker sent 19995; client received 19995
  • no_loss: broker acknowledged 19995 from the peer; client received 19995; broker dropped 0
  • offered_rate_held: peer wrote 15996 of 16000 offered in the window
  • client_kept_up: client received 15996 of 15996 in the window
  • callbacks_matched: 19995 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker
997

run 1 · valid

C source sent19,992
broker received ($SYS)19,992
broker sent ($SYS)19,992
broker dropped ($SYS)0
client received19,992
in window: offered / received15994 / 15994
CPU user / sys per msg133 µs / 28.1 µs
CPU (share of a core)32.2 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19992; peer wrote 19992
  • broker_confirms_deliveries: broker sent 19992; client received 19992
  • no_loss: broker acknowledged 19992 from the peer; client received 19992; broker dropped 0
  • offered_rate_held: peer wrote 15994 of 16000 offered in the window
  • client_kept_up: client received 15994 of 15994 in the window
  • callbacks_matched: 19992 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker

run 2 · valid

C source sent19,988
broker received ($SYS)19,988
broker sent ($SYS)19,988
broker dropped ($SYS)0
client received19,988
in window: offered / received15997 / 15997
CPU user / sys per msg116 µs / 42.5 µs
CPU (share of a core)31.7 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19988; peer wrote 19988
  • broker_confirms_deliveries: broker sent 19988; client received 19988
  • no_loss: broker acknowledged 19988 from the peer; client received 19988; broker dropped 0
  • offered_rate_held: peer wrote 15997 of 16000 offered in the window
  • client_kept_up: client received 15997 of 15997 in the window
  • callbacks_matched: 19988 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.28 cores busy outside the client, peer and broker

run 3 · valid

C source sent19,995
broker received ($SYS)19,995
broker sent ($SYS)19,995
broker dropped ($SYS)0
client received19,995
in window: offered / received15996 / 15996
CPU user / sys per msg137 µs / 20.0 µs
CPU (share of a core)31.4 %
threads2
  • worker_completed: worker reported its counts
  • peer_completed: peer reported its counts
  • broker_counters_read: fresh $SYS reading before and after the run
  • broker_confirms_peer_publishes: broker received 19995; peer wrote 19995
  • broker_confirms_deliveries: broker sent 19995; client received 19995
  • no_loss: broker acknowledged 19995 from the peer; client received 19995; broker dropped 0
  • offered_rate_held: peer wrote 15996 of 16000 offered in the window
  • client_kept_up: client received 15996 of 15996 in the window
  • callbacks_matched: 19995 messages reached a filter callback, 0 the catch-all
  • broker_headroom: broker used 0.12 of its core
  • host_quiet: 0.00 cores busy outside the client, peer and broker
aiomqtt 2.5.1 asyncio—unsupportedunsupportedunsupportedunsupportedunsupportedunsupportedunsupported
aiomqtt3 3.0.0a1 asyncio experimental—unsupportedunsupportedunsupportedunsupportedunsupportedunsupportedunsupported
amqtt 0.12.1 asyncio—unsupportedunsupportedunsupportedunsupportedunsupportedunsupportedunsupported
awscrt 0.37.0 crt_event_loop native—unsupportedunsupportedunsupportedunsupportedunsupportedunsupportedunsupported
gmqtt 0.7.0 asyncio—unsupportedunsupportedunsupportedunsupportedunsupportedunsupportedunsupported
zmqtt 0.2.4 asyncio experimental—unsupportedunsupportedunsupportedunsupportedunsupportedunsupportedunsupported

Latency by percentile

100 µs1 ms10 msp50p75p90p99p99.9maxpaho: p50 129 µs, p75 135 µs, p90 143 µs, p99 225 µs, p99.9 1,999 µs, max 6,079 µsmqttium: p50 217 µs, p75 233 µs, p90 242 µs, p99 303 µs, p99.9 1,475 µs, max 4,684 µspahomqttium