|
|
@ -51,6 +51,8 @@ void DMGasPathMgrService::setOnlineState(shared_ptr<MsgProcessContext> cxt, bool |
|
|
|
std::lock_guard<std::recursive_mutex> lock(lock_); |
|
|
|
logger->info("setOnlineState:{}", isOnline); |
|
|
|
this->isOnline = isOnline; |
|
|
|
stateUpdateThread->wake(); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
void DMGasPathMgrService::selectChannel(shared_ptr<MsgProcessContext> cxt, DMGasPath dmGasPath) { |
|
|
|