File tree 1 file changed +8
-1
lines changed
1 file changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -808,7 +808,7 @@ namespace portsorch_test
808
808
809
809
auto queueConsumer = static_cast <Consumer*>(gBufferOrch ->getExecutor (APP_BUFFER_QUEUE_TABLE_NAME));
810
810
queueConsumer->dumpPendingTasks (ts);
811
- ASSERT_TRUE (ts.empty ()); // Queue is not skipped
811
+ ASSERT_FALSE (ts.empty ()); // Queue is skipped
812
812
ts.clear ();
813
813
814
814
auto pgConsumer = static_cast <Consumer*>(gBufferOrch ->getExecutor (APP_BUFFER_PG_TABLE_NAME));
@@ -818,6 +818,13 @@ namespace portsorch_test
818
818
819
819
// release zero buffer drop handler
820
820
dropHandler.reset ();
821
+
822
+ // process queue
823
+ static_cast <Orch *>(gBufferOrch )->doTask ();
824
+
825
+ queueConsumer->dumpPendingTasks (ts);
826
+ ASSERT_TRUE (ts.empty ()); // queue should be processed now
827
+ ts.clear ();
821
828
}
822
829
823
830
/* This test checks that a LAG member validation happens on orchagent level
You can’t perform that action at this time.
0 commit comments