Finetune some rtsp timeout constants.

Change-Id: Ice731c5097c2a2dee8a7f0cd45b547cd34f532c6
This commit is contained in:
Andreas Huber
2010-08-30 09:53:52 -07:00
parent 01ee34d707
commit f6639c46e8

View File

@@ -33,6 +33,14 @@
#define USE_TCP_INTERLEAVED 0 #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 { namespace android {
static bool GetAttribute(const char *s, const char *key, AString *value) { static bool GetAttribute(const char *s, const char *key, AString *value) {
@@ -322,7 +330,7 @@ struct MyHandler : public AHandler {
mDoneMsg = NULL; mDoneMsg = NULL;
sp<AMessage> timeout = new AMessage('tiou', id()); sp<AMessage> timeout = new AMessage('tiou', id());
timeout->post(10000000ll); timeout->post(kStartupTimeoutUs);
} else { } else {
sp<AMessage> reply = new AMessage('disc', id()); sp<AMessage> reply = new AMessage('disc', id());
mConn->disconnect(reply); mConn->disconnect(reply);
@@ -389,7 +397,7 @@ struct MyHandler : public AHandler {
} }
mNumAccessUnitsReceived = 0; mNumAccessUnitsReceived = 0;
msg->post(1000000); msg->post(kAccessUnitTimeoutUs);
break; break;
} }
@@ -400,7 +408,7 @@ struct MyHandler : public AHandler {
if (!mCheckPending) { if (!mCheckPending) {
mCheckPending = true; mCheckPending = true;
sp<AMessage> check = new AMessage('chek', id()); sp<AMessage> check = new AMessage('chek', id());
check->post(1000000); check->post(kAccessUnitTimeoutUs);
} }
size_t trackIndex; size_t trackIndex;