blob: 4b746db33971d6619062881dfaa37a0f2f255d64 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
#include "audio_element_handle.hpp"
#include "audio_element.hpp"
#include "freertos/projdefs.h"
namespace audio {
AudioElementHandle::AudioElementHandle(std::unique_ptr<TaskHandle_t> task,
std::shared_ptr<IAudioElement> element)
: task_(std::move(task)), element_(std::move(element)) {}
AudioElementHandle::~AudioElementHandle() {
Quit();
}
auto AudioElementHandle::CurrentState() -> ElementState {
return element_->ElementState();
}
auto AudioElementHandle::PlayPause(enum PlayPause state) -> void {
ElementState s = CurrentState();
if (state == PLAY && s == STATE_PAUSE) {
// Ensure we actually finished any previous pause command.
// TODO: really?
PauseSync();
SetStateAndWakeUp(STATE_RUN);
return;
}
if (state == PAUSE && s == STATE_RUN) {
element_->ElementState(STATE_PAUSE);
SetStateAndWakeUp(STATE_PAUSE);
return;
}
}
auto AudioElementHandle::Quit() -> void {
SetStateAndWakeUp(STATE_QUIT);
}
auto AudioElementHandle::PauseSync() -> void {
PlayPause(PAUSE);
MonitorUtilState(eSuspended);
}
auto AudioElementHandle::QuitSync() -> void {
Quit();
MonitorUtilState(eDeleted);
}
auto AudioElementHandle::MonitorUtilState(eTaskState desired) -> void {
while (eTaskGetState(task_.get()) != desired) {
WakeUpTask();
vTaskDelay(pdMS_TO_TICKS(1));
}
}
auto AudioElementHandle::SetStateAndWakeUp(ElementState state) -> void {
element_->ElementState(state);
WakeUpTask();
}
auto AudioElementHandle::WakeUpTask() -> void {
// TODO: various races where the task isn't blocked yet, but there is a block
// between now and its next element state check. Also think about chunk blocks
// nested in element bodies.
// Maybe we need a big mutex or semaphore somewhere in here.
switch (eTaskGetState(task_.get())) {
case eBlocked:
// TODO: when is this safe?
xTaskAbortDelay(task_.get());
break;
case eSuspended:
vTaskResume(task_.get());
break;
default:
return;
}
}
} // namespace audio
|
