OpenSDN source code
Classes | Public Types | Public Member Functions | Static Public Attributes | Private Types | Private Member Functions | Private Attributes | Friends | List of all members
InstanceManager Class Reference

#include <instance_manager.h>

Collaboration diagram for InstanceManager:
Collaboration graph
[legend]

Classes

struct  InstanceManagerChildEvent
 
class  NamespaceStaleCleaner
 

Public Types

enum  CmdType { Start = 1 , Stop }
 
enum  ChldEventType { OnErrorEvent , OnTaskTimeoutEvent , OnExitEvent }
 

Public Member Functions

 InstanceManager (Agent *)
 
 ~InstanceManager ()
 
void Initialize (DB *database, const std::string &netns_cmd, const std::string &docker_cmd, const int netns_workers, const int netns_timeout)
 
void Terminate ()
 
bool DequeueEvent (InstanceManagerChildEvent event)
 
InstanceState * GetState (ServiceInstance *) const
 
bool StaleTimeout ()
 
void SetStaleTimerInterval (int minutes)
 
int StaleTimerInterval ()
 
void SetNamespaceStorePath (std::string path)
 
void SetNetNSCmd (const std::string &netns_cmd)
 

Static Public Attributes

static const int kTimeoutDefault = 30
 
static const int kWorkersDefault = 1
 
static const int kReattemptsDefault = 2
 

Private Types

typedef std::map< InstanceTask *, ServiceInstance * > TaskSvcMap
 

Private Member Functions

void RegisterSigHandler ()
 
void InitSigHandler (AgentSignal *signal)
 
InstanceManagerAdapter * FindApplicableAdapter (const ServiceInstance::Properties &props)
 
void StartServiceInstance (ServiceInstance *svc_instance, InstanceState *state, bool update)
 
void StopServiceInstance (ServiceInstance *svc_instance, InstanceState *state)
 
void StopStaleNetNS (ServiceInstance::Properties &props)
 
void OnError (InstanceTask *task, const std::string errors)
 
void OnExit (InstanceTask *task, const boost::system::error_code &ec)
 
void RegisterSvcInstance (InstanceTask *task, ServiceInstance *svc_instance)
 
void UnregisterSvcInstance (ServiceInstance *svc_instance)
 
ServiceInstance * UnregisterSvcInstance (InstanceTask *task)
 
ServiceInstance * GetSvcInstance (InstanceTask *task) const
 
InstanceTaskQueue * GetTaskQueue (const std::string &str)
 
void Enqueue (InstanceTask *task, const boost::uuids::uuid &uuid)
 
void ScheduleNextTask (InstanceTaskQueue *task_queue)
 
bool StartTask (InstanceTaskQueue *task_queue, InstanceTask *task)
 
InstanceState * GetState (InstanceTask *task) const
 
void SetState (ServiceInstance *svc_instance, InstanceState *state)
 
void ClearState (ServiceInstance *svc_instance)
 
bool DeleteState (ServiceInstance *svc_instance)
 
void UpdateStateStatusType (InstanceManagerChildEvent event)
 
void SetLastCmdType (ServiceInstance *svc_instance, int last_cmd_type)
 
int GetLastCmdType (ServiceInstance *svc_instance) const
 
void ClearLastCmdType (ServiceInstance *svc_instance)
 
void OnTaskTimeout (InstanceTaskQueue *task_queue)
 
void OnErrorEventHandler (InstanceManagerChildEvent event)
 
void OnExitEventHandler (InstanceManagerChildEvent event)
 
void OnTaskTimeoutEventHandler (InstanceManagerChildEvent event)
 
void StateClear ()
 
void EventObserver (DBTablePartBase *db_part, DBEntryBase *entry)
 
 DISALLOW_COPY_AND_ASSIGN (InstanceManager)
 

Private Attributes

DBTableBase::ListenerId si_listener_
 
std::string netns_cmd_
 
int netns_timeout_
 
int netns_reattempts_
 
WorkQueue< InstanceManagerChildEvent > work_queue_
 
