Skip to content
Permalink
Browse files

reflow: make RTP receive FIFO maximum size configurable

  • Loading branch information...
dpocock committed May 13, 2019
1 parent c303693 commit ee3251317f2340a0e53ed5549e566645fc7444aa
Showing with 6 additions and 3 deletions.
  1. +3 −3 reflow/Flow.cxx
  2. +3 −0 reflow/Flow.hxx
@@ -28,8 +28,8 @@ using namespace dtls;

using namespace std;

#define MAX_RECEIVE_FIFO_DURATION 10 // seconds
#define MAX_RECEIVE_FIFO_SIZE (100 * MAX_RECEIVE_FIFO_DURATION) // 1000 = 1 message every 10 ms for 10 seconds - appropriate for RTP
int Flow::maxReceiveFifoDuration = 10; // seconds
int Flow::maxReceiveFifoSize = 100 * maxReceiveFifoDuration; // 1000 = 1 message every 10 ms for 10 seconds - appropriate for RTP

#define RESIPROCATE_SUBSYSTEM FlowManagerSubsystem::FLOWMANAGER

@@ -141,7 +141,7 @@ Flow::Flow(asio::io_service& ioService,
mAllocationProps(StunMessage::PropsNone),
mReservationToken(0),
mFlowState(Unconnected),
mReceivedDataFifo(MAX_RECEIVE_FIFO_DURATION,MAX_RECEIVE_FIFO_SIZE)
mReceivedDataFifo(maxReceiveFifoDuration, maxReceiveFifoSize)
{
InfoLog(<< "Flow: flow created for " << mLocalBinding << " ComponentId=" << mComponentId);

@@ -48,6 +48,9 @@ class Flow : public TurnAsyncSocketHandler
{
public:

static int maxReceiveFifoDuration;
static int maxReceiveFifoSize;

enum FlowState
{
Unconnected,

0 comments on commit ee32513

Please sign in to comment.
You can’t perform that action at this time.