File tree Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -245,6 +245,7 @@ void P4Orch::handleP4rtNotification(
245245 if (!prev_op.empty () && status.ok ()) {
246246 drain (prev_op);
247247 }
248+ m_publisher.flush ();
248249}
249250
250251void P4Orch::handlePortStatusChangeNotification (const std::string &op, const std::string &data)
Original file line number Diff line number Diff line change @@ -90,7 +90,8 @@ class P4Orch : public Orch
9090 swss::NotificationConsumer *m_portStatusNotificationConsumer;
9191
9292 // Sepcial publisher that writes to APPL DB instead of APPL STATE DB.
93- ResponsePublisher m_publisher{" APPL_DB" , /* bool buffered=*/ true , /* db_write_thread=*/ true };
93+ // Sepcial publisher that writes to APPL DB instead of APPL STATE DB.
94+ ResponsePublisher m_publisher{" APPL_DB" , /* bool buffered=*/ true };
9495
9596 friend class P4OrchTest ;
9697 friend class p4orch ::test::WcmpManagerTest;
You can’t perform that action at this time.
0 commit comments