]> git.sesse.net Git - nageru/blob - nageru/alsa_input.h
Remove a TODO that was fixed a while back.
[nageru] / nageru / alsa_input.h
1 #ifndef _ALSA_INPUT_H
2 #define _ALSA_INPUT_H 1
3
4 // ALSA sound input, running in a separate thread and sending audio back
5 // in callbacks.
6 //
7 // Note: “frame” here generally refers to the ALSA definition of frame,
8 // which is a set of samples, exactly one for each channel.
9
10 #include <alsa/asoundlib.h>
11 #include <stdint.h>
12 #include <sys/types.h>
13 #include <atomic>
14 #include <chrono>
15 #include <functional>
16 #include <memory>
17 #include <string>
18 #include <thread>
19
20 #include "bmusb/bmusb.h"
21 #include "quittable_sleeper.h"
22
23 class ALSAPool;
24
25 class ALSAInput {
26 public:
27         typedef std::function<bool(const uint8_t *data, unsigned num_samples, bmusb::AudioFormat audio_format, std::chrono::steady_clock::time_point ts)> audio_callback_t;
28
29         ALSAInput(const char *device, unsigned sample_rate, unsigned num_channels, audio_callback_t audio_callback, ALSAPool *parent_pool, unsigned internal_dev_index);
30         ~ALSAInput();
31
32         // If not called before start_capture_thread(), the capture thread
33         // will call it until it succeeds.
34         bool open_device();
35
36         // Not valid before the device has been successfully opened.
37         // NOTE: Might very well be different from the sample rate given to the
38         // constructor, since the card might not support the one you wanted.
39         unsigned get_sample_rate() const { return sample_rate; }
40
41         void start_capture_thread();
42         void stop_capture_thread();
43
44         // Set access, sample rate and format parameters on the given ALSA PCM handle.
45         // Returns the computed parameter set and the chosen sample rate. Note that
46         // sample_rate is an in/out parameter; you send in the desired rate,
47         // and ALSA picks one as close to that as possible.
48         static bool set_base_params(const char *device_name, snd_pcm_t *pcm_handle, snd_pcm_hw_params_t *hw_params, unsigned *sample_rate);
49
50 private:
51         bool done_init = false;
52         void capture_thread_func();
53
54         enum class CaptureEndReason {
55                 REQUESTED_QUIT,
56                 DEVICE_GONE,
57                 OTHER_ERROR
58         };
59         CaptureEndReason do_capture();
60
61         std::string device;
62         unsigned sample_rate, num_channels, num_periods;
63         snd_pcm_uframes_t period_size;
64         snd_pcm_uframes_t buffer_frames;
65         bmusb::AudioFormat audio_format;
66         audio_callback_t audio_callback;
67
68         snd_pcm_t *pcm_handle = nullptr;
69         std::thread capture_thread;
70         QuittableSleeper should_quit;
71         std::unique_ptr<uint8_t[]> buffer;
72         ALSAPool *parent_pool;
73         unsigned internal_dev_index;
74 };
75
76 #endif  // !defined(_ALSA_INPUT_H)