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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
/**
* @file pulse/player.c Pulseaudio sound driver - player
*
* Copyright (C) 2010 - 2016 Creytiv.com
*/
#include <pulse/pulseaudio.h>
#include <pulse/simple.h>
#include <pthread.h>
#include <re.h>
#include <rem.h>
#include <baresip.h>
#include "pulse.h"
struct auplay_st {
const struct auplay *ap; /* inheritance */
pa_simple *s;
pthread_t thread;
bool run;
int16_t *sampv;
size_t sampc;
auplay_write_h *wh;
void *arg;
};
static void auplay_destructor(void *arg)
{
struct auplay_st *st = arg;
/* Wait for termination of other thread */
if (st->run) {
debug("pulse: stopping playback thread\n");
st->run = false;
(void)pthread_join(st->thread, NULL);
}
if (st->s)
pa_simple_free(st->s);
mem_deref(st->sampv);
}
static void *write_thread(void *arg)
{
struct auplay_st *st = arg;
const size_t num_bytes = st->sampc * 2;
int ret, pa_error = 0;
while (st->run) {
st->wh(st->sampv, st->sampc, st->arg);
ret = pa_simple_write(st->s, st->sampv, num_bytes, &pa_error);
if (ret < 0) {
warning("pulse: pa_simple_write error (%s)\n",
pa_strerror(pa_error));
}
}
return NULL;
}
int pulse_player_alloc(struct auplay_st **stp, const struct auplay *ap,
struct auplay_prm *prm, const char *device,
auplay_write_h *wh, void *arg)
{
struct auplay_st *st;
pa_sample_spec ss;
pa_buffer_attr attr;
int err = 0, pa_error = 0;
if (!stp || !ap || !prm || !wh)
return EINVAL;
debug("pulse: opening player (%u Hz, %d channels, device '%s')\n",
prm->srate, prm->ch, device);
st = mem_zalloc(sizeof(*st), auplay_destructor);
if (!st)
return ENOMEM;
st->ap = ap;
st->wh = wh;
st->arg = arg;
st->sampc = prm->srate * prm->ch * prm->ptime / 1000;
st->sampv = mem_alloc(2 * st->sampc, NULL);
if (!st->sampv) {
err = ENOMEM;
goto out;
}
ss.format = PA_SAMPLE_S16NE;
ss.channels = prm->ch;
ss.rate = prm->srate;
attr.maxlength = (uint32_t)-1;
attr.tlength = (uint32_t)pa_usec_to_bytes(prm->ptime * 1000, &ss);
attr.prebuf = (uint32_t)-1;
attr.minreq = (uint32_t)-1;
attr.fragsize = (uint32_t)-1;
st->s = pa_simple_new(NULL,
"Baresip",
PA_STREAM_PLAYBACK,
str_isset(device) ? device : 0,
"VoIP Playback",
&ss,
NULL,
&attr,
&pa_error);
if (!st->s) {
warning("pulse: could not connect to server (%s)\n",
pa_strerror(pa_error));
err = ENODEV;
goto out;
}
st->run = true;
err = pthread_create(&st->thread, NULL, write_thread, st);
if (err) {
st->run = false;
goto out;
}
debug("pulse: playback started\n");
out:
if (err)
mem_deref(st);
else
*stp = st;
return err;
}
|
