| 588 | } |
| 589 | |
| 590 | void ProcessorClient::suspendProcessing(bool b) { |
| 591 | m_suspended = b; |
| 592 | |
| 593 | std::lock_guard<std::mutex> lock(m_cmdMtx); |
| 594 | |
| 595 | if (b) { |
| 596 | Message<BypassPlugin> msg(this); |
| 597 | PLD(msg).setNumber(0); |
| 598 | msg.send(m_sockCmdOut.get()); |
| 599 | } else { |
| 600 | Message<UnbypassPlugin> msg(this); |
| 601 | PLD(msg).setNumber(0); |
| 602 | msg.send(m_sockCmdOut.get()); |
| 603 | } |
| 604 | } |
| 605 | |
| 606 | void ProcessorClient::suspendProcessingRemoteOnly(bool b) { |
| 607 | std::lock_guard<std::mutex> lock(m_cmdMtx); |