11 static struct pa_context
*context
= NULL
;
12 static struct pa_stream
*stream
= NULL
;
13 static struct pa_mainloop_api
*mainloop_api
= NULL
;
15 static void *buffer
= NULL
;
16 static size_t buffer_length
= 0, buffer_index
= 0;
18 static void* stdin_source
= NULL
;
20 static void context_die_callback(struct pa_context
*c
, void *userdata
) {
22 fprintf(stderr
, "Connection to server shut down, exiting.\n");
23 mainloop_api
->quit(mainloop_api
, 1);
26 static void stream_die_callback(struct pa_stream
*s
, void *userdata
) {
28 fprintf(stderr
, "Stream deleted, exiting.\n");
29 mainloop_api
->quit(mainloop_api
, 1);
32 static void do_write(size_t length
) {
34 assert(buffer
&& buffer_length
);
37 if (l
> buffer_length
)
40 pa_stream_write(stream
, buffer
+buffer_index
, l
);
47 buffer_index
= buffer_length
= 0;
51 static void stream_write_callback(struct pa_stream
*s
, size_t length
, void *userdata
) {
54 mainloop_api
->enable_io(mainloop_api
, stdin_source
, PA_MAINLOOP_API_IO_EVENT_INPUT
);
62 static void stream_complete_callback(struct pa_context
*c
, struct pa_stream
*s
, void *userdata
) {
66 fprintf(stderr
, "Stream creation failed.\n");
67 mainloop_api
->quit(mainloop_api
, 1);
72 pa_stream_set_die_callback(stream
, stream_die_callback
, NULL
);
73 pa_stream_set_write_callback(stream
, stream_write_callback
, NULL
);
76 static void context_complete_callback(struct pa_context
*c
, int success
, void *userdata
) {
77 static const struct pa_sample_spec ss
= {
78 .format
= PA_SAMPLE_S16NE
,
86 fprintf(stderr
, "Connection failed\n");
90 if (pa_stream_new(c
, PA_STREAM_PLAYBACK
, NULL
, "pacat", &ss
, NULL
, stream_complete_callback
, NULL
) < 0) {
91 fprintf(stderr
, "pa_stream_new() failed.\n");
98 mainloop_api
->quit(mainloop_api
, 1);
101 static void stdin_callback(struct pa_mainloop_api
*a
, void *id
, int fd
, enum pa_mainloop_api_io_events events
, void *userdata
) {
104 assert(a
== mainloop_api
&& id
&& fd
== STDIN_FILENO
&& events
== PA_MAINLOOP_API_IO_EVENT_INPUT
);
107 mainloop_api
->enable_io(mainloop_api
, stdin_source
, PA_MAINLOOP_API_IO_EVENT_NULL
);
111 if (!stream
|| !(l
= w
= pa_stream_writable_size(stream
)))
115 if ((r
= read(fd
, buffer
, l
)) <= 0) {
117 mainloop_api
->quit(mainloop_api
, 0);
119 fprintf(stderr
, "read() failed: %s\n", strerror(errno
));
120 mainloop_api
->quit(mainloop_api
, 1);
133 int main(int argc
, char *argv
[]) {
134 struct pa_mainloop
* m
;
137 if (!(m
= pa_mainloop_new())) {
138 fprintf(stderr
, "pa_mainloop_new() failed.\n");
142 mainloop_api
= pa_mainloop_get_api(m
);
144 if (!(stdin_source
= mainloop_api
->source_io(mainloop_api
, STDIN_FILENO
, PA_MAINLOOP_API_IO_EVENT_INPUT
, stdin_callback
, NULL
))) {
145 fprintf(stderr
, "source_io() failed.\n");
149 if (!(context
= pa_context_new(mainloop_api
, argv
[0]))) {
150 fprintf(stderr
, "pa_context_new() failed.\n");
154 if (pa_context_connect(context
, NULL
, context_complete_callback
, NULL
) < 0) {
155 fprintf(stderr
, "pa_context_connext() failed.\n");
159 pa_context_set_die_callback(context
, context_die_callback
, NULL
);
161 if (pa_mainloop_run(m
, &ret
) < 0) {
162 fprintf(stderr
, "pa_mainloop_run() failed.\n");
168 pa_stream_free(stream
);
170 pa_context_free(context
);