aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/de/pixart/messenger/services/XmppConnectionService.java
diff options
context:
space:
mode:
authorDaniel Gultsch <daniel@gultsch.de>2016-08-09 19:21:54 +0200
committerChristian Schneppe <christian@pix-art.de>2016-08-11 21:36:58 +0200
commitead0feadf03b3b829e49894b630e3d420ddf40cf (patch)
tree8682eee570a242ee5005e56d90bb045d5d5adc71 /src/main/java/de/pixart/messenger/services/XmppConnectionService.java
parent237e5f5f8861a5b88ddcd149e8503f933954a4e6 (diff)
close tcp connection after 30s of inactivity when in push_mode
Diffstat (limited to 'src/main/java/de/pixart/messenger/services/XmppConnectionService.java')
-rw-r--r--src/main/java/de/pixart/messenger/services/XmppConnectionService.java31
1 files changed, 20 insertions, 11 deletions
diff --git a/src/main/java/de/pixart/messenger/services/XmppConnectionService.java b/src/main/java/de/pixart/messenger/services/XmppConnectionService.java
index 8b1000005..35d93765e 100644
--- a/src/main/java/de/pixart/messenger/services/XmppConnectionService.java
+++ b/src/main/java/de/pixart/messenger/services/XmppConnectionService.java
@@ -325,14 +325,15 @@ public class XmppConnectionService extends Service {
joinMuc(conversation);
}
account.pendingConferenceJoins.clear();
- scheduleWakeUpCall(Config.PING_MAX_INTERVAL, account.getUuid().hashCode());
+ scheduleWakeUpCall(Config.PUSH_MODE ? Config.PING_MIN_INTERVAL : Config.PING_MAX_INTERVAL, account.getUuid().hashCode());
} else if (account.getStatus() == Account.State.OFFLINE) {
resetSendingToWaiting(account);
final boolean disabled = account.isOptionSet(Account.OPTION_DISABLED);
- final boolean pushMode = Config.CLOSE_TCP_WHEN_SWITCHING_TO_BACKGROUND
+ final boolean listeners = checkListeners();
+ final boolean pushMode = Config.PUSH_MODE
&& mPushManagementService.available(account)
- && checkListeners();
- Log.d(Config.LOGTAG,account.getJid().toBareJid()+": push mode "+Boolean.toString(pushMode));
+ && listeners;
+ Log.d(Config.LOGTAG,account.getJid().toBareJid()+": push mode="+Boolean.toString(pushMode)+" listeners="+Boolean.toString(listeners));
if (!disabled && !pushMode) {
int timeToReconnect = mRandom.nextInt(20) + 10;
scheduleWakeUpCall(timeToReconnect, account.getUuid().hashCode());
@@ -580,7 +581,7 @@ public class XmppConnectionService extends Service {
break;
case ACTION_IDLE_PING:
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M
- && !Config.CLOSE_TCP_WHEN_SWITCHING_TO_BACKGROUND) {
+ && !Config.PUSH_MODE) {
scheduleNextIdlePing();
}
break;
@@ -611,7 +612,7 @@ public class XmppConnectionService extends Service {
if (account.getStatus() == Account.State.ONLINE) {
long lastReceived = account.getXmppConnection().getLastPacketReceived();
long lastSent = account.getXmppConnection().getLastPingSent();
- long pingInterval = "ui".equals(action) ? Config.PING_MIN_INTERVAL * 1000 : Config.PING_MAX_INTERVAL * 1000;
+ long pingInterval = (Config.PUSH_MODE || "ui".equals(action)) ? Config.PING_MIN_INTERVAL * 1000 : Config.PING_MAX_INTERVAL * 1000;
long msToNextPing = (Math.max(lastReceived, lastSent) + pingInterval) - SystemClock.elapsedRealtime();
long pingTimeoutIn = (lastSent + Config.PING_TIMEOUT * 1000) - SystemClock.elapsedRealtime();
if (lastSent > lastReceived) {
@@ -659,10 +660,18 @@ public class XmppConnectionService extends Service {
}
}
if (pingNow) {
+ final boolean listeners = checkListeners();
for (Account account : pingCandidates) {
- account.getXmppConnection().sendPing();
- Log.d(Config.LOGTAG, account.getJid().toBareJid() + " send ping (action="+action+")");
- this.scheduleWakeUpCall(Config.PING_TIMEOUT, account.getUuid().hashCode());
+ if (listeners
+ && Config.PUSH_MODE
+ && mPushManagementService.available(account)) {
+ account.getXmppConnection().waitForPush();
+ cancelWakeUpCall(account.getUuid().hashCode());
+ } else {
+ account.getXmppConnection().sendPing();
+ Log.d(Config.LOGTAG, account.getJid().toBareJid() + " send ping (action=" + action + ",listeners="+Boolean.toString(listeners)+")");
+ scheduleWakeUpCall(Config.PING_TIMEOUT, account.getUuid().hashCode());
+ }
}
}
if (wakeLock.isHeld()) {
@@ -799,7 +808,7 @@ public class XmppConnectionService extends Service {
updateUnreadCountBadge();
toggleScreenEventReceiver();
if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M
- && !Config.CLOSE_TCP_WHEN_SWITCHING_TO_BACKGROUND) {
+ && !Config.PUSH_MODE) {
scheduleNextIdlePing();
}
@@ -1871,7 +1880,7 @@ public class XmppConnectionService extends Service {
if (connection.getFeatures().csi()) {
connection.sendInactive();
}
- if (Config.CLOSE_TCP_WHEN_SWITCHING_TO_BACKGROUND && mPushManagementService.available(account)) {
+ if (Config.PUSH_MODE && mPushManagementService.available(account)) {
connection.waitForPush();
cancelWakeUpCall(account.getUuid().hashCode());
}