| 520 | double ProcessorClient::getTailLengthSeconds() { return m_tailSeconds; } |
| 521 | |
| 522 | void ProcessorClient::getStateInformation(String& settings) { |
| 523 | traceScope(); |
| 524 | |
| 525 | std::lock_guard<std::mutex> lock(m_cmdMtx); |
| 526 | |
| 527 | Message<GetPluginSettings> msg(this); |
| 528 | PLD(msg).setNumber(0); |
| 529 | if (!msg.send(m_sockCmdOut.get())) { |
| 530 | logln("getStateInformation failed: can't send message"); |
| 531 | return; |
| 532 | } |
| 533 | |
| 534 | Message<PluginSettings> res(this); |
| 535 | MessageHelper::Error err; |
| 536 | if (res.read(m_sockCmdOut.get(), &err, 5000)) { |
| 537 | m_lastSettings = PLD(res).getString(); |
| 538 | settings = m_lastSettings; |
| 539 | } else { |
| 540 | logln("getStateInformation failed: failed to read PluginSettings message: " << err.toString()); |
| 541 | m_sockCmdOut->close(); |
| 542 | return; |
| 543 | } |
| 544 | } |
| 545 | |
| 546 | void ProcessorClient::setStateInformation(const String& settings) { |
| 547 | traceScope(); |