summaryrefslogtreecommitdiff
path: root/gr-audio/lib/oss/oss_source.cc
diff options
context:
space:
mode:
authorMarcus Müller <mmueller@gnuradio.org>2019-08-07 21:45:12 +0200
committerMarcus Müller <marcus@hostalia.de>2019-08-09 23:04:28 +0200
commitf7bbf2c1d8d780294f3e016aff239ca35eb6516e (patch)
treee09ab6112e02b2215b2d59ac24d3d6ea2edac745 /gr-audio/lib/oss/oss_source.cc
parent78431dc6941e3acc67c858277dfe4a0ed583643c (diff)
Tree: clang-format without the include sorting
Diffstat (limited to 'gr-audio/lib/oss/oss_source.cc')
-rw-r--r--gr-audio/lib/oss/oss_source.cc188
1 files changed, 91 insertions, 97 deletions
diff --git a/gr-audio/lib/oss/oss_source.cc b/gr-audio/lib/oss/oss_source.cc
index 4c6365d057..14b8a0c969 100644
--- a/gr-audio/lib/oss/oss_source.cc
+++ b/gr-audio/lib/oss/oss_source.cc
@@ -39,149 +39,143 @@
#include <stdexcept>
namespace gr {
- namespace audio {
-
- source::sptr
- oss_source_fcn(int sampling_rate,
- const std::string &device_name,
- bool ok_to_block)
- {
- return source::sptr
- (new oss_source(sampling_rate, device_name, ok_to_block));
- }
-
- static std::string
- default_device_name()
- {
- return prefs::singleton()->get_string
- ("audio_oss", "default_input_device", "/dev/dsp");
- }
-
- oss_source::oss_source(int sampling_rate,
- const std::string device_name,
- bool ok_to_block)
- : sync_block("audio_oss_source",
- io_signature::make(0, 0, 0),
- io_signature::make(1, 2, sizeof(float))),
- d_sampling_rate(sampling_rate),
- d_device_name(device_name.empty() ? default_device_name() : device_name),
- d_fd(-1), d_buffer(0), d_chunk_size(0)
- {
- if((d_fd = open(d_device_name.c_str(), O_RDONLY)) < 0) {
+namespace audio {
+
+source::sptr
+oss_source_fcn(int sampling_rate, const std::string& device_name, bool ok_to_block)
+{
+ return source::sptr(new oss_source(sampling_rate, device_name, ok_to_block));
+}
+
+static std::string default_device_name()
+{
+ return prefs::singleton()->get_string(
+ "audio_oss", "default_input_device", "/dev/dsp");
+}
+
+oss_source::oss_source(int sampling_rate, const std::string device_name, bool ok_to_block)
+ : sync_block("audio_oss_source",
+ io_signature::make(0, 0, 0),
+ io_signature::make(1, 2, sizeof(float))),
+ d_sampling_rate(sampling_rate),
+ d_device_name(device_name.empty() ? default_device_name() : device_name),
+ d_fd(-1),
+ d_buffer(0),
+ d_chunk_size(0)
+{
+ if ((d_fd = open(d_device_name.c_str(), O_RDONLY)) < 0) {
fprintf(stderr, "audio_oss_source: ");
perror(d_device_name.c_str());
throw std::runtime_error("audio_oss_source");
- }
+ }
- double CHUNK_TIME =
+ double CHUNK_TIME =
std::max(0.001, prefs::singleton()->get_double("audio_oss", "latency", 0.005));
- d_chunk_size = (int)(d_sampling_rate * CHUNK_TIME);
- set_output_multiple(d_chunk_size);
+ d_chunk_size = (int)(d_sampling_rate * CHUNK_TIME);
+ set_output_multiple(d_chunk_size);
- d_buffer = new short[d_chunk_size * 2];
+ d_buffer = new short[d_chunk_size * 2];
- int format = AFMT_S16_NE;
- int orig_format = format;
- if(ioctl(d_fd, SNDCTL_DSP_SETFMT, &format) < 0) {
+ int format = AFMT_S16_NE;
+ int orig_format = format;
+ if (ioctl(d_fd, SNDCTL_DSP_SETFMT, &format) < 0) {
std::cerr << "audio_oss_source: " << d_device_name << " ioctl failed\n";
- perror(d_device_name.c_str ());
+ perror(d_device_name.c_str());
throw std::runtime_error("audio_oss_source");
- }
+ }
- if(format != orig_format) {
+ if (format != orig_format) {
fprintf(stderr, "audio_oss_source: unable to support format %d\n", orig_format);
fprintf(stderr, " card requested %d instead.\n", format);
- }
+ }
- // set to stereo no matter what. Some hardware only does stereo
- int channels = 2;
- if(ioctl(d_fd, SNDCTL_DSP_CHANNELS, &channels) < 0 || channels != 2) {
+ // set to stereo no matter what. Some hardware only does stereo
+ int channels = 2;
+ if (ioctl(d_fd, SNDCTL_DSP_CHANNELS, &channels) < 0 || channels != 2) {
perror("audio_oss_source: could not set STEREO mode");
throw std::runtime_error("audio_oss_source");
- }
+ }
- // set sampling freq
- int sf = sampling_rate;
- if(ioctl(d_fd, SNDCTL_DSP_SPEED, &sf) < 0) {
- std::cerr << "audio_oss_source: "
- << d_device_name << ": invalid sampling_rate "
+ // set sampling freq
+ int sf = sampling_rate;
+ if (ioctl(d_fd, SNDCTL_DSP_SPEED, &sf) < 0) {
+ std::cerr << "audio_oss_source: " << d_device_name << ": invalid sampling_rate "
<< sampling_rate << "\n";
sampling_rate = 8000;
- if(ioctl(d_fd, SNDCTL_DSP_SPEED, &sf) < 0) {
- std::cerr << "audio_oss_source: failed to set sampling_rate to 8000\n";
- throw std::runtime_error ("audio_oss_source");
+ if (ioctl(d_fd, SNDCTL_DSP_SPEED, &sf) < 0) {
+ std::cerr << "audio_oss_source: failed to set sampling_rate to 8000\n";
+ throw std::runtime_error("audio_oss_source");
}
- }
}
+}
- oss_source::~oss_source()
- {
- close(d_fd);
- delete [] d_buffer;
- }
+oss_source::~oss_source()
+{
+ close(d_fd);
+ delete[] d_buffer;
+}
- int
- oss_source::work(int noutput_items,
- gr_vector_const_void_star &input_items,
- gr_vector_void_star &output_items)
- {
- float *f0 = (float *)output_items[0];
- float *f1 = (float *)output_items[1]; // will be invalid if this is mono output
+int oss_source::work(int noutput_items,
+ gr_vector_const_void_star& input_items,
+ gr_vector_void_star& output_items)
+{
+ float* f0 = (float*)output_items[0];
+ float* f1 = (float*)output_items[1]; // will be invalid if this is mono output
- const int shorts_per_item = 2; // L + R
- const int bytes_per_item = shorts_per_item * sizeof(short);
+ const int shorts_per_item = 2; // L + R
+ const int bytes_per_item = shorts_per_item * sizeof(short);
- // To minimize latency, never return more than CHUNK_TIME
- // worth of samples per call to work.
+ // To minimize latency, never return more than CHUNK_TIME
+ // worth of samples per call to work.
- noutput_items = std::min(noutput_items, d_chunk_size);
+ noutput_items = std::min(noutput_items, d_chunk_size);
- int base = 0;
- int ntogo = noutput_items;
+ int base = 0;
+ int ntogo = noutput_items;
- while(ntogo > 0) {
+ while (ntogo > 0) {
int nbytes = std::min(ntogo, d_chunk_size) * bytes_per_item;
int result_nbytes = read(d_fd, d_buffer, nbytes);
- if(result_nbytes < 0) {
- perror("audio_oss_source");
- return -1; // say we're done
+ if (result_nbytes < 0) {
+ perror("audio_oss_source");
+ return -1; // say we're done
}
- if((result_nbytes & (bytes_per_item - 1)) != 0) {
- fprintf(stderr, "audio_oss_source: internal error.\n");
- throw std::runtime_error("internal error");
+ if ((result_nbytes & (bytes_per_item - 1)) != 0) {
+ fprintf(stderr, "audio_oss_source: internal error.\n");
+ throw std::runtime_error("internal error");
}
int result_nitems = result_nbytes / bytes_per_item;
// now unpack samples into output streams
- switch(output_items.size()) {
- case 1: // mono output
- for(int i = 0; i < result_nitems; i++) {
- f0[base+i] = d_buffer[2*i+0] * (1.0 / 32767);
- }
- break;
+ switch (output_items.size()) {
+ case 1: // mono output
+ for (int i = 0; i < result_nitems; i++) {
+ f0[base + i] = d_buffer[2 * i + 0] * (1.0 / 32767);
+ }
+ break;
- case 2: // stereo output
- for(int i = 0; i < result_nitems; i++) {
- f0[base+i] = d_buffer[2*i+0] * (1.0 / 32767);
- f1[base+i] = d_buffer[2*i+1] * (1.0 / 32767);
- }
- break;
+ case 2: // stereo output
+ for (int i = 0; i < result_nitems; i++) {
+ f0[base + i] = d_buffer[2 * i + 0] * (1.0 / 32767);
+ f1[base + i] = d_buffer[2 * i + 1] * (1.0 / 32767);
+ }
+ break;
default:
- assert(0);
+ assert(0);
}
ntogo -= result_nitems;
base += result_nitems;
- }
-
- return noutput_items - ntogo;
}
- } /* namespace audio */
+ return noutput_items - ntogo;
+}
+
+} /* namespace audio */
} /* namespace gr */
generated by cgit v1.2.3 (git 2.39.1) at 2025-03-30 04:08:50 +0000