aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJake McGinty <me@jake.su>2018-06-01 22:10:29 -0500
committerJake McGinty <me@jake.su>2018-06-01 22:10:29 -0500
commit72881d86a81165c5c3d3b54a6337bfd02b8bdbc5 (patch)
treef4e47057cdb7113569e621a3767f9f58dacc17e5
parentcrossbeam crypto pool (diff)
downloadwireguard-rs-72881d86a81165c5c3d3b54a6337bfd02b8bdbc5.tar.xz
wireguard-rs-72881d86a81165c5c3d3b54a6337bfd02b8bdbc5.zip
use unbounded_send in thread pool
-rw-r--r--src/crypto_pool.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/crypto_pool.rs b/src/crypto_pool.rs
index b77b9fd..2208e98 100644
--- a/src/crypto_pool.rs
+++ b/src/crypto_pool.rs
@@ -78,12 +78,12 @@ fn worker(receiver: Receiver<Work>) {
raw_packet.truncate(0);
}
- executor::spawn(tx.send(DecryptResult {
+ tx.unbounded_send(DecryptResult {
endpoint: element.endpoint,
orig_packet: element.packet,
out_packet: raw_packet,
session_type: element.session_type,
- })).wait_future();
+ }).unwrap();
},
Work::Encrypt((tx, mut element)) => {
let padding = if element.in_packet.len() % PADDING_MULTIPLE != 0 {
@@ -102,11 +102,11 @@ fn worker(receiver: Receiver<Work>) {
&mut out_packet[16..]).unwrap();
out_packet.truncate(TRANSPORT_HEADER_SIZE + len);
- executor::spawn(tx.send(EncryptResult {
+ tx.unbounded_send(EncryptResult {
endpoint: element.endpoint,
our_index: element.our_index,
out_packet,
- })).wait_future();
+ }).unwrap();
}
}
}