src/sourceoutput.c

   1 #include <assert.h>
   2 #include <stdlib.h>
   3 #include <string.h>
   4
   5 #include "sourceoutput.h"
   6 #include "strbuf.h"
   7
   8 struct pa_source_output* pa_source_output_new(struct pa_source *s, const char *name, const struct pa_sample_spec *spec) {
   9     struct pa_source_output *o;
  10     struct pa_resampler *resampler = NULL;
  11     int r;
  12     assert(s && spec);
  13
  14     if (!pa_sample_spec_equal(&s->sample_spec, spec))
  15         if (!(resampler = pa_resampler_new(&s->sample_spec, spec)))
  16             return NULL;
  17
  18     o = malloc(sizeof(struct pa_source_output));
  19     assert(o);
  20     o->name = name ? strdup(name) : NULL;
  21     o->source = s;
  22     o->sample_spec = *spec;
  23
  24     o->push = NULL;
  25     o->kill = NULL;
  26     o->userdata = NULL;
  27     o->resampler = resampler;
  28
  29     assert(s->core);
  30     r = pa_idxset_put(s->core->source_outputs, o, &o->index);
  31     assert(r == 0 && o->index != PA_IDXSET_INVALID);
  32     r = pa_idxset_put(s->outputs, o, NULL);
  33     assert(r == 0);
  34
  35     return o;
  36 }
  37
  38 void pa_source_output_free(struct pa_source_output* o) {
  39     assert(o);
  40
  41     assert(o->source && o->source->core);
  42     pa_idxset_remove_by_data(o->source->core->source_outputs, o, NULL);
  43     pa_idxset_remove_by_data(o->source->outputs, o, NULL);
  44
  45     if (o->resampler)
  46         pa_resampler_free(o->resampler);
  47
  48     free(o->name);
  49     free(o);
  50 }
  51
  52 void pa_source_output_kill(struct pa_source_output*i) {
  53     assert(i);
  54
  55     if (i->kill)
  56         i->kill(i);
  57 }
  58
  59 char *pa_source_output_list_to_string(struct pa_core *c) {
  60     struct pa_strbuf *s;
  61     struct pa_source_output *o;
  62     uint32_t index = PA_IDXSET_INVALID;
  63     assert(c);
  64
  65     s = pa_strbuf_new();
  66     assert(s);
  67
  68     pa_strbuf_printf(s, "%u source outputs(s) available.\n", pa_idxset_ncontents(c->source_outputs));
  69
  70     for (o = pa_idxset_first(c->source_outputs, &index); o; o = pa_idxset_next(c->source_outputs, &index)) {
  71         char ss[PA_SAMPLE_SNPRINT_MAX_LENGTH];
  72         pa_sample_snprint(ss, sizeof(ss), &o->sample_spec);
  73         assert(o->source);
  74         pa_strbuf_printf(
  75             s, "  index: %u\n\tname: <%s>\n\tsource: <%u>\n\tsample_spec: <%s>\n",
  76             o->index,
  77             o->name,
  78             o->source->index,
  79             ss);
  80     }
  81
  82     return pa_strbuf_tostring_free(s);
  83 }
  84
  85 void pa_source_output_push(struct pa_source_output *o, const struct pa_memchunk *chunk) {
  86     struct pa_memchunk rchunk;
  87     assert(o && chunk && chunk->length && o->push);
  88
  89     if (!o->resampler) {
  90         o->push(o, chunk);
  91         return;
  92     }
  93
  94     pa_resampler_run(o->resampler, chunk, &rchunk);
  95     if (!rchunk.length)
  96         return;
  97
  98     assert(rchunk.memblock);
  99     o->push(o, &rchunk);
 100     pa_memblock_unref(rchunk.memblock);
 101 }