commit dc816386eca2fe778884099586ccb2ee1857fee5
author Kim Sungyeon <sy85.kim@samsung.com> Tue Mar 24 13:40:20 2020 +0900
committer Lajos Molnar <lajos@google.com> Wed Feb 17 08:32:58 2021 -0800
tree 5adf48fdeb7c8b10e523ee00bde08d4dd8641957
parent 71a9abf607f80aca29f5f5cada1ec8b66e7f9e5c

VT: ARTPWriter: Introduce Moderator logic

Moderator logic (Not enabled as default)
    - N/W can drop packets if the writer sends a large amount of data instantly.
      The dropping is severe for UDP based protocols like RTP
    - So some logic added to prevent overflow of instant high bandwidth.

Bug: 165061754
Merged-in: I60fdf8b484ab5d077d1281df69dc5996103a25c2
Change-Id: I60fdf8b484ab5d077d1281df69dc5996103a25c2
Signed-off-by: Kim Sungyeon <sy85.kim@samsung.com>

media/libstagefright/rtsp/ARTPWriter.cpp

diff --git a/media/libstagefright/rtsp/ARTPWriter.cpp b/media/libstagefright/rtsp/ARTPWriter.cpp
index ea83e73..02c9d48 100644
--- a/media/libstagefright/rtsp/ARTPWriter.cpp
+++ b/media/libstagefright/rtsp/ARTPWriter.cpp
@@ -570,6 +570,11 @@
             remAddr = (struct sockaddr *)&mRTPAddr;
     }
 
+    // Unseal code if moderator is needed (prevent overflow of instant bandwidth)
+    // Set limit bits per period through the moderator.
+    // ex) 6KByte/10ms = 48KBit/10ms = 4.8MBit/s instant limit
+    // ModerateInstantTraffic(10, 6 * 1024);
+
     ssize_t n = sendto(isRTCP ? mRTCPSocket : mRTPSocket,
             buffer->data(), buffer->size(), 0, remAddr, sizeSockSt);
 
@@ -1515,4 +1520,15 @@
     }
 }
 
+// TODO : Develop more advanced moderator based on AS & TMMBR value
+void ARTPWriter::ModerateInstantTraffic(uint32_t samplePeriod, uint32_t limitBytes) {
+    unsigned int bytes =  mTrafficRec->readBytesForLastPeriod(samplePeriod);
+    if(bytes > limitBytes) {
+        ALOGI("Nuclear moderator. #seq = %d \t\t %d bits / 10ms",
+              mSeqNo, bytes * 8);
+        usleep(4000);
+        mTrafficRec->updateClock(ALooper::GetNowUs() / 1000);
+    }
+}
+
 }  // namespace android

media/libstagefright/rtsp/ARTPWriter.h

diff --git a/media/libstagefright/rtsp/ARTPWriter.h b/media/libstagefright/rtsp/ARTPWriter.h
index 5a10b31..6f25a66 100644
--- a/media/libstagefright/rtsp/ARTPWriter.h
+++ b/media/libstagefright/rtsp/ARTPWriter.h
@@ -156,6 +156,7 @@
     void send(const sp<ABuffer> &buffer, bool isRTCP);
     void makeSocketPairAndBind(String8& localIp, int localPort, String8& remoteIp, int remotePort);
 
+    void ModerateInstantTraffic(uint32_t samplePeriod, uint32_t limitBytes);
     DISALLOW_EVIL_CONSTRUCTORS(ARTPWriter);
 };