mirror of
https://github.com/Relintai/pandemonium_engine.git
synced 2024-12-23 20:36:53 +01:00
301 lines
14 KiB
Diff
301 lines
14 KiB
Diff
diff --git a/platform/android/java/src/com/google/android/vending/expansion/downloader/DownloaderClientMarshaller.java b/platform/android/java/src/com/google/android/vending/expansion/downloader/DownloaderClientMarshaller.java
|
|
index ad6ea0de6..452c7d148 100644
|
|
--- a/platform/android/java/src/com/google/android/vending/expansion/downloader/DownloaderClientMarshaller.java
|
|
+++ b/platform/android/java/src/com/google/android/vending/expansion/downloader/DownloaderClientMarshaller.java
|
|
@@ -32,6 +32,9 @@ import android.os.Messenger;
|
|
import android.os.RemoteException;
|
|
import android.util.Log;
|
|
|
|
+// -- PANDEMONIUM start --
|
|
+import java.lang.ref.WeakReference;
|
|
+// -- PANDEMONIUM end --
|
|
|
|
|
|
/**
|
|
@@ -118,29 +121,46 @@ public class DownloaderClientMarshaller {
|
|
/**
|
|
* Target we publish for clients to send messages to IncomingHandler.
|
|
*/
|
|
- final Messenger mMessenger = new Messenger(new Handler() {
|
|
+ // -- PANDEMONIUM start --
|
|
+ private final MessengerHandlerClient mMsgHandler = new MessengerHandlerClient(this);
|
|
+ final Messenger mMessenger = new Messenger(mMsgHandler);
|
|
+
|
|
+ private static class MessengerHandlerClient extends Handler {
|
|
+ private final WeakReference<Stub> mDownloader;
|
|
+ public MessengerHandlerClient(Stub downloader) {
|
|
+ mDownloader = new WeakReference<>(downloader);
|
|
+ }
|
|
+
|
|
@Override
|
|
public void handleMessage(Message msg) {
|
|
- switch (msg.what) {
|
|
- case MSG_ONDOWNLOADPROGRESS:
|
|
- Bundle bun = msg.getData();
|
|
- if ( null != mContext ) {
|
|
- bun.setClassLoader(mContext.getClassLoader());
|
|
- DownloadProgressInfo dpi = (DownloadProgressInfo) msg.getData()
|
|
- .getParcelable(PARAM_PROGRESS);
|
|
- mItf.onDownloadProgress(dpi);
|
|
- }
|
|
- break;
|
|
- case MSG_ONDOWNLOADSTATE_CHANGED:
|
|
- mItf.onDownloadStateChanged(msg.getData().getInt(PARAM_NEW_STATE));
|
|
- break;
|
|
- case MSG_ONSERVICECONNECTED:
|
|
- mItf.onServiceConnected(
|
|
- (Messenger) msg.getData().getParcelable(PARAM_MESSENGER));
|
|
- break;
|
|
+ Stub downloader = mDownloader.get();
|
|
+ if (downloader != null) {
|
|
+ downloader.handleMessage(msg);
|
|
}
|
|
}
|
|
- });
|
|
+ }
|
|
+
|
|
+ private void handleMessage(Message msg) {
|
|
+ switch (msg.what) {
|
|
+ case MSG_ONDOWNLOADPROGRESS:
|
|
+ Bundle bun = msg.getData();
|
|
+ if (null != mContext) {
|
|
+ bun.setClassLoader(mContext.getClassLoader());
|
|
+ DownloadProgressInfo dpi = (DownloadProgressInfo)msg.getData()
|
|
+ .getParcelable(PARAM_PROGRESS);
|
|
+ mItf.onDownloadProgress(dpi);
|
|
+ }
|
|
+ break;
|
|
+ case MSG_ONDOWNLOADSTATE_CHANGED:
|
|
+ mItf.onDownloadStateChanged(msg.getData().getInt(PARAM_NEW_STATE));
|
|
+ break;
|
|
+ case MSG_ONSERVICECONNECTED:
|
|
+ mItf.onServiceConnected(
|
|
+ (Messenger)msg.getData().getParcelable(PARAM_MESSENGER));
|
|
+ break;
|
|
+ }
|
|
+ }
|
|
+ // -- PANDEMONIUM end --
|
|
|
|
public Stub(IDownloaderClient itf, Class<?> downloaderService) {
|
|
mItf = itf;
|
|
diff --git a/platform/android/java/src/com/google/android/vending/expansion/downloader/DownloaderServiceMarshaller.java b/platform/android/java/src/com/google/android/vending/expansion/downloader/DownloaderServiceMarshaller.java
|
|
index 979352299..3771d19c9 100644
|
|
--- a/platform/android/java/src/com/google/android/vending/expansion/downloader/DownloaderServiceMarshaller.java
|
|
+++ b/platform/android/java/src/com/google/android/vending/expansion/downloader/DownloaderServiceMarshaller.java
|
|
@@ -25,6 +25,9 @@ import android.os.Message;
|
|
import android.os.Messenger;
|
|
import android.os.RemoteException;
|
|
|
|
+// -- PANDEMONIUM start --
|
|
+import java.lang.ref.WeakReference;
|
|
+// -- PANDEMONIUM end --
|
|
|
|
|
|
/**
|
|
@@ -108,32 +111,49 @@ public class DownloaderServiceMarshaller {
|
|
|
|
private static class Stub implements IStub {
|
|
private IDownloaderService mItf = null;
|
|
- final Messenger mMessenger = new Messenger(new Handler() {
|
|
+ // -- PANDEMONIUM start --
|
|
+ private final MessengerHandlerServer mMsgHandler = new MessengerHandlerServer(this);
|
|
+ final Messenger mMessenger = new Messenger(mMsgHandler);
|
|
+
|
|
+ private static class MessengerHandlerServer extends Handler {
|
|
+ private final WeakReference<Stub> mDownloader;
|
|
+ public MessengerHandlerServer(Stub downloader) {
|
|
+ mDownloader = new WeakReference<>(downloader);
|
|
+ }
|
|
+
|
|
@Override
|
|
public void handleMessage(Message msg) {
|
|
- switch (msg.what) {
|
|
- case MSG_REQUEST_ABORT_DOWNLOAD:
|
|
- mItf.requestAbortDownload();
|
|
- break;
|
|
- case MSG_REQUEST_CONTINUE_DOWNLOAD:
|
|
- mItf.requestContinueDownload();
|
|
- break;
|
|
- case MSG_REQUEST_PAUSE_DOWNLOAD:
|
|
- mItf.requestPauseDownload();
|
|
- break;
|
|
- case MSG_SET_DOWNLOAD_FLAGS:
|
|
- mItf.setDownloadFlags(msg.getData().getInt(PARAMS_FLAGS));
|
|
- break;
|
|
- case MSG_REQUEST_DOWNLOAD_STATE:
|
|
- mItf.requestDownloadStatus();
|
|
- break;
|
|
- case MSG_REQUEST_CLIENT_UPDATE:
|
|
- mItf.onClientUpdated((Messenger) msg.getData().getParcelable(
|
|
- PARAM_MESSENGER));
|
|
- break;
|
|
+ Stub downloader = mDownloader.get();
|
|
+ if (downloader != null) {
|
|
+ downloader.handleMessage(msg);
|
|
}
|
|
}
|
|
- });
|
|
+ }
|
|
+
|
|
+ private void handleMessage(Message msg) {
|
|
+ switch (msg.what) {
|
|
+ case MSG_REQUEST_ABORT_DOWNLOAD:
|
|
+ mItf.requestAbortDownload();
|
|
+ break;
|
|
+ case MSG_REQUEST_CONTINUE_DOWNLOAD:
|
|
+ mItf.requestContinueDownload();
|
|
+ break;
|
|
+ case MSG_REQUEST_PAUSE_DOWNLOAD:
|
|
+ mItf.requestPauseDownload();
|
|
+ break;
|
|
+ case MSG_SET_DOWNLOAD_FLAGS:
|
|
+ mItf.setDownloadFlags(msg.getData().getInt(PARAMS_FLAGS));
|
|
+ break;
|
|
+ case MSG_REQUEST_DOWNLOAD_STATE:
|
|
+ mItf.requestDownloadStatus();
|
|
+ break;
|
|
+ case MSG_REQUEST_CLIENT_UPDATE:
|
|
+ mItf.onClientUpdated((Messenger)msg.getData().getParcelable(
|
|
+ PARAM_MESSENGER));
|
|
+ break;
|
|
+ }
|
|
+ }
|
|
+ // -- PANDEMONIUM end --
|
|
|
|
public Stub(IDownloaderService itf) {
|
|
mItf = itf;
|
|
diff --git a/platform/android/java/src/com/google/android/vending/expansion/downloader/Helpers.java b/platform/android/java/src/com/google/android/vending/expansion/downloader/Helpers.java
|
|
index e4b1b0f1c..36cd6aacf 100644
|
|
--- a/platform/android/java/src/com/google/android/vending/expansion/downloader/Helpers.java
|
|
+++ b/platform/android/java/src/com/google/android/vending/expansion/downloader/Helpers.java
|
|
@@ -24,7 +24,10 @@ import android.os.StatFs;
|
|
import android.os.SystemClock;
|
|
import android.util.Log;
|
|
|
|
-import com.android.vending.expansion.downloader.R;
|
|
+// -- PANDEMONIUM start --
|
|
+//import com.android.vending.expansion.downloader.R;
|
|
+import net.relintai.pandemonium.pandemonium.R;
|
|
+// -- PANDEMONIUM end --
|
|
|
|
import java.io.File;
|
|
import java.text.SimpleDateFormat;
|
|
@@ -146,12 +149,14 @@ public class Helpers {
|
|
}
|
|
return "";
|
|
}
|
|
- return String.format("%.2f",
|
|
+ // -- PANDEMONIUM start --
|
|
+ return String.format(Locale.ENGLISH, "%.2f",
|
|
(float) overallProgress / (1024.0f * 1024.0f))
|
|
+ "MB /" +
|
|
- String.format("%.2f", (float) overallTotal /
|
|
+ String.format(Locale.ENGLISH, "%.2f", (float) overallTotal /
|
|
(1024.0f * 1024.0f))
|
|
+ "MB";
|
|
+ // -- PANDEMONIUM end --
|
|
}
|
|
|
|
/**
|
|
@@ -184,7 +189,9 @@ public class Helpers {
|
|
}
|
|
|
|
public static String getSpeedString(float bytesPerMillisecond) {
|
|
- return String.format("%.2f", bytesPerMillisecond * 1000 / 1024);
|
|
+ // -- PANDEMONIUM start --
|
|
+ return String.format(Locale.ENGLISH, "%.2f", bytesPerMillisecond * 1000 / 1024);
|
|
+ // -- PANDEMONIUM end --
|
|
}
|
|
|
|
public static String getTimeRemaining(long durationInMilliseconds) {
|
|
diff --git a/platform/android/java/src/com/google/android/vending/expansion/downloader/SystemFacade.java b/platform/android/java/src/com/google/android/vending/expansion/downloader/SystemFacade.java
|
|
index 12edd97ab..a0e1165cc 100644
|
|
--- a/platform/android/java/src/com/google/android/vending/expansion/downloader/SystemFacade.java
|
|
+++ b/platform/android/java/src/com/google/android/vending/expansion/downloader/SystemFacade.java
|
|
@@ -26,6 +26,10 @@ import android.net.NetworkInfo;
|
|
import android.telephony.TelephonyManager;
|
|
import android.util.Log;
|
|
|
|
+// -- PANDEMONIUM start --
|
|
+import android.annotation.SuppressLint;
|
|
+// -- PANDEMONIUM end --
|
|
+
|
|
/**
|
|
* Contains useful helper functions, typically tied to the application context.
|
|
*/
|
|
@@ -51,6 +55,7 @@ class SystemFacade {
|
|
return null;
|
|
}
|
|
|
|
+ @SuppressLint("MissingPermission")
|
|
NetworkInfo activeInfo = connectivity.getActiveNetworkInfo();
|
|
if (activeInfo == null) {
|
|
if (Constants.LOGVV) {
|
|
@@ -69,6 +74,7 @@ class SystemFacade {
|
|
return false;
|
|
}
|
|
|
|
+ @SuppressLint("MissingPermission")
|
|
NetworkInfo info = connectivity.getActiveNetworkInfo();
|
|
boolean isMobile = (info != null && info.getType() == ConnectivityManager.TYPE_MOBILE);
|
|
TelephonyManager tm = (TelephonyManager) mContext
|
|
diff --git a/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloadNotification.java b/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloadNotification.java
|
|
index f1536e80e..4b214b22d 100644
|
|
--- a/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloadNotification.java
|
|
+++ b/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloadNotification.java
|
|
@@ -16,7 +16,11 @@
|
|
|
|
package com.google.android.vending.expansion.downloader.impl;
|
|
|
|
-import com.android.vending.expansion.downloader.R;
|
|
+// -- PANDEMONIUM start --
|
|
+//import com.android.vending.expansion.downloader.R;
|
|
+import net.relintai.pandemonium.pandemonium.R;
|
|
+// -- PANDEMONIUM end --
|
|
+
|
|
import com.google.android.vending.expansion.downloader.DownloadProgressInfo;
|
|
import com.google.android.vending.expansion.downloader.DownloaderClientMarshaller;
|
|
import com.google.android.vending.expansion.downloader.Helpers;
|
|
diff --git a/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloadThread.java b/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloadThread.java
|
|
index b2e0e7af0..c114b8a64 100644
|
|
--- a/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloadThread.java
|
|
+++ b/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloadThread.java
|
|
@@ -146,8 +146,12 @@ public class DownloadThread {
|
|
|
|
try {
|
|
PowerManager pm = (PowerManager) mContext.getSystemService(Context.POWER_SERVICE);
|
|
- wakeLock = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, Constants.TAG);
|
|
- wakeLock.acquire();
|
|
+ // -- PANDEMONIUM start --
|
|
+ //wakeLock = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, Constants.TAG);
|
|
+ //wakeLock.acquire();
|
|
+ wakeLock = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, "org.pandemonium.game:wakelock");
|
|
+ wakeLock.acquire(20 * 60 * 1000L /*20 minutes*/);
|
|
+ // -- PANDEMONIUM end --
|
|
|
|
if (Constants.LOGV) {
|
|
Log.v(Constants.TAG, "initiating download for " + mInfo.mFileName);
|
|
diff --git a/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloaderService.java b/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloaderService.java
|
|
index 4babe476f..8d41a7690 100644
|
|
--- a/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloaderService.java
|
|
+++ b/platform/android/java/src/com/google/android/vending/expansion/downloader/impl/DownloaderService.java
|
|
@@ -50,6 +50,10 @@ import android.provider.Settings.Secure;
|
|
import android.telephony.TelephonyManager;
|
|
import android.util.Log;
|
|
|
|
+// -- PANDEMONIUM start --
|
|
+import android.annotation.SuppressLint;
|
|
+// -- PANDEMONIUM end --
|
|
+
|
|
import java.io.File;
|
|
|
|
/**
|
|
@@ -578,6 +582,7 @@ public abstract class DownloaderService extends CustomIntentService implements I
|
|
Log.w(Constants.TAG,
|
|
"couldn't get connectivity manager to poll network state");
|
|
} else {
|
|
+ @SuppressLint("MissingPermission")
|
|
NetworkInfo activeInfo = mConnectivityManager
|
|
.getActiveNetworkInfo();
|
|
updateNetworkState(activeInfo);
|