统计插入帧的时间

gb28181library/src/main/cpp/gb28181_muxer.cpp

@@ -130,6 +130,10 @@ int GB28181Muxer::sendVideoFrame(uint8_t *buf) {
     memcpy(new_buf, buf, in_y_size * 3 / 2);
     video_queue.push(new_buf);
 
+    int64_t  nowPushTime = getCurrentTime();
+    LOGI("[muxer]推入帧间隔时间:%lld", nowPushTime - lastPushTime);
+    lastPushTime = nowPushTime;
+
     return 0;
 }
 
@@ -376,8 +380,8 @@ int GB28181Muxer::mux(GB28181Muxer *gb28181Muxer) {
         uint64_t t2 = getCurrentTime();
 
         gb28181Muxer->pFrame->pts = (v_time - gb28181Muxer->startTime) * 90;
-        LOGE("v_time: %lld, get a pts:%lld (audio queue left num: %d, video queue left num: %d)",
-             v_time, gb28181Muxer->pFrame->pts, audio_queue.size(), video_queue.size());
+        LOGE("v_time: %lld, get a pts:%lld (audio queue left num: %d, video queue left num: %d, count: %d)",
+             v_time, gb28181Muxer->pFrame->pts, audio_queue.size(), video_queue.size(), gb28181Muxer->videoFrameCnt++);
 
         int got_picture;
         // 送入编码器

gb28181library/src/main/cpp/gb28181_muxer.h

@@ -62,6 +62,8 @@ private:
     int videoFrameCnt = 0;
     int64_t startTime = 0;
 
+    int64_t lastPushTime = 0;
+
     int mux(GB28181Muxer *gb28181Muxer);
 
 };

gb28181library/src/main/java/com/autulin/gb28181library/DemoActivity.java

@@ -49,31 +49,10 @@ public class DemoActivity extends AppCompatActivity implements
                         mMediaRecorder.endMux();
                     }
                 }
-//                new Thread(runnable).start();
             }
         });
     }
 
-    private Runnable runnable = new Runnable() {
-        @Override
-        public void run() {
-            try {
-                DatagramSocket socket = new DatagramSocket(8888);
-                InetAddress serverAddress = InetAddress.getByName("10.112.181.160");
-                String str = "hello";
-                DatagramPacket pkt = new DatagramPacket (str.getBytes() , str.getBytes().length , serverAddress , 8888);
-                socket.send(pkt);
-                socket.close();
-            } catch (SocketException e) {
-                e.printStackTrace();
-            } catch (UnknownHostException e) {
-                e.printStackTrace();
-            } catch (IOException e) {
-                e.printStackTrace();
-            }
-        }
-    };
-
     @Override
     public void onResume() {
         super.onResume();