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

Revert "Disable latency tracking due to performance problems"

Browse Source 
This reverts commit 3dd57e9f38eb4b0ac6320706f38bb08db2549be5.
This commit is contained in:
Cameron Gutman 2014-07-01 19:51:45 -07:00
parent 3f00885d2c
commit 1d27309e53
1 changed files with 22 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/com/limelight/binding/video/MediaCodecDecoderRenderer.java
View File

@ -28,6 +28,10 @@ public class MediaCodecDecoderRenderer implements VideoDecoderRenderer {
private boolean needsSpsNumRefFixup; private boolean needsSpsNumRefFixup;
private VideoDepacketizer depacketizer; private VideoDepacketizer depacketizer;
private long totalTimeMs;
private long decoderTimeMs;
private int totalFrames;
private final static byte[] BITSTREAM_RESTRICTIONS = new byte[] {(byte) 0xF1, (byte) 0x83, 0x2A, 0x00}; private final static byte[] BITSTREAM_RESTRICTIONS = new byte[] {(byte) 0xF1, (byte) 0x83, 0x2A, 0x00};
public static final List<String> blacklistedDecoderPrefixes; public static final List<String> blacklistedDecoderPrefixes;
@ -179,6 +183,13 @@ public class MediaCodecDecoderRenderer implements VideoDecoderRenderer {
if (outIndex >= 0) { if (outIndex >= 0) {
int lastIndex = outIndex; int lastIndex = outIndex;
// Add delta time to the totals (excluding probable outliers)
long delta = System.currentTimeMillis()-info.presentationTimeUs;
if (delta > 5 && delta < 300) {
decoderTimeMs += delta;
totalTimeMs += delta;
}
// Get the last output buffer in the queue // Get the last output buffer in the queue
while ((outIndex = videoDecoder.dequeueOutputBuffer(info, 0)) >= 0) { while ((outIndex = videoDecoder.dequeueOutputBuffer(info, 0)) >= 0) {
videoDecoder.releaseOutputBuffer(lastIndex, false); videoDecoder.releaseOutputBuffer(lastIndex, false);
@ -237,6 +248,13 @@ public class MediaCodecDecoderRenderer implements VideoDecoderRenderer {
{ {
ByteBuffer buf = videoDecoderInputBuffers[inputIndex]; ByteBuffer buf = videoDecoderInputBuffers[inputIndex];
long currentTime = System.currentTimeMillis();
long delta = currentTime-decodeUnit.getReceiveTimestamp();
if (delta >= 0 && delta < 300) {
totalTimeMs += currentTime-decodeUnit.getReceiveTimestamp();
totalFrames++;
}
// Clear old input data // Clear old input data
buf.clear(); buf.clear();
@ -309,7 +327,7 @@ public class MediaCodecDecoderRenderer implements VideoDecoderRenderer {
videoDecoder.queueInputBuffer(inputIndex, videoDecoder.queueInputBuffer(inputIndex,
0, spsLength, 0, spsLength,
0, codecFlags); currentTime, codecFlags);
return true; return true;
} }
} }
@ -322,7 +340,7 @@ public class MediaCodecDecoderRenderer implements VideoDecoderRenderer {
videoDecoder.queueInputBuffer(inputIndex, videoDecoder.queueInputBuffer(inputIndex,
0, decodeUnit.getDataLength(), 0, decodeUnit.getDataLength(),
0, codecFlags); currentTime, codecFlags);
} }
return true; return true;
@ -414,11 +432,11 @@ public class MediaCodecDecoderRenderer implements VideoDecoderRenderer {
@Override @Override
public int getAverageDecoderLatency() { public int getAverageDecoderLatency() {
return 0; return (int)(decoderTimeMs / totalFrames);
} }
@Override @Override
public int getAverageEndToEndLatency() { public int getAverageEndToEndLatency() {
return 0; return (int)(totalTimeMs / totalFrames);
} }
} }