Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[mqtt] Benchmark broker message dispatching #2897

Merged
merged 16 commits into from
May 1, 2020
Merged

[mqtt] Benchmark broker message dispatching #2897

Show file tree
Hide file tree
Changes from 12 commits
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
4b07ee7
Fix persist_broker_state benches
dmolokanov Apr 28, 2020
6824a4b
Add dispatch q0 messages benches
dmolokanov Apr 28, 2020
58f6138
Add proper clients
dmolokanov Apr 28, 2020
6483d92
Code cleanup
dmolokanov Apr 28, 2020
60d156f
Add on_publish callback
dmolokanov Apr 29, 2020
0342db9
enable persist benches
dmolokanov Apr 29, 2020
aefe945
Merge branch 'master' into mqtt-dispatch-bench
dmolokanov Apr 29, 2020
5e1d70b
fix persist broker state
dmolokanov Apr 29, 2020
edc9b7f
Single threaded broker
dmolokanov Apr 29, 2020
fa04d1a
add fan_in and fan_out scenarios
dmolokanov Apr 30, 2020
0cbf196
add feature for broker callbacks
dmolokanov Apr 30, 2020
7e365b5
require tokio multi-threaded runtime for becnhes
dmolokanov Apr 30, 2020
f14813b
make some dependencies optional with benches feature
dmolokanov Apr 30, 2020
c429ad2
add docs to bench
dmolokanov May 1, 2020
4fb83c5
remove unhandled packets
dmolokanov May 1, 2020
ef9d441
Merge branch 'master' into mqtt-dispatch-bench
kodiakhq[bot] May 1, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
39 changes: 13 additions & 26 deletions mqtt/Cargo.lock
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

21 changes: 17 additions & 4 deletions mqtt/mqtt-broker/Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,6 @@ version = "0.1.0"
authors = ["Azure IoT Edge Devs"]
edition = "2018"

# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

[dependencies]
bincode = "1.2"
bytes = "0.5"
Expand Down Expand Up @@ -38,9 +36,10 @@ atty = "0.2"
bytes = "0.5"
criterion = "0.3"
fail = { version = "0.3", features = ["failpoints"] }
itertools = "0.9"
matches = "0.1"
proptest = "0.9"
rand = "0.3"
rand = "0.7"
dmolokanov marked this conversation as resolved.
Show resolved Hide resolved
serde_json = "1.0"
tempfile = "3"
test-case = "1.0"
Expand All @@ -52,5 +51,19 @@ name = "persist_failpoints"
required-features = ["fail/failpoints"]

[[bench]]
name = "file_persist_bench"
name = "persist_broker_state"
harness = false

[[bench]]
name = "dispatch_messages"
harness = false
required-features = ["__internal_broker_callbacks", "tokio/rt-threaded"]

[features]
default = []

# Internal (PRIVATE!) features used to aid testing.
# Don't rely on these whatsoever. They may disappear at anytime.

# When enabled, adds additional broker callback to measure processing time
__internal_broker_callbacks = []
Loading