Loading media/libstagefright/wifi-display/ANetworkSession.cpp +8 −18 Original line number Original line Diff line number Diff line Loading @@ -451,24 +451,6 @@ status_t ANetworkSession::Session::writeMore() { const Fragment &frag = *mOutFragments.begin(); const Fragment &frag = *mOutFragments.begin(); const sp<ABuffer> &datagram = frag.mBuffer; const sp<ABuffer> &datagram = frag.mBuffer; uint8_t *data = datagram->data(); if (data[0] == 0x80 && (data[1] & 0x7f) == 33) { int64_t nowUs = ALooper::GetNowUs(); uint32_t prevRtpTime = U32_AT(&data[4]); // 90kHz time scale uint32_t rtpTime = (nowUs * 9ll) / 100ll; int32_t diffTime = (int32_t)rtpTime - (int32_t)prevRtpTime; ALOGV("correcting rtpTime by %.0f ms", diffTime / 90.0); data[4] = rtpTime >> 24; data[5] = (rtpTime >> 16) & 0xff; data[6] = (rtpTime >> 8) & 0xff; data[7] = rtpTime & 0xff; } int n; int n; do { do { n = send(mSocket, datagram->data(), datagram->size(), 0); n = send(mSocket, datagram->data(), datagram->size(), 0); Loading Loading @@ -874,6 +856,14 @@ status_t ANetworkSession::createClientOrServer( err = -errno; err = -errno; goto bail2; goto bail2; } } int tos = 224; // VOICE res = setsockopt(s, IPPROTO_IP, IP_TOS, &tos, sizeof(tos)); if (res < 0) { err = -errno; goto bail2; } } } err = MakeSocketNonBlocking(s); err = MakeSocketNonBlocking(s); Loading Loading
media/libstagefright/wifi-display/ANetworkSession.cpp +8 −18 Original line number Original line Diff line number Diff line Loading @@ -451,24 +451,6 @@ status_t ANetworkSession::Session::writeMore() { const Fragment &frag = *mOutFragments.begin(); const Fragment &frag = *mOutFragments.begin(); const sp<ABuffer> &datagram = frag.mBuffer; const sp<ABuffer> &datagram = frag.mBuffer; uint8_t *data = datagram->data(); if (data[0] == 0x80 && (data[1] & 0x7f) == 33) { int64_t nowUs = ALooper::GetNowUs(); uint32_t prevRtpTime = U32_AT(&data[4]); // 90kHz time scale uint32_t rtpTime = (nowUs * 9ll) / 100ll; int32_t diffTime = (int32_t)rtpTime - (int32_t)prevRtpTime; ALOGV("correcting rtpTime by %.0f ms", diffTime / 90.0); data[4] = rtpTime >> 24; data[5] = (rtpTime >> 16) & 0xff; data[6] = (rtpTime >> 8) & 0xff; data[7] = rtpTime & 0xff; } int n; int n; do { do { n = send(mSocket, datagram->data(), datagram->size(), 0); n = send(mSocket, datagram->data(), datagram->size(), 0); Loading Loading @@ -874,6 +856,14 @@ status_t ANetworkSession::createClientOrServer( err = -errno; err = -errno; goto bail2; goto bail2; } } int tos = 224; // VOICE res = setsockopt(s, IPPROTO_IP, IP_TOS, &tos, sizeof(tos)); if (res < 0) { err = -errno; goto bail2; } } } err = MakeSocketNonBlocking(s); err = MakeSocketNonBlocking(s); Loading