Skip to content
This repository has been archived by the owner on Sep 15, 2021. It is now read-only.

feat: support packet splitting and multi-stream parallel transmission #5

Merged
merged 44 commits into from
Aug 25, 2021

Conversation

shjwudp
Copy link
Member

@shjwudp shjwudp commented Aug 25, 2021

No description provided.

@todo
Copy link

todo bot commented Aug 25, 2021

Consider dynamically assigning tasks to make the least stream full

bagua-net/src/bagua_net.rs

Lines 357 to 362 in 79fed32

// TODO: Consider dynamically assigning tasks to make the least stream full
parallel_streams.push(std::thread::spawn(move || {
let out_timer = std::time::Instant::now();
let mut sum_in_time = 0.;
for (data, state) in msg_receiver.iter() {
let in_timer = std::time::Instant::now();


This comment was generated by todo based on a TODO comment in 79fed32 in #5. cc @BaguaSys.

@shjwudp shjwudp requested a review from NOBLES5E August 25, 2021 06:30
@NOBLES5E NOBLES5E changed the title feat: Support unpacking and multi-stream parallel transmission feat: support unpacking and multi-stream parallel transmission Aug 25, 2021
@shjwudp
Copy link
Member Author

shjwudp commented Aug 25, 2021

@NOBLES5E README modified and ready to review.

@shjwudp shjwudp changed the title feat: support unpacking and multi-stream parallel transmission feat: support packet splitting and multi-stream parallel transmission Aug 25, 2021
@NOBLES5E NOBLES5E merged commit e9694b7 into master Aug 25, 2021
@shjwudp shjwudp deleted the profiling_and_promotion branch August 28, 2021 00:09
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants