sascha/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2025-11-04 00:51:49 +00:00
Code Issues Releases Wiki Activity

Fail if memory not allocated

Browse Source
This commit is contained in:
Jesse Hills
2024-01-15 13:31:51 +09:00
parent 317ee53188
commit c018ea0848
1 changed files with 14 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
esphome/components/esp_adf/speaker/esp_adf_speaker.cpp
View File

@@ -24,7 +24,17 @@ void ESPADFSpeaker::setup() {
ESP_LOGCONFIG(TAG, "Setting up ESP ADF Speaker..."); ESP_LOGCONFIG(TAG, "Setting up ESP ADF Speaker...");
this->buffer_queue_ = xQueueCreate(BUFFER_COUNT, sizeof(DataEvent)); this->buffer_queue_ = xQueueCreate(BUFFER_COUNT, sizeof(DataEvent));
if (this->buffer_queue_ == nullptr) {
ESP_LOGW(TAG, "Could not allocate buffer queue.");
this->mark_failed();
return;
}
this->event_queue_ = xQueueCreate(20, sizeof(TaskEvent)); this->event_queue_ = xQueueCreate(20, sizeof(TaskEvent));
if (this->event_queue_ == nullptr) {
ESP_LOGW(TAG, "Could not allocate event queue.");
this->mark_failed();
return;
}
} }
void ESPADFSpeaker::start() { this->state_ = speaker::STATE_STARTING; } void ESPADFSpeaker::start() { this->state_ = speaker::STATE_STARTING; }
@@ -246,6 +256,10 @@ void ESPADFSpeaker::loop() {
} }
size_t ESPADFSpeaker::play(const uint8_t *data, size_t length) { size_t ESPADFSpeaker::play(const uint8_t *data, size_t length) {
if (this->is_failed()) {
ESP_LOGE(TAG, "Failed to play audio, speaker is in failed state.");
return 0;
}
if (this->state_ != speaker::STATE_RUNNING && this->state_ != speaker::STATE_STARTING) { if (this->state_ != speaker::STATE_RUNNING && this->state_ != speaker::STATE_STARTING) {
this->start(); this->start();
} }