Fixed datacenter port switch condition
This commit is contained in:
parent
507d05aaf1
commit
ff85d74b85
@ -423,7 +423,7 @@ public class TcpConnection extends PyroClientAdapter {
|
|||||||
} else {
|
} else {
|
||||||
FileLog.d("tmessages", "Disconnected " + TcpConnection.this);
|
FileLog.d("tmessages", "Disconnected " + TcpConnection.this);
|
||||||
}
|
}
|
||||||
boolean swirchToNextPort = wasConnected && hasSomeDataSinceLastConnect;
|
boolean switchToNextPort = wasConnected && !hasSomeDataSinceLastConnect && timedout;
|
||||||
firstPacket = true;
|
firstPacket = true;
|
||||||
restOfTheData = null;
|
restOfTheData = null;
|
||||||
channelToken = 0;
|
channelToken = 0;
|
||||||
@ -452,7 +452,7 @@ public class TcpConnection extends PyroClientAdapter {
|
|||||||
}
|
}
|
||||||
if (ConnectionsManager.isNetworkOnline()) {
|
if (ConnectionsManager.isNetworkOnline()) {
|
||||||
isNextPort = true;
|
isNextPort = true;
|
||||||
if (failedConnectionCount > willRetryConnectCount || swirchToNextPort) {
|
if (failedConnectionCount > willRetryConnectCount || switchToNextPort) {
|
||||||
Datacenter datacenter = ConnectionsManager.Instance.datacenterWithId(datacenterId);
|
Datacenter datacenter = ConnectionsManager.Instance.datacenterWithId(datacenterId);
|
||||||
datacenter.nextAddressOrPort();
|
datacenter.nextAddressOrPort();
|
||||||
failedConnectionCount = 0;
|
failedConnectionCount = 0;
|
||||||
|
Loading…
Reference in New Issue
Block a user