Skip to content

Commit

Permalink
Fix pre shutdown select (sonic-net#397)
Browse files Browse the repository at this point in the history
  • Loading branch information
kcudnik committed Dec 7, 2018
1 parent f734752 commit 31fd65e
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions syncd/syncd.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3633,21 +3633,21 @@ int syncd_main(int argc, char **argv)

SWSS_LOG_NOTICE("syncd listening for events");

swss::Select s;
std::shared_ptr<swss::Select> s = std::make_shared<swss::Select>();

s.addSelectable(asicState.get());
s.addSelectable(restartQuery.get());
s.addSelectable(flexCounter.get());
s.addSelectable(flexCounterGroup.get());
s.addSelectable(ffb.get());
s->addSelectable(asicState.get());
s->addSelectable(restartQuery.get());
s->addSelectable(flexCounter.get());
s->addSelectable(flexCounterGroup.get());
s->addSelectable(ffb.get());

SWSS_LOG_NOTICE("starting main loop");

while(true)
{
swss::Selectable *sel = NULL;

int result = s.select(&sel);
int result = s->select(&sel);

if (sel == restartQuery.get())
{
Expand Down Expand Up @@ -3710,9 +3710,9 @@ int syncd_main(int argc, char **argv)
{
warmRestartTable->hset("warm-shutdown", "state", "pre-shutdown-succeeded");

s = swss::Select();
s = std::make_shared<swss::Select>(); // make sure previous select is destroyed

s.addSelectable(restartQuery.get());
s->addSelectable(restartQuery.get());

SWSS_LOG_NOTICE("switched to PRE_SHUTDOWN, from now on accepting only shurdown requests");
}
Expand Down

0 comments on commit 31fd65e

Please sign in to comment.