moonlight-stream/moonlight-android
1
0
Fork 0
mirror of https://github.com/moonlight-stream/moonlight-android.git synced 2025-07-20 19:42:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into 4k

Browse Source 
Conflicts:
	app/libs/limelight-common.jar
This commit is contained in:
Cameron Gutman 2015-10-31 15:44:36 -07:00
commit 74ea87676e
1 changed files with 62 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
app/src/main/java/com/limelight/computers/ComputerManagerService.java
View File

@ -31,11 +31,12 @@ import android.os.IBinder;
import org.xmlpull.v1.XmlPullParserException; import org.xmlpull.v1.XmlPullParserException;
public class ComputerManagerService extends Service { public class ComputerManagerService extends Service {
private static final int SERVERINFO_POLLING_PERIOD_MS = 3000; private static final int SERVERINFO_POLLING_PERIOD_MS = 1500;
private static final int APPLIST_POLLING_PERIOD_MS = 30000; private static final int APPLIST_POLLING_PERIOD_MS = 30000;
private static final int APPLIST_FAILED_POLLING_RETRY_MS = 2000;
private static final int MDNS_QUERY_PERIOD_MS = 1000; private static final int MDNS_QUERY_PERIOD_MS = 1000;
private static final int FAST_POLL_TIMEOUT = 500; private static final int FAST_POLL_TIMEOUT = 500;
private static final int OFFLINE_POLL_TRIES = 3; private static final int OFFLINE_POLL_TRIES = 5;
private final ComputerManagerBinder binder = new ComputerManagerBinder(); private final ComputerManagerBinder binder = new ComputerManagerBinder();
@ -119,7 +120,7 @@ public class ComputerManagerService extends Service {
return true; return true;
} }
private Thread createPollingThread(final ComputerDetails details) { private Thread createPollingThread(final PollingTuple tuple) {
Thread t = new Thread() { Thread t = new Thread() {
@Override @Override
public void run() { public void run() {
@ -127,24 +128,26 @@ public class ComputerManagerService extends Service {
int offlineCount = 0; int offlineCount = 0;
while (!isInterrupted() && pollingActive) { while (!isInterrupted() && pollingActive) {
try { try {
// Check if this poll has modified the details // Only allow one request to the machine at a time
if (!runPoll(details, false, offlineCount)) { synchronized (tuple.networkLock) {
LimeLog.warning(details.name + " is offline (try " + offlineCount + ")"); // Check if this poll has modified the details
offlineCount++; if (!runPoll(tuple.computer, false, offlineCount)) {
} LimeLog.warning(tuple.computer.name + " is offline (try " + offlineCount + ")");
else { offlineCount++;
offlineCount = 0; } else {
offlineCount = 0;
}
} }
// Wait until the next polling interval // Wait until the next polling interval
Thread.sleep(SERVERINFO_POLLING_PERIOD_MS / ((offlineCount > 0) ? 2 : 1)); Thread.sleep(SERVERINFO_POLLING_PERIOD_MS);
} catch (InterruptedException e) { } catch (InterruptedException e) {
break; break;
} }
} }
} }
}; };
t.setName("Polling thread for "+details.localIp.getHostAddress()); t.setName("Polling thread for " + tuple.computer.localIp.getHostAddress());
return t; return t;
} }
@ -166,7 +169,7 @@ public class ComputerManagerService extends Service {
// Report this computer initially // Report this computer initially
listener.notifyComputerUpdated(tuple.computer); listener.notifyComputerUpdated(tuple.computer);
tuple.thread = createPollingThread(tuple.computer); tuple.thread = createPollingThread(tuple);
tuple.thread.start(); tuple.thread.start();
} }
} }
@ -283,7 +286,7 @@ public class ComputerManagerService extends Service {
// Start a polling thread if polling is active // Start a polling thread if polling is active
if (pollingActive && tuple.thread == null) { if (pollingActive && tuple.thread == null) {
tuple.thread = createPollingThread(details); tuple.thread = createPollingThread(tuple);
tuple.thread.start(); tuple.thread.start();
} }
@ -293,7 +296,10 @@ public class ComputerManagerService extends Service {
} }
// If we got here, we didn't find an entry // If we got here, we didn't find an entry
PollingTuple tuple = new PollingTuple(details, pollingActive ? createPollingThread(details) : null); PollingTuple tuple = new PollingTuple(details, null);
if (pollingActive) {
tuple.thread = createPollingThread(tuple);
}
pollingTuples.add(tuple); pollingTuples.add(tuple);
if (tuple.thread != null) { if (tuple.thread != null) {
tuple.thread.start(); tuple.thread.start();
@ -607,6 +613,7 @@ public class ComputerManagerService extends Service {
private Thread thread; private Thread thread;
private final ComputerDetails computer; private final ComputerDetails computer;
private final Object pollEvent = new Object(); private final Object pollEvent = new Object();
private boolean receivedAppList = false;
public ApplistPoller(ComputerDetails computer) { public ApplistPoller(ComputerDetails computer) {
this.computer = computer; this.computer = computer;
@ -621,7 +628,15 @@ public class ComputerManagerService extends Service {
private boolean waitPollingDelay() { private boolean waitPollingDelay() {
try { try {
synchronized (pollEvent) { synchronized (pollEvent) {
pollEvent.wait(APPLIST_POLLING_PERIOD_MS); if (receivedAppList) {
// If we've already reported an app list successfully,
// wait the full polling period
pollEvent.wait(APPLIST_POLLING_PERIOD_MS);
}
else {
// If we've failed to get an app list so far, retry much earlier
pollEvent.wait(APPLIST_FAILED_POLLING_RETRY_MS);
}
} }
} catch (InterruptedException e) { } catch (InterruptedException e) {
return false; return false;
@ -630,6 +645,18 @@ public class ComputerManagerService extends Service {
return thread != null && !thread.isInterrupted(); return thread != null && !thread.isInterrupted();
} }
private PollingTuple getPollingTuple(ComputerDetails details) {
synchronized (pollingTuples) {
for (PollingTuple tuple : pollingTuples) {
if (details.uuid.equals(tuple.computer.uuid)) {
return tuple;
}
}
}
return null;
}
public void start() { public void start() {
thread = new Thread() { thread = new Thread() {
@Override @Override
@ -660,9 +687,23 @@ public class ComputerManagerService extends Service {
NvHTTP http = new NvHTTP(selectedAddr, idManager.getUniqueId(), NvHTTP http = new NvHTTP(selectedAddr, idManager.getUniqueId(),
null, PlatformBinding.getCryptoProvider(ComputerManagerService.this)); null, PlatformBinding.getCryptoProvider(ComputerManagerService.this));
PollingTuple tuple = getPollingTuple(computer);
try { try {
// Query the app list from the server String appList;
String appList = http.getAppListRaw(); if (tuple != null) {
// If we're polling this machine too, grab the network lock
// while doing the app list request to prevent other requests
// from being issued in the meantime.
synchronized (tuple.networkLock) {
appList = http.getAppListRaw();
}
}
else {
// No polling is happening now, so we just call it directly
appList = http.getAppListRaw();
}
List<NvApp> list = NvHTTP.getAppListByReader(new StringReader(appList)); List<NvApp> list = NvHTTP.getAppListByReader(new StringReader(appList));
if (appList != null && !appList.isEmpty() && !list.isEmpty()) { if (appList != null && !appList.isEmpty() && !list.isEmpty()) {
// Open the cache file // Open the cache file
@ -682,6 +723,7 @@ public class ComputerManagerService extends Service {
// Update the computer // Update the computer
computer.rawAppList = appList; computer.rawAppList = appList;
receivedAppList = true;
// Notify that the app list has been updated // Notify that the app list has been updated
// and ensure that the thread is still active // and ensure that the thread is still active
@ -718,10 +760,12 @@ public class ComputerManagerService extends Service {
class PollingTuple { class PollingTuple {
public Thread thread; public Thread thread;
public final ComputerDetails computer; public final ComputerDetails computer;
public final Object networkLock;
public PollingTuple(ComputerDetails computer, Thread thread) { public PollingTuple(ComputerDetails computer, Thread thread) {
this.computer = computer; this.computer = computer;
this.thread = thread; this.thread = thread;
this.networkLock = new Object();
} }
} }