aboutsummaryrefslogtreecommitdiff
path: root/p2p/src/discovery
diff options
context:
space:
mode:
Diffstat (limited to 'p2p/src/discovery')
-rw-r--r--p2p/src/discovery/lookup.rs4
-rw-r--r--p2p/src/discovery/mod.rs4
-rw-r--r--p2p/src/discovery/refresh.rs6
3 files changed, 7 insertions, 7 deletions
diff --git a/p2p/src/discovery/lookup.rs b/p2p/src/discovery/lookup.rs
index aefc3a0..1d73306 100644
--- a/p2p/src/discovery/lookup.rs
+++ b/p2p/src/discovery/lookup.rs
@@ -5,9 +5,9 @@ use log::{error, trace};
use rand::{rngs::OsRng, seq::SliceRandom, RngCore};
use smol::lock::{Mutex, RwLock};
-use karyons_core::{async_util::timeout, crypto::KeyPair, util::decode, GlobalExecutor};
+use karyon_core::{async_util::timeout, crypto::KeyPair, util::decode, GlobalExecutor};
-use karyons_net::{Conn, Endpoint};
+use karyon_net::{Conn, Endpoint};
use crate::{
codec::Codec,
diff --git a/p2p/src/discovery/mod.rs b/p2p/src/discovery/mod.rs
index 8091991..040a415 100644
--- a/p2p/src/discovery/mod.rs
+++ b/p2p/src/discovery/mod.rs
@@ -7,13 +7,13 @@ use log::{error, info};
use rand::{rngs::OsRng, seq::SliceRandom};
use smol::lock::Mutex;
-use karyons_core::{
+use karyon_core::{
async_util::{Backoff, TaskGroup, TaskResult},
crypto::KeyPair,
GlobalExecutor,
};
-use karyons_net::{Conn, Endpoint};
+use karyon_net::{Conn, Endpoint};
use crate::{
config::Config,
diff --git a/p2p/src/discovery/refresh.rs b/p2p/src/discovery/refresh.rs
index 180ac27..ed111fb 100644
--- a/p2p/src/discovery/refresh.rs
+++ b/p2p/src/discovery/refresh.rs
@@ -9,13 +9,13 @@ use smol::{
Timer,
};
-use karyons_core::{
+use karyon_core::{
async_util::{timeout, Backoff, TaskGroup, TaskResult},
util::{decode, encode},
GlobalExecutor,
};
-use karyons_net::{dial_udp, listen_udp, Addr, Connection, Endpoint, NetError, Port, UdpConn};
+use karyon_net::{dial_udp, listen_udp, Addr, Connection, Endpoint, NetError, Port, UdpConn};
/// Maximum failures for an entry before removing it from the routing table.
pub const MAX_FAILURES: u32 = 3;
@@ -200,7 +200,7 @@ impl RefreshService {
while retry < self.config.refresh_connect_retries {
match self.send_ping_msg(&conn).await {
Ok(()) => return Ok(()),
- Err(Error::KaryonsNet(NetError::Timeout)) => {
+ Err(Error::KaryonNet(NetError::Timeout)) => {
retry += 1;
backoff.sleep().await;
}