close tcp connection after 30s of inactivity when in push_mode
This commit is contained in:
parent
237e5f5f88
commit
ead0feadf0
3 changed files with 31 additions and 14 deletions
src/main/java/de/pixart/messenger
|
@ -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;
|
||||
|
|
|
@ -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);
|
||||
}
|
||||
}
|
||||
|
|
|
@ -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());
|
||||
}
|
||||
|
|
Reference in a new issue