mirror of
https://github.com/Qortal/altcoinj.git
synced 2025-02-07 23:03:04 +00:00
Remove a couple of checkNotLocked asserts that didn't get deleted last time.
This commit is contained in:
parent
7696835f86
commit
b7eab44990
@ -519,7 +519,6 @@ public class PeerGroup extends AbstractIdleService {
|
|||||||
|
|
||||||
/** Picks a peer from discovery and connects to it. If connection fails, picks another and tries again. */
|
/** Picks a peer from discovery and connects to it. If connection fails, picks another and tries again. */
|
||||||
protected void connectToAnyPeer() throws PeerDiscoveryException {
|
protected void connectToAnyPeer() throws PeerDiscoveryException {
|
||||||
checkState(!lock.isLocked());
|
|
||||||
final State state = state();
|
final State state = state();
|
||||||
if (!(state == State.STARTING || state == State.RUNNING)) return;
|
if (!(state == State.STARTING || state == State.RUNNING)) return;
|
||||||
|
|
||||||
@ -691,7 +690,6 @@ public class PeerGroup extends AbstractIdleService {
|
|||||||
|
|
||||||
// Internal version.
|
// Internal version.
|
||||||
protected ChannelFuture connectTo(SocketAddress address, boolean incrementMaxConnections) {
|
protected ChannelFuture connectTo(SocketAddress address, boolean incrementMaxConnections) {
|
||||||
checkState(!lock.isLocked());
|
|
||||||
ChannelFuture future = bootstrap.connect(address);
|
ChannelFuture future = bootstrap.connect(address);
|
||||||
// Make sure that the channel group gets access to the channel only if it connects successfully (otherwise
|
// Make sure that the channel group gets access to the channel only if it connects successfully (otherwise
|
||||||
// it cannot be closed and trying to do so will cause problems).
|
// it cannot be closed and trying to do so will cause problems).
|
||||||
|
Loading…
x
Reference in New Issue
Block a user