diff options
author | Lorenzo Colitti <lorenzo@google.com> | 2011-03-09 15:09:20 -0800 |
---|---|---|
committer | Android Git Automerger <android-git-automerger@android.com> | 2011-03-09 15:09:20 -0800 |
commit | 8df2477c4e7e5bf72d6d1216ae5184c53304470e (patch) | |
tree | de10bc8f1b96b4ba50452438e9f8c57a7dd7afda | |
parent | e4a02b61290fa61955c979cfd1afc17a92bba481 (diff) | |
parent | bd0e806a61df9b67890dc3b1390db554e7468b4a (diff) | |
download | frameworks_base-8df2477c4e7e5bf72d6d1216ae5184c53304470e.zip frameworks_base-8df2477c4e7e5bf72d6d1216ae5184c53304470e.tar.gz frameworks_base-8df2477c4e7e5bf72d6d1216ae5184c53304470e.tar.bz2 |
am bd0e806a: Support IPv6->IPv4 fallback in HTTP streaming.
* commit 'bd0e806a61df9b67890dc3b1390db554e7468b4a':
Support IPv6->IPv4 fallback in HTTP streaming.
-rw-r--r-- | media/libstagefright/HTTPStream.cpp | 38 |
1 files changed, 24 insertions, 14 deletions
diff --git a/media/libstagefright/HTTPStream.cpp b/media/libstagefright/HTTPStream.cpp index adb6d01..4ad1c12 100644 --- a/media/libstagefright/HTTPStream.cpp +++ b/media/libstagefright/HTTPStream.cpp @@ -150,31 +150,41 @@ status_t HTTPStream::connect(const char *server, int port) { } CHECK_EQ(mSocket, -1); - mSocket = socket(ai[0].ai_family, ai[0].ai_socktype, ai[0].ai_protocol); - if (mSocket < 0) { - freeaddrinfo(ai); - return UNKNOWN_ERROR; - } + mState = CONNECTING; + status_t res = -1; + struct addrinfo *tmp; + for (tmp = ai; tmp; tmp = tmp->ai_next) { + mSocket = socket(tmp->ai_family, tmp->ai_socktype, tmp->ai_protocol); + if (mSocket < 0) { + continue; + } - setReceiveTimeout(30); // Time out reads after 30 secs by default + setReceiveTimeout(30); // Time out reads after 30 secs by default. - mState = CONNECTING; + int s = mSocket; - int s = mSocket; + mLock.unlock(); - mLock.unlock(); + res = MyConnect(s, tmp->ai_addr, tmp->ai_addrlen); - status_t res = MyConnect(s, ai[0].ai_addr, ai[0].ai_addrlen); + mLock.lock(); - freeaddrinfo(ai); + if (mState != CONNECTING) { + close(s); + freeaddrinfo(ai); + return UNKNOWN_ERROR; + } - mLock.lock(); + if (res == OK) { + break; + } - if (mState != CONNECTING) { - return UNKNOWN_ERROR; + close(s); } + freeaddrinfo(ai); + if (res != OK) { close(mSocket); mSocket = -1; |