|
@@ -184,14 +184,11 @@ impl InboundSession {
|
|
|
channel_id: channel.info.id,
|
|
channel_id: channel.info.id,
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
- match self.register_channel(channel.clone(), ex.clone()).await {
|
|
|
|
|
- Ok(()) => {}
|
|
|
|
|
- Err(e) => {
|
|
|
|
|
- warn!(
|
|
|
|
|
- target: "net::inbound_session::setup_channel()",
|
|
|
|
|
- "Channel setup failed! Err={}", e
|
|
|
|
|
- );
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ if let Err(e) = self.register_channel(channel.clone(), ex.clone()).await {
|
|
|
|
|
+ warn!(
|
|
|
|
|
+ target: "net::inbound_session::setup_channel()",
|
|
|
|
|
+ "Channel setup failed! Err={}", e
|
|
|
|
|
+ );
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
dnetev!(self, InboundDisconnected, {
|
|
dnetev!(self, InboundDisconnected, {
|