| 466 | } |
| 467 | |
| 468 | void ProcessorClient::unload() { |
| 469 | m_loaded = false; |
| 470 | |
| 471 | std::lock_guard<std::mutex> lock(m_cmdMtx); |
| 472 | |
| 473 | Message<DelPlugin> msg(this); |
| 474 | PLD(msg).setNumber(0); |
| 475 | msg.send(m_sockCmdOut.get()); |
| 476 | |
| 477 | MessageHelper::Error e; |
| 478 | MessageFactory msgFactory(this); |
| 479 | auto result = msgFactory.getResult(m_sockCmdOut.get(), 5, &e); |
| 480 | if (nullptr != result && result->getReturnCode() > -1) { |
| 481 | m_latency = result->getReturnCode(); |
| 482 | } else { |
| 483 | logln("unload failed: can read result message: " << e.toString()); |
| 484 | m_sockCmdOut->close(); |
| 485 | } |
| 486 | } |
| 487 | |
| 488 | const String ProcessorClient::getName() { return m_name; } |
| 489 | |