Merge "Move unrelated tasks from db::DBTable context"

Juniper · May 9, 2016 · d2549d6 · d2549d6
2 parents 83d2b6d + 47927a8
commit d2549d6
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 2 deletions.
diff --git 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
@@ -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
@@ -50,9 +50,10 @@ void VnswInterfaceListenerBase::Init() {
         (boost::bind(&VnswInterfaceListenerBase::FabricRouteNotify,
                      this, _1, _2));
 
+
     /* Allocate Route Event Workqueue */
     revent_queue_ = new WorkQueue<Event *>
-                    (TaskScheduler::GetInstance()->GetTaskId("db::DBTable"), 0,
+                    (TaskScheduler::GetInstance()->GetTaskId(kTaskDBExclude), 0,
                      boost::bind(&VnswInterfaceListenerBase::ProcessEvent,
                      this, _1));
     revent_queue_->set_name("Netlink interface listener");