ESPHome  2022.6.2
component.cpp
Go to the documentation of this file.
2 
4 #include "esphome/core/hal.h"
5 #include "esphome/core/helpers.h"
6 #include "esphome/core/log.h"
7 #include <utility>
8 
9 namespace esphome {
10 
11 static const char *const TAG = "component";
12 
13 namespace setup_priority {
14 
15 const float BUS = 1000.0f;
16 const float IO = 900.0f;
17 const float HARDWARE = 800.0f;
18 const float DATA = 600.0f;
19 const float PROCESSOR = 400.0;
20 const float BLUETOOTH = 350.0f;
21 const float AFTER_BLUETOOTH = 300.0f;
22 const float WIFI = 250.0f;
23 const float BEFORE_CONNECTION = 220.0f;
24 const float AFTER_WIFI = 200.0f;
25 const float AFTER_CONNECTION = 100.0f;
26 const float LATE = -100.0f;
27 
28 } // namespace setup_priority
29 
30 const uint32_t COMPONENT_STATE_MASK = 0xFF;
31 const uint32_t COMPONENT_STATE_CONSTRUCTION = 0x00;
32 const uint32_t COMPONENT_STATE_SETUP = 0x01;
33 const uint32_t COMPONENT_STATE_LOOP = 0x02;
34 const uint32_t COMPONENT_STATE_FAILED = 0x03;
35 const uint32_t STATUS_LED_MASK = 0xFF00;
36 const uint32_t STATUS_LED_OK = 0x0000;
37 const uint32_t STATUS_LED_WARNING = 0x0100;
38 const uint32_t STATUS_LED_ERROR = 0x0200;
39 
40 uint32_t global_state = 0; // NOLINT(cppcoreguidelines-avoid-non-const-global-variables)
41 
42 float Component::get_loop_priority() const { return 0.0f; }
43 
45 
47 
48 void Component::loop() {}
49 
50 void Component::set_interval(const std::string &name, uint32_t interval, std::function<void()> &&f) { // NOLINT
51  App.scheduler.set_interval(this, name, interval, std::move(f));
52 }
53 
54 bool Component::cancel_interval(const std::string &name) { // NOLINT
55  return App.scheduler.cancel_interval(this, name);
56 }
57 
58 void Component::set_retry(const std::string &name, uint32_t initial_wait_time, uint8_t max_attempts,
59  std::function<RetryResult()> &&f, float backoff_increase_factor) { // NOLINT
60  App.scheduler.set_retry(this, name, initial_wait_time, max_attempts, std::move(f), backoff_increase_factor);
61 }
62 
63 bool Component::cancel_retry(const std::string &name) { // NOLINT
64  return App.scheduler.cancel_retry(this, name);
65 }
66 
67 void Component::set_timeout(const std::string &name, uint32_t timeout, std::function<void()> &&f) { // NOLINT
68  return App.scheduler.set_timeout(this, name, timeout, std::move(f));
69 }
70 
71 bool Component::cancel_timeout(const std::string &name) { // NOLINT
72  return App.scheduler.cancel_timeout(this, name);
73 }
74 
75 void Component::call_loop() { this->loop(); }
76 void Component::call_setup() { this->setup(); }
77 void Component::call_dump_config() { this->dump_config(); }
78 
79 uint32_t Component::get_component_state() const { return this->component_state_; }
81  uint32_t state = this->component_state_ & COMPONENT_STATE_MASK;
82  switch (state) {
84  // State Construction: Call setup and set state to setup
85  this->component_state_ &= ~COMPONENT_STATE_MASK;
86  this->component_state_ |= COMPONENT_STATE_SETUP;
87  this->call_setup();
88  break;
90  // State setup: Call first loop and set state to loop
91  this->component_state_ &= ~COMPONENT_STATE_MASK;
92  this->component_state_ |= COMPONENT_STATE_LOOP;
93  this->call_loop();
94  break;
96  // State loop: Call loop
97  this->call_loop();
98  break;
99  case COMPONENT_STATE_FAILED: // NOLINT(bugprone-branch-clone)
100  // State failed: Do nothing
101  break;
102  default:
103  break;
104  }
105 }
106 const char *Component::get_component_source() const {
107  if (this->component_source_ == nullptr)
108  return "<unknown>";
109  return this->component_source_;
110 }
112  ESP_LOGE(TAG, "Component %s was marked as failed.", this->get_component_source());
113  this->component_state_ &= ~COMPONENT_STATE_MASK;
114  this->component_state_ |= COMPONENT_STATE_FAILED;
115  this->status_set_error();
116 }
117 void Component::defer(std::function<void()> &&f) { // NOLINT
118  App.scheduler.set_timeout(this, "", 0, std::move(f));
119 }
120 bool Component::cancel_defer(const std::string &name) { // NOLINT
121  return App.scheduler.cancel_timeout(this, name);
122 }
123 void Component::defer(const std::string &name, std::function<void()> &&f) { // NOLINT
124  App.scheduler.set_timeout(this, name, 0, std::move(f));
125 }
126 void Component::set_timeout(uint32_t timeout, std::function<void()> &&f) { // NOLINT
127  App.scheduler.set_timeout(this, "", timeout, std::move(f));
128 }
129 void Component::set_interval(uint32_t interval, std::function<void()> &&f) { // NOLINT
130  App.scheduler.set_interval(this, "", interval, std::move(f));
131 }
132 void Component::set_retry(uint32_t initial_wait_time, uint8_t max_attempts, std::function<RetryResult()> &&f,
133  float backoff_increase_factor) { // NOLINT
134  App.scheduler.set_retry(this, "", initial_wait_time, max_attempts, std::move(f), backoff_increase_factor);
135 }
136 bool Component::is_failed() { return (this->component_state_ & COMPONENT_STATE_MASK) == COMPONENT_STATE_FAILED; }
137 bool Component::can_proceed() { return true; }
138 bool Component::status_has_warning() { return this->component_state_ & STATUS_LED_WARNING; }
139 bool Component::status_has_error() { return this->component_state_ & STATUS_LED_ERROR; }
141  this->component_state_ |= STATUS_LED_WARNING;
143 }
145  this->component_state_ |= STATUS_LED_ERROR;
147 }
148 void Component::status_clear_warning() { this->component_state_ &= ~STATUS_LED_WARNING; }
149 void Component::status_clear_error() { this->component_state_ &= ~STATUS_LED_ERROR; }
150 void Component::status_momentary_warning(const std::string &name, uint32_t length) {
151  this->status_set_warning();
152  this->set_timeout(name, length, [this]() { this->status_clear_warning(); });
153 }
154 void Component::status_momentary_error(const std::string &name, uint32_t length) {
155  this->status_set_error();
156  this->set_timeout(name, length, [this]() { this->status_clear_error(); });
157 }
160  if (std::isnan(this->setup_priority_override_))
161  return this->get_setup_priority();
162  return this->setup_priority_override_;
163 }
164 void Component::set_setup_priority(float priority) { this->setup_priority_override_ = priority; }
165 
167 #ifdef CLANG_TIDY
168  bool loop_overridden = true;
169  bool call_loop_overridden = true;
170 #else
171 #pragma GCC diagnostic push
172 #pragma GCC diagnostic ignored "-Wpmf-conversions"
173  bool loop_overridden = (void *) (this->*(&Component::loop)) != (void *) (&Component::loop);
174  bool call_loop_overridden = (void *) (this->*(&Component::call_loop)) != (void *) (&Component::call_loop);
175 #pragma GCC diagnostic pop
176 #endif
177  return loop_overridden || call_loop_overridden;
178 }
179 
180 PollingComponent::PollingComponent(uint32_t update_interval) : update_interval_(update_interval) {}
181 
183  // Let the polling component subclass setup their HW.
184  this->setup();
185 
186  // Register interval.
187  this->set_interval("update", this->get_update_interval(), [this]() { this->update(); });
188 }
189 
190 uint32_t PollingComponent::get_update_interval() const { return this->update_interval_; }
191 void PollingComponent::set_update_interval(uint32_t update_interval) { this->update_interval_ = update_interval; }
192 
194  : started_(millis()), component_(component) {}
196  uint32_t now = millis();
197  if (now - started_ > 50) {
198  const char *src = component_ == nullptr ? "<null>" : component_->get_component_source();
199  ESP_LOGV(TAG, "Component %s took a long time for an operation (%.2f s).", src, (now - started_) / 1e3f);
200  ESP_LOGV(TAG, "Components should block for at most 20-30ms.");
201  ;
202  }
203 }
204 
205 } // namespace esphome
void setup()
const uint32_t COMPONENT_STATE_LOOP
Definition: component.cpp:33
const uint32_t COMPONENT_STATE_FAILED
Definition: component.cpp:34
const char * name
Definition: stm32flash.h:78
void loop()
RetryResult
Definition: component.h:64
const float DATA
For components that import data from directly connected sensors like DHT.
Definition: component.cpp:18
virtual void loop()
This method will be called repeatedly.
Definition: component.cpp:48
void set_interval(const std::string &name, uint32_t interval, std::function< void()> &&f)
Set an interval function with a unique name.
Definition: component.cpp:50
const float BEFORE_CONNECTION
For components that should be initialized after WiFi and before API is connected. ...
Definition: component.cpp:23
const float AFTER_CONNECTION
For components that should be initialized after a data connection (API/MQTT) is connected.
Definition: component.cpp:25
virtual float get_loop_priority() const
priority of loop().
Definition: component.cpp:42
bool cancel_timeout(const std::string &name)
Cancel a timeout function.
Definition: component.cpp:71
const float AFTER_WIFI
For components that should be initialized after WiFi is connected.
Definition: component.cpp:24
void set_retry(const std::string &name, uint32_t initial_wait_time, uint8_t max_attempts, std::function< RetryResult()> &&f, float backoff_increase_factor=1.0f)
Set an retry function with a unique name.
Definition: component.cpp:58
bool cancel_timeout(Component *component, const std::string &name)
Definition: scheduler.cpp:39
void status_momentary_warning(const std::string &name, uint32_t length=5000)
Definition: component.cpp:150
float get_actual_setup_priority() const
Definition: component.cpp:159
void set_timeout(const std::string &name, uint32_t timeout, std::function< void()> &&f)
Set a timeout function with a unique name.
Definition: component.cpp:67
bool cancel_interval(const std::string &name)
Cancel an interval function.
Definition: component.cpp:54
const uint32_t STATUS_LED_OK
Definition: component.cpp:36
void set_setup_priority(float priority)
Definition: component.cpp:164
void defer(const std::string &name, std::function< void()> &&f)
Defer a callback to the next loop() call.
Definition: component.cpp:123
const float LATE
For components that should be initialized at the very end of the setup process.
Definition: component.cpp:26
bool has_overridden_loop() const
Definition: component.cpp:166
bool status_has_warning()
Definition: component.cpp:138
virtual void dump_config()
Definition: component.cpp:158
const float AFTER_BLUETOOTH
Definition: component.cpp:21
virtual void call_dump_config()
Definition: component.cpp:77
uint32_t IRAM_ATTR HOT millis()
Definition: core.cpp:26
void status_momentary_error(const std::string &name, uint32_t length=5000)
Definition: component.cpp:154
uint32_t global_state
Definition: component.cpp:40
virtual void call_setup()
Definition: component.cpp:76
uint32_t get_component_state() const
Definition: component.cpp:79
const float BUS
For communication buses like i2c/spi.
Definition: component.cpp:15
virtual void setup()
Where the component&#39;s initialization should happen.
Definition: component.cpp:46
const uint32_t COMPONENT_STATE_SETUP
Definition: component.cpp:32
virtual float get_setup_priority() const
priority of setup().
Definition: component.cpp:44
void status_clear_warning()
Definition: component.cpp:148
const uint32_t COMPONENT_STATE_CONSTRUCTION
Definition: component.cpp:31
bool cancel_defer(const std::string &name)
Cancel a defer callback using the specified name, name must not be empty.
Definition: component.cpp:120
virtual void update()=0
const float PROCESSOR
For components that use data from sensors like displays.
Definition: component.cpp:19
const char * get_component_source() const
Get the integration where this component was declared as a string.
Definition: component.cpp:106
Application App
Global storage of Application pointer - only one Application can exist.
virtual bool can_proceed()
Definition: component.cpp:137
bool cancel_retry(Component *component, const std::string &name)
Definition: scheduler.cpp:116
WarnIfComponentBlockingGuard(Component *component)
Definition: component.cpp:193
void status_set_warning()
Definition: component.cpp:140
const uint32_t COMPONENT_STATE_MASK
Definition: component.cpp:30
bool cancel_retry(const std::string &name)
Cancel a retry function.
Definition: component.cpp:63
virtual uint32_t get_update_interval() const
Get the update interval in ms of this sensor.
Definition: component.cpp:190
const uint32_t STATUS_LED_WARNING
Definition: component.cpp:37
uint8_t priority
void status_clear_error()
Definition: component.cpp:149
const float HARDWARE
For components that deal with hardware and are very important like GPIO switch.
Definition: component.cpp:17
void call_setup() override
Definition: component.cpp:182
virtual void mark_failed()
Mark this component as failed.
Definition: component.cpp:111
bool cancel_interval(Component *component, const std::string &name)
Definition: scheduler.cpp:72
const float IO
For components that represent GPIO pins like PCF8573.
Definition: component.cpp:16
const uint32_t STATUS_LED_ERROR
Definition: component.cpp:38
void set_timeout(Component *component, const std::string &name, uint32_t timeout, std::function< void()> func)
Definition: scheduler.cpp:16
Definition: a4988.cpp:4
virtual void call_loop()
Definition: component.cpp:75
const uint32_t STATUS_LED_MASK
Definition: component.cpp:35
virtual void set_update_interval(uint32_t update_interval)
Manually set the update interval in ms for this polling object.
Definition: component.cpp:191
void set_retry(Component *component, const std::string &name, uint32_t initial_wait_time, uint8_t max_attempts, std::function< RetryResult()> func, float backoff_increase_factor=1.0f)
Definition: scheduler.cpp:94
void set_interval(Component *component, const std::string &name, uint32_t interval, std::function< void()> func)
Definition: scheduler.cpp:42
bool state
Definition: fan.h:34