fixed warning (#7519)
This commit is contained in:
parent
e95b093483
commit
73f5cc57be
@ -688,7 +688,7 @@ impl ClusterConnections {
|
|||||||
|
|
||||||
pub fn remove(&self, data: Arc<ClusterData>, node: &NodeId, is_inbound: bool) {
|
pub fn remove(&self, data: Arc<ClusterData>, node: &NodeId, is_inbound: bool) {
|
||||||
{
|
{
|
||||||
let mut data = &mut *self.data.write();
|
let mut data = self.data.write();
|
||||||
if let Entry::Occupied(entry) = data.connections.entry(node.clone()) {
|
if let Entry::Occupied(entry) = data.connections.entry(node.clone()) {
|
||||||
if entry.get().is_inbound() != is_inbound {
|
if entry.get().is_inbound() != is_inbound {
|
||||||
return;
|
return;
|
||||||
|
Loading…
Reference in New Issue
Block a user