pkt_init.cc

Go to the documentation of this file.

/*
 * Copyright (c) 2013 Juniper Networks, Inc. All rights reserved.
 */

#include <io/event_manager.h>
#include <cmn/agent_cmn.h>
#include <cmn/agent_factory.h>
#include "sandesh/sandesh_trace.h"
#include "pkt/pkt_init.h"
#include "pkt/pkt_handler.h"
#include "pkt/proto.h"
#include "pkt/proto_handler.h"
#include "pkt/flow_proto.h"
#include "pkt/flow_table.h"
#include "pkt/packet_buffer.h"
#include "pkt/control_interface.h"
#include "pkt/flow_mgmt.h"

SandeshTraceBufferPtr PacketTraceBuf(SandeshTraceBufferCreate("Packet", 1000));

PktModule::PktModule(Agent *agent) :
    agent_(agent), control_interface_(NULL),
    pkt_handler_(NULL), flow_proto_(NULL),
    packet_buffer_manager_(new PacketBufferManager(this)) {
}

PktModule::~PktModule() {
}

void PktModule::Init(bool run_with_vrouter) {
    boost::asio::io_context &io = *agent_->event_manager()->io_service();

    pkt_handler_.reset(new PktHandler(agent_, this));

    if (control_interface_) {
        control_interface_->Init(pkt_handler_.get());
    }

    flow_proto_.reset(new FlowProto(agent_, io));
    flow_proto_->Init();

    uint16_t table_count = agent_->flow_thread_count();
    for (uint8_t i = 0; i < table_count; i++) {
        flow_mgmt_manager_list_.push_back(new FlowMgmtManager(agent_, i));
        flow_mgmt_manager_list_[i]->Init();
    }
    FlowMgmtManager::InitLogQueue(agent_);
}

void PktModule::InitDone() {
    flow_proto_->InitDone();
}

void PktModule::set_control_interface(ControlInterface *intf) {
    control_interface_ = intf;
}

void PktModule::Shutdown() {
    flow_proto_->Shutdown();
    flow_proto_.reset(NULL);

    control_interface_->Shutdown();
    control_interface_ = NULL;

    FlowMgmtManagerList::iterator it = flow_mgmt_manager_list_.begin();
    while (it != flow_mgmt_manager_list_.end()) {
        (*it)->Shutdown();
        it++;
    }

    STLDeleteValues(&flow_mgmt_manager_list_);
    FlowMgmtManager::ShutdownLogQueue();
}

void PktModule::IoShutdown() {
    control_interface_->IoShutdown();
}

void PktModule::FlushFlows() {
    flow_proto_->FlushFlows();
}

void PktModule::CreateInterfaces() {
    if (control_interface_ == NULL)
        return;

    Interface::Transport transport = Interface::TRANSPORT_ETHERNET;
    if (agent_->vrouter_on_host_dpdk()) {
        transport = Interface::TRANSPORT_SOCKET;
    }

    PacketInterface::Create(agent_->interface_table(),
                            control_interface_->Name(),
                            transport);
}

FlowTable *PktModule::flow_table(uint16_t index) const {
    return flow_proto_->GetTable(index);
}