diff options
Diffstat (limited to 'host-interface.hpp')
| -rw-r--r-- | host-interface.hpp | 30 |
1 files changed, 14 insertions, 16 deletions
diff --git a/host-interface.hpp b/host-interface.hpp index 0ad3bfb..8901a2b 100644 --- a/host-interface.hpp +++ b/host-interface.hpp @@ -4,7 +4,7 @@ #include <sdbusplus/bus.hpp> #include <phosphor-logging/elog.hpp> #include <xyz/openbmc_project/Control/Host/server.hpp> -#include "elog-errors.hpp" +#include <timer.hpp> namespace phosphor { @@ -26,13 +26,17 @@ class Host : public sdbusplus::server::object::object< * * @param[in] bus - The Dbus bus object * @param[in] objPath - The Dbus object path + * @param[in] events - The sd_event pointer */ Host(sdbusplus::bus::bus& bus, - const char* objPath) : + const char* objPath, + sd_event* events) : sdbusplus::server::object::object< sdbusplus::xyz::openbmc_project::Control::server::Host>( bus, objPath), - bus(bus) + bus(bus), + timer(events, + std::bind(&Host::hostTimeout, this)) {} /** @brief Send input command to host @@ -51,30 +55,24 @@ class Host : public sdbusplus::server::object::object< * passed to the host (which is required when calling this interface) * */ - Command getNextCommand() - { - if(this->workQueue.empty()) - { - log<level::ERR>("Control Host work queue is empty!"); - elog<xyz::openbmc_project::Control::Internal::Host::QueueEmpty>(); - } - Command command = this->workQueue.front(); - this->workQueue.pop(); - this->commandComplete(command, Result::Success); - this->checkQueue(); - return command; - } + Command getNextCommand(); private: /** @brief Check if anything in queue and alert host if so */ void checkQueue(); + /** @brief Call back interface on message timeouts to host */ + void hostTimeout(); + /** @brief Persistent sdbusplus DBus bus connection. */ sdbusplus::bus::bus& bus; /** @brief Queue to store the requested commands */ std::queue<Command> workQueue{}; + + /** @brief Timer for commands to host */ + phosphor::ipmi::Timer timer; }; } // namespace host |
