blob: 71ef339da2618ffb64acd046ecede562daa6dd8c [file] [log] [blame]
Patrick Venture863b9242018-03-08 08:29:23 -08001#pragma once
2
Patrick Ventureda4a5dd2018-08-31 09:42:48 -07003#include "dbus/util.hpp"
4#include "interfaces.hpp"
5
Patrick Venture863b9242018-03-08 08:29:23 -08006#include <chrono>
7#include <cmath>
8#include <iostream>
9#include <map>
Patrick Venture0ef1faf2018-06-13 12:50:53 -070010#include <memory>
Patrick Venture863b9242018-03-08 08:29:23 -080011#include <mutex>
Patrick Ventureda4a5dd2018-08-31 09:42:48 -070012#include <sdbusplus/bus.hpp>
13#include <sdbusplus/message.hpp>
14#include <sdbusplus/server.hpp>
Patrick Venture863b9242018-03-08 08:29:23 -080015#include <set>
16#include <string>
17#include <tuple>
18#include <vector>
19
Patrick Venture863b9242018-03-08 08:29:23 -080020int DbusHandleSignal(sd_bus_message* msg, void* data, sd_bus_error* err);
21
22/*
23 * This ReadInterface will passively listen for Value updates from whomever
24 * owns the associated dbus object.
25 *
26 * This requires another modification in phosphor-dbus-interfaces that will
27 * signal a value update every time it's read instead of only when it changes
28 * to help us:
29 * - ensure we're still receiving data (since we don't control the reader)
30 * - simplify stale data detection
31 * - simplify error detection
32 */
33class DbusPassive : public ReadInterface
34{
Patrick Ventureda4a5dd2018-08-31 09:42:48 -070035 public:
36 static std::unique_ptr<ReadInterface>
37 CreateDbusPassive(sdbusplus::bus::bus& bus, const std::string& type,
38 const std::string& id, DbusHelperInterface* helper);
Patrick Venture0ef1faf2018-06-13 12:50:53 -070039
Patrick Ventureda4a5dd2018-08-31 09:42:48 -070040 DbusPassive(sdbusplus::bus::bus& bus, const std::string& type,
41 const std::string& id, DbusHelperInterface* helper);
Patrick Venture863b9242018-03-08 08:29:23 -080042
Patrick Ventureda4a5dd2018-08-31 09:42:48 -070043 ReadReturn read(void) override;
James Feist36b7d8e2018-10-05 15:39:01 -070044 bool getFailed(void) const override;
Patrick Venture863b9242018-03-08 08:29:23 -080045
Patrick Ventureda4a5dd2018-08-31 09:42:48 -070046 void setValue(double value);
James Feist36b7d8e2018-10-05 15:39:01 -070047 void setFailed(bool value);
Patrick Ventureda4a5dd2018-08-31 09:42:48 -070048 int64_t getScale(void);
49 std::string getId(void);
Patrick Venture863b9242018-03-08 08:29:23 -080050
Patrick Ventureda4a5dd2018-08-31 09:42:48 -070051 private:
52 sdbusplus::bus::bus& _bus;
53 sdbusplus::server::match::match _signal;
54 int64_t _scale;
55 std::string _id; // for debug identification
56 DbusHelperInterface* _helper;
Patrick Venture863b9242018-03-08 08:29:23 -080057
Patrick Ventureda4a5dd2018-08-31 09:42:48 -070058 std::mutex _lock;
59 double _value = 0;
James Feist36b7d8e2018-10-05 15:39:01 -070060 bool _failed = false;
Patrick Ventureda4a5dd2018-08-31 09:42:48 -070061 /* The last time the value was refreshed, not necessarily changed. */
62 std::chrono::high_resolution_clock::time_point _updated;
Patrick Venture863b9242018-03-08 08:29:23 -080063};
64
Patrick Venture0df7c0f2018-06-13 09:02:13 -070065int HandleSensorValue(sdbusplus::message::message& msg, DbusPassive* owner);