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.

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

Fix v5 #393

Merged
merged 50 commits into from May 12, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
50 commits
Select commit Hold shift + click to select a range
99b2889
rumqttc: move old code to v4 module
abhikjain360 Feb 11, 2022
c094fa5
rumqttc: v5: init with v4 code
abhikjain360 Feb 11, 2022
c064f0e
rumqttc: v5: packet: copy code from mqttbytes/v5
abhikjain360 Feb 11, 2022
ff8097b
rumqttc: v5: use mqttbytes/v5
abhikjain360 Feb 11, 2022
218b8a8
rumqttc: v5: use v5::packet instead of mqttbytes::v5
abhikjain360 Feb 11, 2022
076fb26
rumqttc: fix examples, tests and docs
abhikjain360 Feb 11, 2022
86ace53
rumqttc: use request_buf in eventloop and client
abhikjain360 Feb 12, 2022
76ad541
rumqttc: client: more intuitive API + code reduction
abhikjain360 Feb 12, 2022
a491af4
rumqttc: examples: remove needless import
abhikjain360 Feb 12, 2022
298858a
Merge remote-tracking branch 'fork/master' into rumqqtc-v5
abhikjain360 Feb 12, 2022
9401e29
rumqttc: v5: replace async_channel + pollseter -> flume
abhikjain360 Feb 13, 2022
72fb077
rumqttc: v5: AsyncClient: limit scope of MutecGuard for async runtime
abhikjain360 Feb 15, 2022
2269cd1
rumqttc: v5: add examples
abhikjain360 Feb 15, 2022
bc9baa0
Merge branch 'master' into rumqqtc-v5
abhikjain360 Feb 15, 2022
826e9d0
rumqttc: v4: examples: fix
abhikjain360 Feb 15, 2022
a017f41
merge master
abhikjain360 Mar 7, 2022
279805a
cmacos test
abhikjain360 Mar 7, 2022
1941b05
Merge branch 'master' into rumqqtc-v5
de-sh Mar 10, 2022
17fec71
Limit GitHub actions to running only on PRs affecting code/dependenci…
de-sh Mar 16, 2022
a149b77
rumqttc: v5: separate pub/sub client option
abhikjain360 Mar 17, 2022
3023103
Merge branch 'rumqqtc-v5' of github.com:abhikjain360/rumqtt into rumq…
abhikjain360 Mar 17, 2022
dfc7df0
merge simplerouter from master
abhikjain360 Mar 21, 2022
b38469f
rumqttc: v5: fix pkid
abhikjain360 Mar 22, 2022
b516430
rumqttc: v5: remove cancel channel
abhikjain360 Mar 24, 2022
d2de93e
rumqttc: v5: renaming buffers
abhikjain360 Mar 24, 2022
d7a897a
rumqttc: v5: asyncclient: remove `AsyncClient::from_senders(..)`
abhikjain360 Mar 24, 2022
923e2ad
rumqttc: v5: asyncclient: internal functions rename
abhikjain360 Mar 24, 2022
53a573a
rumqttc: merge master
abhikjain360 Mar 24, 2022
acfda4c
rumqttc: merge master (fixed)
abhikjain360 Mar 24, 2022
2d56f3e
rumqttc: client: rollback pub-sub seperation
abhikjain360 Mar 24, 2022
6fbf234
rumqttc: eventloop: remove `Eventloop.event`, `Event` and `Outgoing`
abhikjain360 Mar 24, 2022
b1458fd
rumqttc: client: rename `AsyncClient::next_publish()` -> `AsyncClient…
abhikjain360 Mar 24, 2022
abdd8f5
rumqttc: state: some inlines
abhikjain360 Mar 24, 2022
c127d3c
rumqttc: ci: ignore packet parsing in cargo clippy
abhikjain360 Mar 25, 2022
913e5f7
rumqttc: ci: ignore packet parsing in cargo clippy
abhikjain360 Mar 25, 2022
cefda92
rumqttc: handle pkids at client side
abhikjain360 Mar 27, 2022
8fffc5d
rumqttc: restore backwards compatibilty
abhikjain360 Mar 27, 2022
7792a5e
rumqttc: v5: move shared buffer to separate struct
abhikjain360 Apr 1, 2022
8b42117
Merge pull request #351 from abhikjain360/rumqqtc-v5
de-sh May 11, 2022
722bfb4
fix benchmark updates
de-sh Apr 23, 2022
f24d57d
Fix clippy warning
de-sh Apr 23, 2022
f04ef52
Fixes to more issues pointed out by clippy
de-sh May 11, 2022
e52e2fe
Merge remote-tracking branch 'origin/master' into fix-v5
de-sh May 11, 2022
96a0a75
Further clippy fixes
de-sh May 12, 2022
ca5f033
Fix wrong check
de-sh May 12, 2022
2c70cbe
Fix missing `Clone`
de-sh May 12, 2022
01062dd
Remove seemingly unnecessary `mut`
de-sh May 12, 2022
8cf28f5
Remove `mut` in syncclient and examples
de-sh May 12, 2022
267c728
clippy suggestion benchmarks/v5
de-sh May 12, 2022
1c03c8b
Fix clippy issue
de-sh May 12, 2022
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
4 changes: 4 additions & 0 deletions .github/workflows/build.yml
Expand Up @@ -2,6 +2,10 @@ on:
pull_request:
branches:
- master
paths:
- '**.rs'
- 'Cargo.*'
- '*/Cargo.*'

name: Build and Test

Expand Down
69 changes: 65 additions & 4 deletions Cargo.lock

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

4 changes: 1 addition & 3 deletions benchmarks/clients/mesh.rs
Expand Up @@ -3,7 +3,7 @@ use tokio::task;
use std::thread;
use std::path::PathBuf;
use bytes::Bytes;
use rumqttlog::router::{Data};
use rumqttlog::router::Data;

mod common;

Expand Down Expand Up @@ -74,5 +74,3 @@ async fn read(tx: Sender<(usize, RouterInMessage)>) {

println!("Id = {}, Total size = {}", id, total_size);
}


3 changes: 2 additions & 1 deletion benchmarks/clients/rumqttasync.rs
@@ -1,4 +1,5 @@
use rumqttc::*;
use rumqttc::{AsyncClient, Event, Incoming, MqttOptions, QoS};

use std::error::Error;
use std::time::{Duration, Instant};

Expand Down
3 changes: 2 additions & 1 deletion benchmarks/clients/rumqttasyncqos0.rs
@@ -1,4 +1,5 @@
use rumqttc::*;
use rumqttc::{AsyncClient, Event, Incoming, MqttOptions, QoS};

use std::error::Error;
use std::time::{Duration, Instant};

Expand Down
2 changes: 1 addition & 1 deletion benchmarks/clients/rumqttsync.rs
@@ -1,4 +1,4 @@
use rumqttc::{self, Client, Event, Incoming, MqttOptions, QoS};
use rumqttc::{Client, Event, Incoming, MqttOptions, QoS};
use std::error::Error;
use std::thread;
use std::time::{Duration, Instant};
Expand Down