change fix timestamp logic

Author: pedroSG94

encoder/src/main/java/com/pedro/encoder/BaseEncoder.java

@@ -51,12 +51,12 @@ public abstract class BaseEncoder implements EncoderCallback {
   private ExecutorService executorService;
   protected BlockingQueue<Frame> queue = new ArrayBlockingQueue<>(80);
   protected MediaCodec codec;
-  protected long presentTimeUs;
+  protected volatile long presentTimeUs;
   protected volatile boolean running = false;
   protected boolean isBufferMode = true;
   protected CodecUtil.CodecType codecType = CodecUtil.CodecType.FIRST_COMPATIBLE_FOUND;
   private MediaCodec.Callback callback;
-  private long oldTimeStamp = 0L;
+  private volatile long oldTimeStamp = 0L;
   protected boolean shouldReset = true;
   protected boolean prepared = false;
   private Handler handler;
@@ -134,10 +134,10 @@ private void initCodec() {
 
   protected void fixTimeStamp(MediaCodec.BufferInfo info) {
     if (oldTimeStamp > info.presentationTimeUs) {
-      info.presentationTimeUs = oldTimeStamp;
-    } else {
-      oldTimeStamp = info.presentationTimeUs;
+      final long currentTs = TimeUtils.getCurrentTimeMicro() - presentTimeUs;
+      info.presentationTimeUs = Math.max(currentTs, oldTimeStamp + 1);
     }
+    oldTimeStamp = info.presentationTimeUs;
   }
 
   private void reloadCodec(IllegalStateException e) {

encoder/src/main/java/com/pedro/encoder/audio/AudioEncoder.java

@@ -160,7 +160,7 @@ protected long calculatePts(Frame frame, long presentTimeUs) {
   @Override
   protected void checkBuffer(@NonNull ByteBuffer byteBuffer,
       @NonNull MediaCodec.BufferInfo bufferInfo) {
-    //fixTimeStamp(bufferInfo);
+    fixTimeStamp(bufferInfo);
   }
 
   @Override