hayodea/salmanoff
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Formatting

Browse Source
This commit is contained in:
Hayodea Hekol
2025-09-16 18:46:30 -04:00
parent ddd6f6d6c6
commit c52c447a78
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
smocore/componentThread.cpp
+12 -10
View File
@@ -139,7 +139,8 @@ public:
[[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context [[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context
) )
{ {
std::cout << "Thread '" << target->name << "': handling JOLT request." std::cout << __func__ << ": Thread '" << target->name << "': handling "
"JOLT request."
<< "\n"; << "\n";
target->io_service.stop(); target->io_service.stop();
@@ -150,7 +151,8 @@ public:
[[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context [[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context
) )
{ {
std::cout << "Thread '" << target->name << "': handling startThread." std::cout << __func__ << ": Thread '" << target->name << "': handling "
"startThread."
<< "\n"; << "\n";
// Execute private setup sequence here // Execute private setup sequence here
@@ -163,8 +165,8 @@ public:
[[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context [[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context
) )
{ {
std::cout << "Thread '" << target->name << "': handling exitThread " std::cout << __func__ << ": Thread '" << target->name << "': handling "
"(main queue)." << std::endl; "exitThread (main queue)." << "\n";
target->cleanup(); target->cleanup();
target->io_service.stop(); target->io_service.stop();
@@ -175,8 +177,8 @@ public:
[[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context [[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context
) )
{ {
std::cout << "Thread '" << target->name << "': handling exitThread " std::cout << __func__ << ": Thread '" << target->name << "': handling "
"(pause queue)." << std::endl; "exitThread (pause queue)."<< "\n";
target->cleanup(); target->cleanup();
target->pause_io_service.stop(); target->pause_io_service.stop();
@@ -188,8 +190,8 @@ public:
[[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context [[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context
) )
{ {
std::cout << "Thread '" << target->name << "': handling pauseThread." std::cout << __func__ << ": Thread '" << target->name << "': handling "
<< std::endl; "pauseThread." << "\n";
/* We have to invoke the callback here before moving on because /* We have to invoke the callback here before moving on because
* our next operation is going to block the thread, so it won't * our next operation is going to block the thread, so it won't
@@ -204,8 +206,8 @@ public:
[[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context [[maybe_unused]] std::shared_ptr<ThreadLifetimeMgmtOp> context
) )
{ {
std::cout << "Thread '" << target->name << "': handling resumeThread." std::cout << __func__ << ": Thread '" << target->name << "': handling "
<< std::endl; "resumeThread." << "\n";
target->pause_io_service.stop(); target->pause_io_service.stop();
callOriginalCbFn(); callOriginalCbFn();