[gbsyncd] Add asic db prefix for channel RESTARTQUERY (#1302)

* Use different channel RESTARTQUERY for syncd/gbsyncd

* change restartquery to restartQuery due to aspell error

Author: jimmyzhai

syncd/RequestShutdown.cpp

@@ -37,7 +37,7 @@ void RequestShutdown::send()
 
     swss::DBConnector db(m_contextConfig->m_dbAsic, 0);
 
-    swss::NotificationProducer restartQuery(&db, SYNCD_NOTIFICATION_CHANNEL_RESTARTQUERY);
+    swss::NotificationProducer restartQuery(&db, SYNCD_NOTIFICATION_CHANNEL_RESTARTQUERY_PER_DB(m_contextConfig->m_dbAsic));
 
     std::vector<swss::FieldValueTuple> values;
 

syncd/RequestShutdown.h

@@ -9,6 +9,18 @@
 
 #define SYNCD_NOTIFICATION_CHANNEL_RESTARTQUERY     "RESTARTQUERY"
 
+/**
+ * @brief Notification channel 'restartQuery' per DB scope
+ *
+ * In https://redis.io/docs/manual/pubsub/, it says:
+ * "Pub/Sub has no relation to the key space. It was made to not interfere with
+ * it on any level, including database numbers."
+ */
+#define SYNCD_NOTIFICATION_CHANNEL_RESTARTQUERY_PER_DB(dbName) \
+    ((dbName) == "ASIC_DB" ? \
+     SYNCD_NOTIFICATION_CHANNEL_RESTARTQUERY : \
+     (dbName) + "_" + SYNCD_NOTIFICATION_CHANNEL_RESTARTQUERY)
+
 namespace syncd
 {
     class RequestShutdown

syncd/Syncd.cpp

@@ -161,7 +161,7 @@ Syncd::Syncd(
 
     m_handler->setSwitchNotifications(m_sn.getSwitchNotifications());
 
-    m_restartQuery = std::make_shared<swss::NotificationConsumer>(m_dbAsic.get(), SYNCD_NOTIFICATION_CHANNEL_RESTARTQUERY);
+    m_restartQuery = std::make_shared<swss::NotificationConsumer>(m_dbAsic.get(), SYNCD_NOTIFICATION_CHANNEL_RESTARTQUERY_PER_DB(m_contextConfig->m_dbAsic));
 
     // TODO to be moved to ASIC_DB
     m_dbFlexCounter = std::make_shared<swss::DBConnector>(m_contextConfig->m_dbFlex, 0);