std::vector< InstanceTaskQueue * > task_queues_
 
TaskSvcMap task_svc_instances_
 
std::map< std::string, int > last_cmd_types_
 
std::string loadbalancer_config_path_
 
std::string namespace_store_path_
 
int stale_timer_interval_
 
Timer * stale_timer_
 
std::unique_ptr< NamespaceStaleCleaner > stale_cleaner_
 
Agent * agent_
 
std::vector< InstanceManagerAdapter * > adapters_
 

Friends

class InstanceManagerTest
 

Detailed Description

Definition at line 33 of file instance_manager.h.

Member Typedef Documentation

◆ TaskSvcMap

typedef std::map<InstanceTask *, ServiceInstance *> InstanceManager::TaskSvcMap
private

Definition at line 151 of file instance_manager.h.

Member Enumeration Documentation

◆ ChldEventType

enum InstanceManager::ChldEventType
Enumerator
OnErrorEvent 
OnTaskTimeoutEvent 
OnExitEvent 

Definition at line 40 of file instance_manager.h.

◆ CmdType

enum InstanceManager::CmdType
Enumerator
Start 
Stop 

Definition at line 35 of file instance_manager.h.

Constructor & Destructor Documentation

◆ InstanceManager()

InstanceManager::InstanceManager ( Agent *  agent)

Definition at line 129 of file instance_manager.cc.

Here is the call graph for this function:

◆ ~InstanceManager()

InstanceManager::~InstanceManager ( )

Definition at line 124 of file instance_manager.cc.

Here is the call graph for this function:

Member Function Documentation

◆ ClearLastCmdType()

void InstanceManager::ClearLastCmdType ( ServiceInstance *  svc_instance)
private

Definition at line 775 of file instance_manager.cc.

Here is the call graph for this function:

◆ ClearState()

void InstanceManager::ClearState ( ServiceInstance *  svc_instance)
private

Definition at line 370 of file instance_manager.cc.

Here is the call graph for this function:

◆ DeleteState()

bool InstanceManager::DeleteState ( ServiceInstance *  svc_instance)
private

Definition at line 374 of file instance_manager.cc.

Here is the call graph for this function:

◆ DequeueEvent()

bool InstanceManager::DequeueEvent ( InstanceManagerChildEvent  event)

Definition at line 289 of file instance_manager.cc.

Here is the call graph for this function:

◆ DISALLOW_COPY_AND_ASSIGN()

InstanceManager::DISALLOW_COPY_AND_ASSIGN ( InstanceManager  )
private

◆ Enqueue()

void InstanceManager::Enqueue ( InstanceTask *  task,
const boost::uuids::uuid &  uuid 
)
private

Definition at line 430 of file instance_manager.cc.

Here is the call graph for this function:

◆ EventObserver()

void InstanceManager::EventObserver ( DBTablePartBase *  db_part,
DBEntryBase *  entry 
)
private

Definition at line 784 of file instance_manager.cc.

Here is the call graph for this function:

◆ FindApplicableAdapter()

InstanceManagerAdapter * InstanceManager::FindApplicableAdapter ( const ServiceInstance::Properties &  props)
private

Definition at line 615 of file instance_manager.cc.

Here is the call graph for this function:

◆ GetLastCmdType()

int InstanceManager::GetLastCmdType ( ServiceInstance *  svc_instance) const
private

Definition at line 764 of file instance_manager.cc.

Here is the call graph for this function:

◆ GetState() [1/2]

InstanceState * InstanceManager::GetState ( InstanceTask *  task) const
private

Definition at line 355 of file instance_manager.cc.

Here is the call graph for this function:

◆ GetState() [2/2]

InstanceState * InstanceManager::GetState ( ServiceInstance *  svc_instance) const

Definition at line 349 of file instance_manager.cc.

Here is the call graph for this function:

◆ GetSvcInstance()

ServiceInstance * InstanceManager::GetSvcInstance ( InstanceTask *  task) const
private

Definition at line 561 of file instance_manager.cc.

◆ GetTaskQueue()

