diff --git a/src/vnsw/agent/cmn/agent.cc b/src/vnsw/agent/cmn/agent.cc index 476f564ba6e..8c70b116d02 100644 --- a/src/vnsw/agent/cmn/agent.cc +++ b/src/vnsw/agent/cmn/agent.cc @@ -143,11 +143,20 @@ void Agent::SetAgentTaskPolicy() { kTaskDBExclude, AGENT_SHUTDOWN_TASKNAME, AGENT_INIT_TASKNAME, - AGENT_SANDESH_TASKNAME + AGENT_SANDESH_TASKNAME, + kTaskConfigManager }; SetTaskPolicyOne("db::DBTable", db_exclude_list, sizeof(db_exclude_list) / sizeof(char *)); + // ConfigManager task + const char *config_manager_exclude_list[] = { + AGENT_SHUTDOWN_TASKNAME, + AGENT_INIT_TASKNAME + }; + SetTaskPolicyOne(kTaskConfigManager, config_manager_exclude_list, + sizeof(config_manager_exclude_list) / sizeof(char *)); + const char *flow_table_exclude_list[] = { "Agent::PktFlowResponder", kTaskFlowKSync, @@ -281,6 +290,9 @@ void Agent::SetAgentTaskPolicy() { const char *db_exclude_task_exclude_list[] = { "Agent::Uve", + "sandesh::RecvQueue", + "Agent::ControllerXmpp", + "bgp::Config", AGENT_SHUTDOWN_TASKNAME, AGENT_INIT_TASKNAME }; diff --git a/src/vnsw/agent/cmn/agent.h b/src/vnsw/agent/cmn/agent.h index 415faa1afa7..efc7dc58b48 100644 --- a/src/vnsw/agent/cmn/agent.h +++ b/src/vnsw/agent/cmn/agent.h @@ -222,6 +222,7 @@ extern void RouterIdDepInit(Agent *agent); #define kTaskHealthCheck "Agent::HealthCheck" #define kTaskDBExclude "Agent::DBExcludeTask" +#define kTaskConfigManager "Agent::ConfigManager" #define kInterfaceDbTablePrefix "db.interface" #define kVnDbTablePrefix "db.vn" diff --git a/src/vnsw/agent/vrouter/ksync/vnswif_listener_base.cc b/src/vnsw/agent/vrouter/ksync/vnswif_listener_base.cc index 81e5234cc74..04e53a737e3 100644 --- a/src/vnsw/agent/vrouter/ksync/vnswif_listener_base.cc +++ b/src/vnsw/agent/vrouter/ksync/vnswif_listener_base.cc @@ -50,9 +50,10 @@ void VnswInterfaceListenerBase::Init() { (boost::bind(&VnswInterfaceListenerBase::FabricRouteNotify, this, _1, _2)); + /* Allocate Route Event Workqueue */ revent_queue_ = new WorkQueue - (TaskScheduler::GetInstance()->GetTaskId("db::DBTable"), 0, + (TaskScheduler::GetInstance()->GetTaskId(kTaskDBExclude), 0, boost::bind(&VnswInterfaceListenerBase::ProcessEvent, this, _1)); revent_queue_->set_name("Netlink interface listener");