diff options
author | Daniel Gultsch <daniel@gultsch.de> | 2016-08-09 19:21:54 +0200 |
---|---|---|
committer | Christian Schneppe <christian@pix-art.de> | 2016-08-11 21:36:58 +0200 |
commit | ead0feadf03b3b829e49894b630e3d420ddf40cf (patch) | |
tree | 8682eee570a242ee5005e56d90bb045d5d5adc71 /src/main/java/de/pixart | |
parent | 237e5f5f8861a5b88ddcd149e8503f933954a4e6 (diff) |
close tcp connection after 30s of inactivity when in push_mode
Diffstat (limited to '')
3 files changed, 31 insertions, 14 deletions
diff --git a/src/main/java/de/pixart/messenger/Config.java b/src/main/java/de/pixart/messenger/Config.java index 262123784..dbf2d6cbe 100644 --- a/src/main/java/de/pixart/messenger/Config.java +++ b/src/main/java/de/pixart/messenger/Config.java @@ -69,7 +69,10 @@ public final class Config { public static final int CONNECT_DISCO_TIMEOUT = 30; public static final int MINI_GRACE_PERIOD = 750; - public static final boolean CLOSE_TCP_WHEN_SWITCHING_TO_BACKGROUND = false; + public static final boolean PUSH_MODE = false; //closes the tcp connection when going to background + //and after PING_MIN_INTERVAL of inactivity + //very experimental. only enable this if you want + //to around with GCM push public static final int AVATAR_SIZE = 720; public static final Bitmap.CompressFormat AVATAR_FORMAT = Bitmap.CompressFormat.JPEG; diff --git a/src/main/java/de/pixart/messenger/services/EventReceiver.java b/src/main/java/de/pixart/messenger/services/EventReceiver.java index 3a48e5179..80e5b06b5 100644 --- a/src/main/java/de/pixart/messenger/services/EventReceiver.java +++ b/src/main/java/de/pixart/messenger/services/EventReceiver.java @@ -3,7 +3,9 @@ package de.pixart.messenger.services; import android.content.BroadcastReceiver; import android.content.Context; import android.content.Intent; +import android.net.ConnectivityManager; +import de.pixart.messenger.Config; import de.pixart.messenger.persistance.DatabaseBackend; public class EventReceiver extends BroadcastReceiver { @@ -16,8 +18,11 @@ public class EventReceiver extends BroadcastReceiver { } else { mIntentForService.setAction("other"); } - if (intent.getAction().equals("ui") - || DatabaseBackend.getInstance(context).hasEnabledAccounts()) { + final String action = intent.getAction(); + if (action.equals(ConnectivityManager.CONNECTIVITY_ACTION) && Config.PUSH_MODE) { + return; + } + if (action.equals("ui") || DatabaseBackend.getInstance(context).hasEnabledAccounts()) { context.startService(mIntentForService); } } 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()); } |