InstanceTaskQueue * InstanceManager::GetTaskQueue ( const std::string &  str)
private

Definition at line 439 of file instance_manager.cc.

◆ Initialize()

void InstanceManager::Initialize ( DB *  database,
const std::string &  netns_cmd,
const std::string &  docker_cmd,
const int  netns_workers,
const int  netns_timeout 
)

Definition at line 150 of file instance_manager.cc.

Here is the call graph for this function:

◆ InitSigHandler()

void InstanceManager::InitSigHandler ( AgentSignal *  signal)
private

◆ OnError()

void InstanceManager::OnError ( InstanceTask *  task,
const std::string  errors 
)
private

Definition at line 687 of file instance_manager.cc.

◆ OnErrorEventHandler()

void InstanceManager::OnErrorEventHandler ( InstanceManagerChildEvent  event)
private

Definition at line 244 of file instance_manager.cc.

Here is the call graph for this function:

◆ OnExit()

void InstanceManager::OnExit ( InstanceTask *  task,
const boost::system::error_code &  ec 
)
private

Definition at line 698 of file instance_manager.cc.

◆ OnExitEventHandler()

void InstanceManager::OnExitEventHandler ( InstanceManagerChildEvent  event)
private

Definition at line 260 of file instance_manager.cc.

Here is the call graph for this function:

◆ OnTaskTimeout()

void InstanceManager::OnTaskTimeout ( InstanceTaskQueue *  task_queue)
private

Definition at line 228 of file instance_manager.cc.

◆ OnTaskTimeoutEventHandler()

void InstanceManager::OnTaskTimeoutEventHandler ( InstanceManagerChildEvent  event)
private

Definition at line 236 of file instance_manager.cc.

Here is the call graph for this function:

◆ RegisterSigHandler()

void InstanceManager::RegisterSigHandler ( )
private

◆ RegisterSvcInstance()

void InstanceManager::RegisterSvcInstance ( InstanceTask *  task,
ServiceInstance *  svc_instance 
)
private

Definition at line 570 of file instance_manager.cc.

Here is the call graph for this function:

◆ ScheduleNextTask()

void InstanceManager::ScheduleNextTask ( InstanceTaskQueue *  task_queue)
private

Definition at line 506 of file instance_manager.cc.

Here is the call graph for this function:

◆ SetLastCmdType()

void InstanceManager::SetLastCmdType ( ServiceInstance *  svc_instance,
int  last_cmd_type 
)
private

Definition at line 752 of file instance_manager.cc.

Here is the call graph for this function:

◆ SetNamespaceStorePath()

void InstanceManager::SetNamespaceStorePath ( std::string  path)

Definition at line 838 of file instance_manager.cc.

◆ SetNetNSCmd()

void InstanceManager::SetNetNSCmd ( const std::string &  netns_cmd)

Definition at line 214 of file instance_manager.cc.

Here is the call graph for this function:

◆ SetStaleTimerInterval()

void InstanceManager::SetStaleTimerInterval ( int  minutes)

Definition at line 224 of file instance_manager.cc.

◆ SetState()

void InstanceManager::SetState ( ServiceInstance *  svc_instance,
InstanceState *  state 
)
private

Definition at line 364 of file instance_manager.cc.

Here is the call graph for this function:

◆ StaleTimeout()

bool InstanceManager::StaleTimeout ( )

Definition at line 828 of file instance_manager.cc.

◆ StaleTimerInterval()

int InstanceManager::StaleTimerInterval ( )
inline

Definition at line 86 of file instance_manager.h.

◆ StartServiceInstance()

void InstanceManager::StartServiceInstance ( ServiceInstance *  svc_instance,
InstanceState *  state,
bool  update 
)
private

Definition at line 626 of file instance_manager.cc.

Here is the call graph for this function:

◆ StartTask()

bool InstanceManager::StartTask ( InstanceTaskQueue *  task_queue,
InstanceTask *  task 
)
private

Definition at line 453 of file instance_manager.cc.

Here is the call graph for this function:

◆ StateClear()

void InstanceManager::StateClear ( )
private

