Finetune some rtsp timeout constants.

Change-Id: Ice731c5097c2a2dee8a7f0cd45b547cd34f532c6

1 files changed, 11 insertions, 3 deletions

diff --git a/media/libstagefright/rtsp/MyHandler.h b/media/libstagefright/rtsp/MyHandler.h
index affacc8..f20dd6f 100644
--- a/media/libstagefright/rtsp/MyHandler.h
+++ b/media/libstagefright/rtsp/MyHandler.h
@@ -33,6 +33,14 @@
 
 #define USE_TCP_INTERLEAVED     0
 
+// If no access units are received within 3 secs, assume that the rtp
+// stream has ended and signal end of stream.
+static int64_t kAccessUnitTimeoutUs = 3000000ll;
+
+// If no access units arrive for the first 10 secs after starting the
+// stream, assume none ever will and signal EOS or switch transports.
+static int64_t kStartupTimeoutUs = 10000000ll;
+
 namespace android {
 
 static bool GetAttribute(const char *s, const char *key, AString *value) {
@@ -322,7 +330,7 @@ struct MyHandler : public AHandler {
                     mDoneMsg = NULL;
 
                     sp<AMessage> timeout = new AMessage('tiou', id());
-                    timeout->post(10000000ll);
+                    timeout->post(kStartupTimeoutUs);
                 } else {
                     sp<AMessage> reply = new AMessage('disc', id());
                     mConn->disconnect(reply);
@@ -389,7 +397,7 @@ struct MyHandler : public AHandler {
                 }
 
                 mNumAccessUnitsReceived = 0;
-                msg->post(1000000);
+                msg->post(kAccessUnitTimeoutUs);
                 break;
             }
 
@@ -400,7 +408,7 @@ struct MyHandler : public AHandler {
                 if (!mCheckPending) {
                     mCheckPending = true;
                     sp<AMessage> check = new AMessage('chek', id());
-                    check->post(1000000);
+                    check->post(kAccessUnitTimeoutUs);
                 }
 
                 size_t trackIndex;