aboutsummaryrefslogtreecommitdiff
path: root/p2p
diff options
context:
space:
mode:
Diffstat (limited to 'p2p')
-rw-r--r--p2p/src/connector.rs2
-rw-r--r--p2p/src/discovery/mod.rs2
-rw-r--r--p2p/src/discovery/refresh.rs2
-rw-r--r--p2p/src/listener.rs2
-rw-r--r--p2p/src/peer/mod.rs2
-rw-r--r--p2p/src/peer_pool.rs2
-rw-r--r--p2p/src/protocols/ping.rs2
7 files changed, 7 insertions, 7 deletions
diff --git a/p2p/src/connector.rs b/p2p/src/connector.rs
index 9bf63f9..de9e746 100644
--- a/p2p/src/connector.rs
+++ b/p2p/src/connector.rs
@@ -52,7 +52,7 @@ impl Connector {
Arc::new(Self {
key_pair: key_pair.clone(),
max_retries,
- task_group: TaskGroup::new(ex),
+ task_group: TaskGroup::with_executor(ex),
monitor,
connection_slots,
enable_tls,
diff --git a/p2p/src/discovery/mod.rs b/p2p/src/discovery/mod.rs
index 4b54233..3e437aa 100644
--- a/p2p/src/discovery/mod.rs
+++ b/p2p/src/discovery/mod.rs
@@ -116,7 +116,7 @@ impl Discovery {
outbound_slots,
connector,
listener,
- task_group: TaskGroup::new(ex),
+ task_group: TaskGroup::with_executor(ex),
config,
})
}
diff --git a/p2p/src/discovery/refresh.rs b/p2p/src/discovery/refresh.rs
index e56f0eb..035a581 100644
--- a/p2p/src/discovery/refresh.rs
+++ b/p2p/src/discovery/refresh.rs
@@ -70,7 +70,7 @@ impl RefreshService {
Self {
table,
listen_endpoint,
- task_group: TaskGroup::new(executor.clone()),
+ task_group: TaskGroup::with_executor(executor.clone()),
executor,
config,
monitor,
diff --git a/p2p/src/listener.rs b/p2p/src/listener.rs
index c9b7390..4a41482 100644
--- a/p2p/src/listener.rs
+++ b/p2p/src/listener.rs
@@ -46,7 +46,7 @@ impl Listener {
Arc::new(Self {
key_pair: key_pair.clone(),
connection_slots,
- task_group: TaskGroup::new(ex),
+ task_group: TaskGroup::with_executor(ex),
enable_tls,
monitor,
})
diff --git a/p2p/src/peer/mod.rs b/p2p/src/peer/mod.rs
index 1fc5ccf..ca68530 100644
--- a/p2p/src/peer/mod.rs
+++ b/p2p/src/peer/mod.rs
@@ -76,7 +76,7 @@ impl Peer {
remote_endpoint,
conn_direction,
protocol_events: EventSys::new(),
- task_group: TaskGroup::new(ex),
+ task_group: TaskGroup::with_executor(ex),
stop_chan: channel::bounded(1),
})
}
diff --git a/p2p/src/peer_pool.rs b/p2p/src/peer_pool.rs
index 48499fe..4e20c99 100644
--- a/p2p/src/peer_pool.rs
+++ b/p2p/src/peer_pool.rs
@@ -80,7 +80,7 @@ impl PeerPool {
peers: Mutex::new(HashMap::new()),
protocols,
protocol_versions,
- task_group: TaskGroup::new(executor.clone()),
+ task_group: TaskGroup::with_executor(executor.clone()),
executor,
monitor,
config,
diff --git a/p2p/src/protocols/ping.rs b/p2p/src/protocols/ping.rs
index 4885c1e..f04e059 100644
--- a/p2p/src/protocols/ping.rs
+++ b/p2p/src/protocols/ping.rs
@@ -50,7 +50,7 @@ impl PingProtocol {
peer,
ping_interval,
ping_timeout,
- task_group: TaskGroup::new(executor),
+ task_group: TaskGroup::with_executor(executor),
})
}