Skip to content

Commit

Permalink
gNOI Warm Reboot - rebootbackend changes
Browse files Browse the repository at this point in the history
  • Loading branch information
rkavitha-hcl authored and KAVITHA RAMALINGAM committed Dec 5, 2024
1 parent f21b38d commit ec885af
Show file tree
Hide file tree
Showing 5 changed files with 40 additions and 4 deletions.
32 changes: 30 additions & 2 deletions src/sonic-framework/rebootbackend/reboot_thread.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -114,6 +114,8 @@ void RebootThread::do_reboot(void) {

if (m_request.method() == RebootMethod::COLD) {
do_cold_reboot(s);
} else if (m_request.method() == RebootMethod::WARM) {
do_warm_reboot(s);
} else {
// This shouldn't be possible. Reference check_start_preconditions()
SWSS_LOG_ERROR("Received unrecognized method type = %s",
Expand Down Expand Up @@ -160,11 +162,28 @@ void RebootThread::do_cold_reboot(swss::Select &s) {
// We shouldn't be here. Platform reboot should've killed us.
log_error_and_set_non_retry_failure("platform failed to reboot");

// Set critical state
//m_critical_interface.report_critical_state("platform failed to reboot");
return;
}

void RebootThread::do_warm_reboot(swss::Select &s) {
SWSS_LOG_ENTER();
SWSS_LOG_NOTICE("Sending warm reboot request to platform");
if (send_dbus_reboot_request() == Progress::EXIT_EARLY) {
return;
}

// Wait for warm reboot. If we return, reboot failed.
if (wait_for_platform_reboot(s) == Progress::EXIT_EARLY) {
return;
}

// We shouldn't be here. Platform reboot should've killed us.
log_error_and_set_non_retry_failure("failed to warm reboot");

return;
}


void RebootThread::reboot_thread(void) {
SWSS_LOG_ENTER();

Expand All @@ -187,6 +206,15 @@ bool RebootThread::check_start_preconditions(const RebootRequest &request,
request.method() != RebootMethod::WARM) {
response.json_string = "RebootThread: Start rx'd unsupported method";
response.status = swss::StatusCode::SWSS_RC_INVALID_PARAM;
} else if (request.method() == RebootMethod::WARM) {
if (m_status.get_last_reboot_status() ==
RebootStatus_Status::RebootStatus_Status_STATUS_FAILURE) {
// If the last reboot failed with a non-retriable failure, don't retry.
// But, we will allow a cold boot to recover.
response.json_string =
"RebootThread: last WARM reboot failed with non-retriable failure";
response.status = swss::StatusCode::SWSS_RC_FAILED_PRECONDITION;
}
} else if (request.delay() != 0) {
response.json_string = "RebootThread: delayed start not supported";
response.status = swss::StatusCode::SWSS_RC_INVALID_PARAM;
Expand Down
1 change: 1 addition & 0 deletions src/sonic-framework/rebootbackend/reboot_thread.h
Original file line number Diff line number Diff line change
Expand Up @@ -161,6 +161,7 @@ class RebootThread {
void do_reboot(void);
Progress send_dbus_reboot_request();
void do_cold_reboot(swss::Select &s);
void do_warm_reboot(swss::Select &s);

// Inner loop select handler to wait for platform reboot.
// wait for timeout
Expand Down
9 changes: 9 additions & 0 deletions src/sonic-framework/rebootbackend/rebootbe.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@
#include "reboot_interfaces.h"
#include "select.h"
#include "status_code_util.h"
#include "warm_restart.h"

namespace rebootbackend {

Expand Down Expand Up @@ -48,6 +49,14 @@ void RebootBE::Start() {
s.addSelectable(&m_Done);
s.addSelectable(&m_RebootThreadFinished);


if (swss::WarmStart::isWarmStart()) {
SWSS_LOG_NOTICE("Launching init thread for warm start");
SetCurrentStatus(RebManagerStatus::WARM_INIT_WAIT);
} else {
SWSS_LOG_NOTICE("Warm restart not enabled");
}

SWSS_LOG_NOTICE("RebootBE entering operational loop");
while (true) {
swss::Selectable *sel;
Expand Down
1 change: 0 additions & 1 deletion src/sonic-framework/tests/reboot_thread_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@ namespace rebootbackend {

#define TENTH_SECOND_MS (100)

//using namespace gnoi::system;
namespace gpu = ::google::protobuf::util;
using Progress = ::rebootbackend::RebootThread::Progress;
using RebootThread = ::rebootbackend::RebootThread;
Expand Down
1 change: 0 additions & 1 deletion src/sonic-framework/tests/rebootbe_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,6 @@ class RebootBETestWithoutStop : public ::testing::Test {
}
virtual ~RebootBETestWithoutStop() = default;


void start_rebootbe() {
m_rebootbe_thread =
std::make_unique<std::thread>(&RebootBE::Start, &m_rebootbe);
Expand Down

0 comments on commit ec885af

Please sign in to comment.