diff --git a/orchagent/aclorch.cpp b/orchagent/aclorch.cpp index fb79a2f157..dcda496be6 100644 --- a/orchagent/aclorch.cpp +++ b/orchagent/aclorch.cpp @@ -2128,7 +2128,7 @@ void AclOrch::doTask(Consumer &consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/copporch.cpp b/orchagent/copporch.cpp index a38aa99a4b..84f91b96fc 100644 --- a/orchagent/copporch.cpp +++ b/orchagent/copporch.cpp @@ -589,7 +589,7 @@ void CoppOrch::doTask(Consumer &consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/fdborch.cpp b/orchagent/fdborch.cpp index 7498eb7e05..0c224fd057 100644 --- a/orchagent/fdborch.cpp +++ b/orchagent/fdborch.cpp @@ -262,7 +262,7 @@ void FdbOrch::doTask(Consumer& consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } @@ -342,7 +342,7 @@ void FdbOrch::doTask(NotificationConsumer& consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/flexcounterorch.cpp b/orchagent/flexcounterorch.cpp index 1e057bfb5b..8493f6897a 100644 --- a/orchagent/flexcounterorch.cpp +++ b/orchagent/flexcounterorch.cpp @@ -45,7 +45,7 @@ void FlexCounterOrch::doTask(Consumer &consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/intfsorch.cpp b/orchagent/intfsorch.cpp index d9946fa981..75a78f3cec 100644 --- a/orchagent/intfsorch.cpp +++ b/orchagent/intfsorch.cpp @@ -252,7 +252,7 @@ void IntfsOrch::doTask(Consumer &consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/mirrororch.cpp b/orchagent/mirrororch.cpp index 25b798603c..ac6857ff4a 100644 --- a/orchagent/mirrororch.cpp +++ b/orchagent/mirrororch.cpp @@ -968,7 +968,7 @@ void MirrorOrch::doTask(Consumer& consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/neighorch.cpp b/orchagent/neighorch.cpp index 1eabb8e3aa..f416841800 100644 --- a/orchagent/neighorch.cpp +++ b/orchagent/neighorch.cpp @@ -275,7 +275,7 @@ void NeighOrch::doTask(Consumer &consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/orchdaemon.cpp b/orchagent/orchdaemon.cpp index de66476d50..70bd1caa45 100644 --- a/orchagent/orchdaemon.cpp +++ b/orchagent/orchdaemon.cpp @@ -179,7 +179,7 @@ bool OrchDaemon::init() /* * The order of the orch list is important for state restore of warm start and - * the queued processing in m_toSync map after gPortsOrch->isPortReady() is set. + * the queued processing in m_toSync map after gPortsOrch->allPortsReady() is set. * * For the multiple consumers in ports_tables, tasks for LAG_TABLE is processed before VLAN_TABLE * when iterating ConsumerMap. diff --git a/orchagent/pfcwdorch.cpp b/orchagent/pfcwdorch.cpp index 043ea64a03..a36ed411e6 100644 --- a/orchagent/pfcwdorch.cpp +++ b/orchagent/pfcwdorch.cpp @@ -53,7 +53,7 @@ void PfcWdOrch::doTask(Consumer& consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/policerorch.cpp b/orchagent/policerorch.cpp index 3aecf822c9..a5ddb1d790 100644 --- a/orchagent/policerorch.cpp +++ b/orchagent/policerorch.cpp @@ -114,7 +114,7 @@ void PolicerOrch::doTask(Consumer &consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/portsorch.cpp b/orchagent/portsorch.cpp index 5b1cdae88a..45ad327dde 100644 --- a/orchagent/portsorch.cpp +++ b/orchagent/portsorch.cpp @@ -388,7 +388,7 @@ void PortsOrch::removeDefaultBridgePorts() SWSS_LOG_NOTICE("Remove bridge ports from default 1Q bridge"); } -bool PortsOrch::isPortReady() +bool PortsOrch::allPortsReady() { return m_initDone && m_pendingPortSet.empty(); } @@ -2371,7 +2371,7 @@ void PortsOrch::doTask(Consumer &consumer) else { /* Wait for all ports to be initialized */ - if (!isPortReady()) + if (!allPortsReady()) { return; } @@ -3222,7 +3222,7 @@ void PortsOrch::doTask(NotificationConsumer &consumer) SWSS_LOG_ENTER(); /* Wait for all ports to be initialized */ - if (!isPortReady()) + if (!allPortsReady()) { return; } diff --git a/orchagent/portsorch.h b/orchagent/portsorch.h index a579e7f545..d2819e62ea 100644 --- a/orchagent/portsorch.h +++ b/orchagent/portsorch.h @@ -55,7 +55,7 @@ class PortsOrch : public Orch, public Subject public: PortsOrch(DBConnector *db, vector &tableNames); - bool isPortReady(); + bool allPortsReady(); bool isInitDone(); map& getAllPorts(); diff --git a/orchagent/qosorch.cpp b/orchagent/qosorch.cpp index 8859f8ef4b..f804bd4dcb 100644 --- a/orchagent/qosorch.cpp +++ b/orchagent/qosorch.cpp @@ -1386,7 +1386,7 @@ void QosOrch::doTask(Consumer &consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/routeorch.cpp b/orchagent/routeorch.cpp index 8187344e71..18b8997754 100644 --- a/orchagent/routeorch.cpp +++ b/orchagent/routeorch.cpp @@ -270,7 +270,7 @@ void RouteOrch::doTask(Consumer& consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/tunneldecaporch.cpp b/orchagent/tunneldecaporch.cpp index f056d5753f..5c196a703a 100644 --- a/orchagent/tunneldecaporch.cpp +++ b/orchagent/tunneldecaporch.cpp @@ -21,7 +21,7 @@ void TunnelDecapOrch::doTask(Consumer& consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } diff --git a/orchagent/watermarkorch.cpp b/orchagent/watermarkorch.cpp index 0cf746dcd4..25eb228230 100644 --- a/orchagent/watermarkorch.cpp +++ b/orchagent/watermarkorch.cpp @@ -50,7 +50,7 @@ void WatermarkOrch::doTask(Consumer &consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; } @@ -141,7 +141,7 @@ void WatermarkOrch::handleFcConfigUpdate(const std::string &key, const std::vect void WatermarkOrch::doTask(NotificationConsumer &consumer) { SWSS_LOG_ENTER(); - if (!gPortsOrch->isPortReady()) + if (!gPortsOrch->allPortsReady()) { return; }