[gbsyncd] Add asic db prefix for channel NOTIFICATIONS (sonic-net#1129)

Fix sonic-net#1131. The communication channel between orchagent and gbsyncd needs different from
the channel "NOTIFICATIONS" between orchagent and syncd.

Author: jimmyzhai

lib/RedisChannel.cpp

@@ -25,7 +25,7 @@ RedisChannel::RedisChannel(
     m_getConsumer           = std::make_shared<swss::ConsumerTable>(m_db.get(), REDIS_TABLE_GETRESPONSE);
 
     m_dbNtf                 = std::make_shared<swss::DBConnector>(dbAsic, 0);
-    m_notificationConsumer  = std::make_shared<swss::NotificationConsumer>(m_dbNtf.get(), REDIS_TABLE_NOTIFICATIONS);
+    m_notificationConsumer  = std::make_shared<swss::NotificationConsumer>(m_dbNtf.get(), REDIS_TABLE_NOTIFICATIONS_PER_DB(dbAsic));
 
     m_runNotificationThread = true;
 

lib/sairediscommon.h

@@ -67,6 +67,18 @@
  */
 #define REDIS_TABLE_NOTIFICATIONS   "NOTIFICATIONS"
 
+/**
+ * @brief Table which will be used to forward notifications 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 REDIS_TABLE_NOTIFICATIONS_PER_DB(dbName) \
+    ((dbName) == "ASIC_DB" ? \
+     REDIS_TABLE_NOTIFICATIONS : \
+     (dbName) + "_" + REDIS_TABLE_NOTIFICATIONS)
+
 /**
  * @brief Table which will be used to send API response from syncd.
  */

syncd/RedisNotificationProducer.cpp

@@ -13,7 +13,7 @@ RedisNotificationProducer::RedisNotificationProducer(
 
     m_db = std::make_shared<swss::DBConnector>(dbName, 0);
 
-    m_notificationProducer = std::make_shared<swss::NotificationProducer>(m_db.get(), REDIS_TABLE_NOTIFICATIONS);
+    m_notificationProducer = std::make_shared<swss::NotificationProducer>(m_db.get(), REDIS_TABLE_NOTIFICATIONS_PER_DB(dbName));
 }
 
 void RedisNotificationProducer::send(

tests/aspell.en.pws

@@ -231,6 +231,7 @@ inseg
 Inseg
 INSEG
 insegs
+io
 ip
 IP
 ipc
@@ -308,6 +309,7 @@ PORTs
 pre
 printf
 ptr
+pubsub
 qos
 queueCounterIds
 queueId