It's WOOOOOOOOORKIIIIIIING

Author: jlucidar

app/src/main/java/com/example/ijdfpvviewer/H264Extractor.java

@@ -19,22 +19,20 @@
 
 import java.io.IOException;
 import java.util.ArrayList;
-import java.util.List;
 
 import static com.google.android.exoplayer2.extractor.ts.TsPayloadReader.FLAG_DATA_ALIGNMENT_INDICATOR;
-
 /**
  * Extracts data from H264 bitstreams.
  */
 public final class H264Extractor implements Extractor {
-
     /** Factory for {@link H264Extractor} instances. */
     public static final ExtractorsFactory FACTORY = () -> new Extractor[] {new H264Extractor()};
 
     private static final int MAX_SYNC_FRAME_SIZE = 30 * 1024;
     private static final int ID3_TAG = Util.getIntegerCodeForString("ID3");
 
-    private final long firstSampleTimestampUs;
+    private long firstSampleTimestampUs;
+    private long sampleTime = 200; // todo: try to lower this. it directly infer on speed and latency
     private final H264Reader reader;
     private final ParsableByteArray sampleData;
 
@@ -51,7 +49,6 @@ public H264Extractor(long firstSampleTimestampUs) {
     }
 
     // Extractor implementation.
-
     @Override
     public boolean sniff(ExtractorInput input) throws IOException {
         return true;
@@ -90,6 +87,8 @@ public int read(ExtractorInput input, PositionHolder seekPosition) throws IOExce
             reader.packetStarted(firstSampleTimestampUs, FLAG_DATA_ALIGNMENT_INDICATOR);
             startedPacket = true;
         }
+        firstSampleTimestampUs+=sampleTime;
+        reader.packetStarted(firstSampleTimestampUs, FLAG_DATA_ALIGNMENT_INDICATOR);
         // TODO: Make it possible for the reader to consume the dataSource directly, so that it becomes
         // unnecessary to copy the data through packetBuffer.
         reader.consume(sampleData);

app/src/main/java/com/example/ijdfpvviewer/InputStreamDataSource.java

@@ -41,9 +41,7 @@ public long open(DataSpec dataSpec) throws IOException {
             if (dataSpec.length != C.LENGTH_UNSET) {
                 bytesRemaining = dataSpec.length;
             } else {
-                bytesRemaining = inputStream.available();
-                if (bytesRemaining == Integer.MAX_VALUE)
-                    bytesRemaining = C.LENGTH_UNSET;
+                bytesRemaining = C.LENGTH_UNSET;
             }
         } catch (IOException e) {
             throw new IOException(e);
@@ -55,32 +53,7 @@ public long open(DataSpec dataSpec) throws IOException {
 
     @Override
     public int read(byte[] buffer, int offset, int readLength) throws IOException {
-        if (readLength == 0) {
-            return 0;
-        } else if (bytesRemaining == 0) {
-            return C.RESULT_END_OF_INPUT;
-        }
-
-        int bytesRead;
-        try {
-            int bytesToRead = bytesRemaining == C.LENGTH_UNSET ? readLength
-                    : (int) Math.min(bytesRemaining, readLength);
-            bytesRead = inputStream.read(buffer, offset, bytesToRead);
-        } catch (IOException e) {
-            throw new IOException(e);
-        }
-
-        if (bytesRead == -1) {
-            if (bytesRemaining != C.LENGTH_UNSET) {
-                // End of stream reached having not read sufficient data.
-                throw new IOException(new EOFException());
-            }
-            return C.RESULT_END_OF_INPUT;
-        }
-        if (bytesRemaining != C.LENGTH_UNSET) {
-            bytesRemaining -= bytesRead;
-        }
-        return bytesRead;
+        return inputStream.read(buffer,offset,readLength);
     }
 
     @Override

app/src/main/java/com/example/ijdfpvviewer/VideoReaderExoplayer.java

@@ -22,17 +22,17 @@ public class VideoReaderExoplayer {
         private SimpleExoPlayer mPlayer;
 
         VideoReaderExoplayer(InputStream input, SurfaceView videoSurface, Context c){
-            DefaultLoadControl loadControl = new DefaultLoadControl.Builder().setBufferDurationsMs(32*1024, 64*1024, 0, 0).createDefaultLoadControl();
+            DefaultLoadControl loadControl = new DefaultLoadControl.Builder().setBufferDurationsMs(32*1024, 64*1024, 0, 0).build();
             mPlayer = new SimpleExoPlayer.Builder(c).setLoadControl(loadControl).build();
 
             mPlayer.setVideoSurfaceView(videoSurface);
             mPlayer.setVideoScalingMode(C.VIDEO_SCALING_MODE_SCALE_TO_FIT_WITH_CROPPING);
 
-            DataSpec dataSpec = new DataSpec(Uri.parse("test"));
+            DataSpec dataSpec = new DataSpec(Uri.parse(""),0,C.LENGTH_UNSET);
 
             DataSource.Factory  dataSourceFactory = () -> (DataSource) new InputStreamDataSource(c, dataSpec, input);
 
-            MediaSource mediaSource = new ProgressiveMediaSource.Factory(dataSourceFactory,H264Extractor.FACTORY).createMediaSource(MediaItem.fromUri(Uri.parse("test")));
+            MediaSource mediaSource = new ProgressiveMediaSource.Factory(dataSourceFactory,H264Extractor.FACTORY).createMediaSource(MediaItem.fromUri(Uri.parse("")));
             mPlayer.setMediaSource(mediaSource);
         }
 

settings.gradle

@@ -0,0 +1,2 @@
+include ':app'
+rootProject.name = "fpv_viewer_android"