6 #define BOOST_FUNCTIONAL_FORWARD_ADAPTER_MAX_ARITY 8
8 #include <boost/functional/forward_adapter.hpp>
41 (
const std::string &config_file,
const std::string &
program_name) {
52 boost::asio::io_context &,
63 boost::asio::io_context &,
71 Agent*, uint64_t, uint32_t, uint32_t>();
74 Agent*, uint64_t, uint32_t, uint32_t>();
77 #ifdef AGENT_VROUTER_TCP
78 #define AGENT_KSYNC_TCP true
80 #define AGENT_KSYNC_TCP false
86 AgentStaticObjectFactory::LinkImpl<KSync, AgentKSyncX, Agent*>();
88 AgentStaticObjectFactory::LinkImpl<KSync, KSync, Agent*>();
100 agent()->event_manager()->io_service()));
103 agent()->event_manager()->io_service()));
106 agent()->event_manager()->io_service()));
111 uve_.reset(AgentStaticObjectFactory::Create<AgentUveBase>(
114 agent()->params()->vmi_vm_vn_uve_interval_msecs(),
119 if (
agent()->tsn_enabled() ==
false) {
121 (*(
agent()->event_manager()->io_service()),
132 ksync_.reset(AgentStaticObjectFactory::Create<KSync>(
agent()));
154 if (
agent()->ksync()) {
160 if (
agent()->uve()) {
166 if (
agent()->stats_collector()) {
172 if (
agent()->flow_stats_manager()) {
184 if (
agent()->port_ipc_handler()) {
188 if (
agent()->rest_server()) {
202 if (
agent()->rest_server()) {
206 if (
agent()->port_ipc_handler()) {
AgentParam * agent_param() const
bool vrouter_on_nic_mode() const
bool vrouter_on_host_dpdk() const
static const uint64_t kBandwidthInterval
static const uint32_t kIncrementalInterval
void set_uve(AgentUveBase *uve)
void set_ksync(KSync *ksync)
PortIpcHandler * port_ipc_handler() const
FlowStatsManager * flow_stats_manager() const
AgentUveBase * uve() const
void set_port_ipc_handler(PortIpcHandler *r)
AgentStatsCollector * stats_collector() const
std::string AgentGUID() const
void set_flow_stats_manager(FlowStatsManager *fsc)
RestServer * rest_server() const
void set_stats_collector(AgentStatsCollector *asc)
void set_rest_server(RestServer *r)
std::unique_ptr< AgentStatsCollector > stats_collector_
std::unique_ptr< VrouterControlInterface > pkt0_
void FlowStatsCollectorShutdown()
void FactoryInit() override
void StatsCollectorShutdown()
std::unique_ptr< RestServer > rest_server_
void ProcessOptions(const std::string &config_file, const std::string &program_name)
virtual ~ContrailAgentInit()
std::unique_ptr< AgentUveBase > uve_
std::unique_ptr< KSync > ksync_
std::unique_ptr< PortIpcHandler > port_ipc_handler_
std::unique_ptr< FlowStatsManager > flow_stats_manager_
void ProcessOptions(const std::string &config_file, const std::string &program_name)
virtual void ModulesShutdown()
static void CreateMockAgent(const string &)
void set_control_interface(ControlInterface *val)
void ReloadAllPorts(const std::string &dir, bool check_port, bool vm_vn_port)
static const std::string kPortsDir
string program_name(string filename)