blob: dfda21f0a4425ca292feb14e68bf2df752298aeb [file] [log] [blame]
Brad Bishope55ef3d2016-12-19 09:12:40 -05001/**
2 * Copyright © 2016 IBM Corporation
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16#include <iostream>
17#include <memory>
Brad Bishop9c7b6e02016-12-19 12:43:36 -050018#include <cstring>
19#include <cstdlib>
20#include <chrono>
Brad Bishop74aa4dd2017-01-06 09:50:31 -050021#include <algorithm>
Brad Bishope55ef3d2016-12-19 09:12:40 -050022#include "sensorset.hpp"
Brad Bishope55ef3d2016-12-19 09:12:40 -050023#include "hwmon.hpp"
24#include "sysfs.hpp"
Brad Bishopd499ca62016-12-19 09:24:50 -050025#include "mainloop.hpp"
Brad Bishopab795a12017-01-05 20:50:49 -050026#include "util.hpp"
Brad Bishope55ef3d2016-12-19 09:12:40 -050027
Brad Bishop9c7b6e02016-12-19 12:43:36 -050028using namespace std::literals::chrono_literals;
29
Brad Bishop74aa4dd2017-01-06 09:50:31 -050030static constexpr auto typeAttrMap =
31{
32 // 1 - hwmon class
33 // 2 - unit
34 // 3 - sysfs scaling factor
35 std::make_tuple(
36 hwmon::type::ctemp,
37 ValueInterface::Unit::DegreesC,
38 -3),
39 std::make_tuple(
40 hwmon::type::cfan,
41 ValueInterface::Unit::RPMS,
42 0),
43 std::make_tuple(
44 hwmon::type::cvolt,
45 ValueInterface::Unit::Volts,
46 -3),
47};
48
49auto getHwmonType(decltype(typeAttrMap)::const_reference attrs)
50{
51 return std::get<0>(attrs);
52}
53
54auto getUnit(decltype(typeAttrMap)::const_reference attrs)
55{
56 return std::get<1>(attrs);
57}
58
59auto getScale(decltype(typeAttrMap)::const_reference attrs)
60{
61 return std::get<2>(attrs);
62}
63
Brad Bishopb9e2b072016-12-19 13:47:10 -050064MainLoop::MainLoop(
Brad Bishop9c7b6e02016-12-19 12:43:36 -050065 sdbusplus::bus::bus&& bus,
Brad Bishopb9e2b072016-12-19 13:47:10 -050066 const std::string& path,
67 const char* prefix,
68 const char* root)
Brad Bishop9c7b6e02016-12-19 12:43:36 -050069 : _bus(std::move(bus)),
70 _manager(sdbusplus::server::manager::manager(_bus, root)),
71 _shutdown(false),
Brad Bishopb9e2b072016-12-19 13:47:10 -050072 _path(path),
73 _prefix(prefix),
Brad Bishop3c344d32017-01-05 11:48:39 -050074 _root(root),
75 state()
Brad Bishopd499ca62016-12-19 09:24:50 -050076{
Brad Bishop9c7b6e02016-12-19 12:43:36 -050077 if (_path.back() == '/')
78 {
79 _path.pop_back();
80 }
Brad Bishopd499ca62016-12-19 09:24:50 -050081}
82
83void MainLoop::shutdown() noexcept
84{
85 _shutdown = true;
86}
87
88void MainLoop::run()
Brad Bishope55ef3d2016-12-19 09:12:40 -050089{
90 // Check sysfs for available sensors.
Brad Bishopd499ca62016-12-19 09:24:50 -050091 auto sensors = std::make_unique<SensorSet>(_path);
Brad Bishope55ef3d2016-12-19 09:12:40 -050092
Brad Bishop75b4ab82017-01-06 09:33:50 -050093 for (auto& i : *sensors)
94 {
Brad Bishop73831cd2017-01-06 09:37:22 -050095 // Ignore inputs without a label.
96 std::string envKey = "LABEL_" + i.first.first + i.first.second;
97 std::string label;
98
99 auto env = getenv(envKey.c_str());
100
101 if (env)
102 {
103 label.assign(env);
104 }
105
106 if (label.empty())
107 {
108 continue;
109 }
110
Brad Bishop47378502017-01-06 09:47:41 -0500111 // Get the initial value for the value interface.
112 auto sysfsPath = make_sysfs_path(
113 _path,
114 i.first.first,
115 i.first.second,
116 hwmon::entry::input);
117 int val = 0;
118 read_sysfs(sysfsPath, val);
119
Brad Bishop075f7a22017-01-06 09:45:08 -0500120 Object o;
121 std::string objectPath{_root};
122
123 objectPath.append("/");
124 objectPath.append(i.first.first);
125 objectPath.append("/");
126 objectPath.append(label);
127
128 auto iface = std::make_shared<ValueObject>(_bus, objectPath.c_str());
Brad Bishop47378502017-01-06 09:47:41 -0500129 iface->value(val);
Brad Bishop74aa4dd2017-01-06 09:50:31 -0500130
131 const auto& attrs = std::find_if(
132 typeAttrMap.begin(),
133 typeAttrMap.end(),
134 [&](const auto & e)
135 {
136 return i.first.first == getHwmonType(e);
137 });
138 if (attrs != typeAttrMap.end())
139 {
140 iface->unit(getUnit(*attrs));
141 iface->scale(getScale(*attrs));
142 }
143
Brad Bishop075f7a22017-01-06 09:45:08 -0500144 o.emplace(InterfaceType::VALUE, iface);
145
146 auto value = std::make_tuple(
147 std::move(i.second),
148 std::move(label),
149 std::move(o));
Brad Bishop73831cd2017-01-06 09:37:22 -0500150
Brad Bishop75b4ab82017-01-06 09:33:50 -0500151 state[std::move(i.first)] = std::move(value);
152 }
153
Brad Bishop9c7b6e02016-12-19 12:43:36 -0500154 {
Brad Bishopab795a12017-01-05 20:50:49 -0500155 auto copy = std::unique_ptr<char, phosphor::utility::Free<char>>(strdup(
156 _path.c_str()));
Brad Bishop9c7b6e02016-12-19 12:43:36 -0500157 auto busname = std::string(_prefix) + '.' + basename(copy.get());
158 _bus.request_name(busname.c_str());
159 }
160
Brad Bishope55ef3d2016-12-19 09:12:40 -0500161 // TODO: Issue#3 - Need to make calls to the dbus sensor cache here to
162 // ensure the objects all exist?
163
164 // Polling loop.
Brad Bishopd499ca62016-12-19 09:24:50 -0500165 while (!_shutdown)
Brad Bishope55ef3d2016-12-19 09:12:40 -0500166 {
167 // Iterate through all the sensors.
Brad Bishop75b4ab82017-01-06 09:33:50 -0500168 for (auto& i : state)
Brad Bishope55ef3d2016-12-19 09:12:40 -0500169 {
Brad Bishop75b4ab82017-01-06 09:33:50 -0500170 auto& attrs = std::get<0>(i.second);
171 if (attrs.find(hwmon::entry::input) != attrs.end())
Brad Bishope55ef3d2016-12-19 09:12:40 -0500172 {
173 // Read value from sensor.
174 int value = 0;
Brad Bishopd499ca62016-12-19 09:24:50 -0500175 read_sysfs(make_sysfs_path(_path,
Brad Bishope55ef3d2016-12-19 09:12:40 -0500176 i.first.first, i.first.second,
177 hwmon::entry::input),
178 value);
179
Brad Bishopdddb7152017-01-06 09:54:23 -0500180 auto& obj = std::get<Object>(i.second);
181 auto iface = obj.find(InterfaceType::VALUE);
182
183 if (iface != obj.end())
184 {
185 auto realIface = std::experimental::any_cast<std::shared_ptr<ValueObject>>
186 (iface->second);
187 realIface->value(value);
188 }
Brad Bishope55ef3d2016-12-19 09:12:40 -0500189 }
190 }
191
Brad Bishop9c7b6e02016-12-19 12:43:36 -0500192 // Respond to DBus
193 _bus.process_discard();
194
Brad Bishope55ef3d2016-12-19 09:12:40 -0500195 // Sleep until next interval.
196 // TODO: Issue#5 - Make this configurable.
197 // TODO: Issue#6 - Optionally look at polling interval sysfs entry.
Brad Bishop9c7b6e02016-12-19 12:43:36 -0500198 _bus.wait((1000000us).count());
Brad Bishope55ef3d2016-12-19 09:12:40 -0500199
200 // TODO: Issue#7 - Should probably periodically check the SensorSet
201 // for new entries.
202 }
Brad Bishope55ef3d2016-12-19 09:12:40 -0500203}
204
205// vim: tabstop=8 expandtab shiftwidth=4 softtabstop=4