diff options
author | Matt Spinler <spinler@us.ibm.com> | 2019-12-12 10:35:01 -0600 |
---|---|---|
committer | Matt Spinler <spinler@us.ibm.com> | 2020-01-27 08:06:26 -0600 |
commit | 7d800a4e5d1305fa64ce02b99b0ec522bc454bbd (patch) | |
tree | 664b9dc6fed93d0637c7ee2f12d756f31b736d92 /extensions/openpower-pels/host_notifier.cpp | |
parent | 5342d9ad13453e2fe9558b12137cd9be2e220544 (diff) | |
download | phosphor-logging-7d800a4e5d1305fa64ce02b99b0ec522bc454bbd.tar.gz phosphor-logging-7d800a4e5d1305fa64ce02b99b0ec522bc454bbd.zip |
PEL: On new PEL, send to host if necessary
When a new PEL comes in, send it to the host now if the host
is up and the class is currently idle.
The PLDM command will be dispatched in a standalone function
called from the event loop so that this function, which may
be part of the 'Create new log' D-Bus method response, can
return first.
Also added testcases to start verifying these paths now that
there is a full mock of the HostInterface class.
Signed-off-by: Matt Spinler <spinler@us.ibm.com>
Change-Id: Ib30a99cc61be9205122287ba310bc315d762e863
Diffstat (limited to 'extensions/openpower-pels/host_notifier.cpp')
-rw-r--r-- | extensions/openpower-pels/host_notifier.cpp | 36 |
1 files changed, 35 insertions, 1 deletions
diff --git a/extensions/openpower-pels/host_notifier.cpp b/extensions/openpower-pels/host_notifier.cpp index 8fe6955..f2d951f 100644 --- a/extensions/openpower-pels/host_notifier.cpp +++ b/extensions/openpower-pels/host_notifier.cpp @@ -155,7 +155,41 @@ void HostNotifier::newLogCallback(const PEL& pel) _pelQueue.push_back(pel.id()); - // TODO: Check if a send is needed now + if (!_dataIface.isHostUp()) + { + return; + } + + // Dispatch a command now if there isn't currently a command + // in progress and this is the first log in the queue or it + // previously gave up from a hard failure. + auto inProgress = (_inProgressPEL != 0) || _hostIface->cmdInProgress() || + _retryTimer.isEnabled(); + + auto firstPEL = _pelQueue.size() == 1; + auto gaveUp = _retryCount >= maxRetryAttempts; + + if (!inProgress && (firstPEL || gaveUp)) + { + _retryCount = 0; + + // Send a log, but from the event loop, not from here. + scheduleDispatch(); + } +} + +void HostNotifier::scheduleDispatch() +{ + _dispatcher = std::make_unique<sdeventplus::source::Defer>( + _hostIface->getEvent(), std::bind(std::mem_fn(&HostNotifier::dispatch), + this, std::placeholders::_1)); +} + +void HostNotifier::dispatch(sdeventplus::source::EventBase& source) +{ + _dispatcher.reset(); + + doNewLogNotify(); } void HostNotifier::doNewLogNotify() |