Agora  1.2.0
Agora project
channel_sim.cc File Reference

Implementation file for the channel simulator class. More...

#include "channel_sim.h"
#include <atomic>
#include <utility>
#include "datatype_conversion.h"
#include "gettime.h"
#include "logger.h"
#include "message.h"
#include "signal_handler.h"
Include dependency graph for channel_sim.cc:

Classes

class  SocketRxBuffer
 

Functions

static std::vector< std::unique_ptr< UDPComm > > CreateCommSockets (const std::string &local_address, int local_port, const std::string &remote_address, int remote_port, size_t interface_count)
 

Variables

static std::atomic< bool > running = true
 
static constexpr bool kPrintChannelOutput = false
 
static constexpr size_t kDefaultQueueSize = 36
 
static constexpr bool kPrintDebugTxUser = false
 
static constexpr bool kPrintDebugTxBs = false
 
static constexpr bool kEnableChannelTiming = true
 
static constexpr double kChannelTimeWarning = 2.0f
 
static constexpr size_t kUdpMTU = 9000
 
static constexpr size_t kDequeueBulkSize = 5
 
static constexpr size_t kSockBufSize = (1024 * 1024 * 64 * 8) - 1
 

Detailed Description

Implementation file for the channel simulator class.

Function Documentation

◆ CreateCommSockets()

static std::vector<std::unique_ptr<UDPComm> > CreateCommSockets ( const std::string &  local_address,
int  local_port,
const std::string &  remote_address,
int  remote_port,
size_t  interface_count 
)
static
Here is the caller graph for this function:

Variable Documentation

◆ kChannelTimeWarning

constexpr double kChannelTimeWarning = 2.0f
staticconstexpr

◆ kDefaultQueueSize

constexpr size_t kDefaultQueueSize = 36
staticconstexpr

◆ kDequeueBulkSize

constexpr size_t kDequeueBulkSize = 5
staticconstexpr

◆ kEnableChannelTiming

constexpr bool kEnableChannelTiming = true
staticconstexpr

◆ kPrintChannelOutput

constexpr bool kPrintChannelOutput = false
staticconstexpr

◆ kPrintDebugTxBs

constexpr bool kPrintDebugTxBs = false
staticconstexpr

◆ kPrintDebugTxUser

constexpr bool kPrintDebugTxUser = false
staticconstexpr

◆ kSockBufSize

constexpr size_t kSockBufSize = (1024 * 1024 * 64 * 8) - 1
staticconstexpr

◆ kUdpMTU

constexpr size_t kUdpMTU = 9000
staticconstexpr

◆ running

std::atomic<bool> running = true
static