Definition at line 392 of file instance_manager.cc.

Here is the call graph for this function:

◆ StopServiceInstance()

void InstanceManager::StopServiceInstance ( ServiceInstance *  svc_instance,
InstanceState *  state 
)
private

Definition at line 657 of file instance_manager.cc.

Here is the call graph for this function:

◆ StopStaleNetNS()

void InstanceManager::StopStaleNetNS ( ServiceInstance::Properties &  props)
private

Definition at line 709 of file instance_manager.cc.

Here is the call graph for this function:

◆ Terminate()

void InstanceManager::Terminate ( )

Definition at line 412 of file instance_manager.cc.

Here is the call graph for this function:

◆ UnregisterSvcInstance() [1/2]

ServiceInstance * InstanceManager::UnregisterSvcInstance ( InstanceTask *  task)
private

Definition at line 581 of file instance_manager.cc.

Here is the call graph for this function:

◆ UnregisterSvcInstance() [2/2]

void InstanceManager::UnregisterSvcInstance ( ServiceInstance *  svc_instance)
private

Definition at line 598 of file instance_manager.cc.

Here is the call graph for this function:

◆ UpdateStateStatusType()

void InstanceManager::UpdateStateStatusType ( InstanceManagerChildEvent  event)
private

Definition at line 301 of file instance_manager.cc.

Here is the call graph for this function:

Friends And Related Function Documentation

◆ InstanceManagerTest

friend class InstanceManagerTest
friend

Definition at line 91 of file instance_manager.h.

Member Data Documentation

◆ adapters_

std::vector<InstanceManagerAdapter *> InstanceManager::adapters_
private

Definition at line 161 of file instance_manager.h.

◆ agent_

Agent* InstanceManager::agent_
private

Definition at line 159 of file instance_manager.h.

◆ kReattemptsDefault

const int InstanceManager::kReattemptsDefault = 2
static

Definition at line 72 of file instance_manager.h.

◆ kTimeoutDefault

const int InstanceManager::kTimeoutDefault = 30
static

Definition at line 70 of file instance_manager.h.

◆ kWorkersDefault

const int InstanceManager::kWorkersDefault = 1
static

Definition at line 71 of file instance_manager.h.

◆ last_cmd_types_

std::map<std::string, int> InstanceManager::last_cmd_types_
private

Definition at line 153 of file instance_manager.h.

◆ loadbalancer_config_path_

std::string InstanceManager::loadbalancer_config_path_
private

Definition at line 154 of file instance_manager.h.

◆ namespace_store_path_

std::string InstanceManager::namespace_store_path_
private

Definition at line 155 of file instance_manager.h.

◆ netns_cmd_

std::string InstanceManager::netns_cmd_
private

Definition at line 145 of file instance_manager.h.

◆ netns_reattempts_

int InstanceManager::netns_reattempts_
private

Definition at line 147 of file instance_manager.h.

◆ netns_timeout_

int InstanceManager::netns_timeout_
private

Definition at line 146 of file instance_manager.h.

◆ si_listener_

DBTableBase::ListenerId InstanceManager::si_listener_
private

Definition at line 144 of file instance_manager.h.

◆ stale_cleaner_

std::unique_ptr<NamespaceStaleCleaner> InstanceManager::stale_cleaner_
private

Definition at line 158 of file instance_manager.h.

◆ stale_timer_

Timer* InstanceManager::stale_timer_
private

Definition at line 157 of file instance_manager.h.

◆ stale_timer_interval_

int InstanceManager::stale_timer_interval_
private

Definition at line 156 of file instance_manager.h.

◆ task_queues_

std::vector<InstanceTaskQueue *> InstanceManager::task_queues_
private

Definition at line 150 of file instance_manager.h.

◆ task_svc_instances_

TaskSvcMap InstanceManager::task_svc_instances_
private

Definition at line 152 of file instance_manager.h.

◆ work_queue_

WorkQueue<InstanceManagerChildEvent> InstanceManager::work_queue_
private

Definition at line 148 of file instance_manager.h.

The documentation for this class was generated from the following files: