Просмотр исходного кода

net: rename selector_id() to type_id()

lunar-mining 4 лет назад
Родитель
Сommit
af68236b8a

+ 4 - 0
src/net/channel.rs

@@ -98,6 +98,10 @@ impl Channel {
         self.info.lock().await.get_info().await
     }
 
+    async fn session_type_id(&self) -> Result<()> {
+        //
+    }
+
     /// Starts the channel. Runs a receive loop to start receiving messages or
     /// handles a network failure.
     pub fn start(self: Arc<Self>, executor: Arc<Executor<'_>>) {

+ 1 - 1
src/net/session/inbound_session.rs

@@ -160,7 +160,7 @@ impl Session for InboundSession {
         self.p2p.upgrade().unwrap()
     }
 
-    fn selector_id(&self) -> SessionBitflag {
+    fn type_id(&self) -> SessionBitflag {
         SESSION_INBOUND
     }
 }

+ 1 - 1
src/net/session/manual_session.rs

@@ -146,7 +146,7 @@ impl Session for ManualSession {
         self.p2p.upgrade().unwrap()
     }
 
-    fn selector_id(&self) -> SessionBitflag {
+    fn type_id(&self) -> SessionBitflag {
         SESSION_MANUAL
     }
 }

+ 2 - 2
src/net/session/mod.rs

@@ -87,7 +87,7 @@ pub trait Session: Sync {
         // They are currently in sleep mode.
         let p2p = self.p2p();
         let protocols =
-            p2p.protocol_registry().attach(self.selector_id(), channel.clone(), p2p.clone()).await;
+            p2p.protocol_registry().attach(self.type_id(), channel.clone(), p2p.clone()).await;
 
         // Perform the handshake protocol
         let protocol_version = ProtocolVersion::new(channel.clone(), self.p2p().settings()).await;
@@ -144,5 +144,5 @@ pub trait Session: Sync {
     /// Returns a pointer to the p2p network interface.
     fn p2p(&self) -> P2pPtr;
 
-    fn selector_id(&self) -> u32;
+    fn type_id(&self) -> u32;
 }

+ 1 - 1
src/net/session/outbound_session.rs

@@ -256,7 +256,7 @@ impl Session for OutboundSession {
         self.p2p.upgrade().unwrap()
     }
 
-    fn selector_id(&self) -> SessionBitflag {
+    fn type_id(&self) -> SessionBitflag {
         SESSION_OUTBOUND
     }
 }

+ 1 - 1
src/net/session/seed_session.rs

@@ -163,7 +163,7 @@ impl Session for SeedSession {
         self.p2p.upgrade().unwrap()
     }
 
-    fn selector_id(&self) -> SessionBitflag {
+    fn type_id(&self) -> SessionBitflag {
         SESSION_SEED
     }
 }