diff --git a/app/src/main/java/net/ossrs/sea/rtmp/io/ChunkStreamInfo.java b/app/src/main/java/net/ossrs/sea/rtmp/io/ChunkStreamInfo.java
index 76c1df5..6078621 100644
--- a/app/src/main/java/net/ossrs/sea/rtmp/io/ChunkStreamInfo.java
+++ b/app/src/main/java/net/ossrs/sea/rtmp/io/ChunkStreamInfo.java
@@ -50,8 +50,10 @@ public class ChunkStreamInfo {
     
     /** Utility method for calculating & synchronizing transmitted timestamps & timestamp deltas */
     public long markRealAbsoluteTimestampTx() {
-        realLastTimestamp = System.nanoTime() / 1000 - realLastTimestamp;
-        return realLastTimestamp;
+        long currentTimestamp = System.nanoTime() / 1000;
+        long diffTimestamp = currentTimestamp - realLastTimestamp;
+        realLastTimestamp = currentTimestamp;
+        return diffTimestamp;
     }
 
     /** @return <code>true</code> if all packet data has been stored, or <code>false</code> if not */
diff --git a/app/src/main/java/net/ossrs/sea/rtmp/io/RtmpConnection.java b/app/src/main/java/net/ossrs/sea/rtmp/io/RtmpConnection.java
index 16400eb..ff76a75 100644
--- a/app/src/main/java/net/ossrs/sea/rtmp/io/RtmpConnection.java
+++ b/app/src/main/java/net/ossrs/sea/rtmp/io/RtmpConnection.java
@@ -121,7 +121,7 @@ public class RtmpConnection implements RtmpPublisher, PacketRxHandler {
         if (connecting) {
             synchronized (connectingLock) {
                 try {
-                    connectingLock.wait();
+                    connectingLock.wait(5000);
                 } catch (InterruptedException ex) {
                     // do nothing
                 }