moonlight-stream/moonlight-android
1
0
Fork 0
mirror of https://github.com/moonlight-stream/moonlight-android.git synced 2025-07-21 03:52:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use a less power intensive way of keeping the DVFS state friendly

Browse Source
This commit is contained in:
Cameron Gutman 2017-05-29 20:11:39 -07:00
parent 49e51f5f6f
commit 08bcd97594
1 changed files with 33 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
app/src/main/java/com/limelight/binding/video/MediaCodecDecoderRenderer.java
View File

@ -31,7 +31,8 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
private MediaCodecInfo hevcDecoder; private MediaCodecInfo hevcDecoder;
private MediaCodec videoDecoder; private MediaCodec videoDecoder;
private Thread rendererThread, spinnerThread; private Thread rendererThread;
private Thread[] spinnerThreads;
private boolean needsSpsBitstreamFixup, isExynos4; private boolean needsSpsBitstreamFixup, isExynos4;
private boolean adaptivePlayback, directSubmit; private boolean adaptivePlayback, directSubmit;
private boolean constrainedHighProfile; private boolean constrainedHighProfile;
@ -97,6 +98,8 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
public MediaCodecDecoderRenderer(int videoFormat) { public MediaCodecDecoderRenderer(int videoFormat) {
//dumpDecoders(); //dumpDecoders();
spinnerThreads = new Thread[Runtime.getRuntime().availableProcessors()];
avcDecoder = findAvcDecoder(); avcDecoder = findAvcDecoder();
if (avcDecoder != null) { if (avcDecoder != null) {
LimeLog.info("Selected AVC decoder: "+avcDecoder.getName()); LimeLog.info("Selected AVC decoder: "+avcDecoder.getName());
@ -346,19 +349,26 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
rendererThread.start(); rendererThread.start();
} }
private void startSpinnerThread() { private void startSpinnerThreads() {
spinnerThread = new Thread() { LimeLog.info("Using "+spinnerThreads.length+" spinner threads");
for (int i = 0; i < spinnerThreads.length; i++) {
spinnerThreads[i] = new Thread() {
@Override @Override
public void run() { public void run() {
// This thread exists to keep the CPU at a higher DVFS state on devices // This thread exists to keep the CPU at a higher DVFS state on devices
// where the governor scales clock speed sporadically, causing dropped frames. // where the governor scales clock speed sporadically, causing dropped frames.
while (!isInterrupted()) { while (!isInterrupted()) {
Thread.yield(); try {
Thread.sleep(0, 1);
} catch (InterruptedException e) {
break;
}
} }
} }
}; };
spinnerThread.setPriority(Thread.MIN_PRIORITY); spinnerThreads[i].setPriority(Thread.MIN_PRIORITY);
spinnerThread.start(); spinnerThreads[i].start();
}
} }
private int dequeueInputBuffer() { private int dequeueInputBuffer() {
@ -392,7 +402,7 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
@Override @Override
public void start() { public void start() {
startRendererThread(); startRendererThread();
startSpinnerThread(); startSpinnerThreads();
} }
@Override @Override
@ -405,12 +415,16 @@ public class MediaCodecDecoderRenderer extends VideoDecoderRenderer {
rendererThread.join(); rendererThread.join();
} catch (InterruptedException ignored) { } } catch (InterruptedException ignored) { }
// Halt the spinner thread // Halt the spinner threads
spinnerThread.interrupt(); for (Thread t : spinnerThreads) {
t.interrupt();
}
for (Thread t : spinnerThreads) {
try { try {
spinnerThread.join(); t.join();
} catch (InterruptedException ignored) { } } catch (InterruptedException ignored) { }
} }
}
@Override @Override
public void cleanup() { public void cleanup() {