break incase the connection with the server failed instead of retrying over and over
This commit is contained in:
parent
6d2c368fde
commit
3241818cba
|
@ -150,14 +150,14 @@ impl ActiveConnection {
|
||||||
Ok(stream) => stream,
|
Ok(stream) => stream,
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
warn!("error opening a unistream for {} error {}", identity, e);
|
warn!("error opening a unistream for {} error {}", identity, e);
|
||||||
continue;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
// validator no longer accepting connection
|
// validator no longer accepting connection
|
||||||
trace!("Could not reconnect to {} because of error {}", identity, e);
|
trace!("Could not reconnect to {} because of error {}", identity, e);
|
||||||
continue;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
@ -187,7 +187,7 @@ impl ActiveConnection {
|
||||||
},
|
},
|
||||||
Err(e) => {
|
Err(e) => {
|
||||||
warn!("Could not connect to {} because of error {}", identity, e);
|
warn!("Could not connect to {} because of error {}", identity, e);
|
||||||
continue;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue