pa_xfree(c->read_data);
pa_xfree(c->write_data);
-
- pa_iochannel_free(c->io);
+
+ if (c->io)
+ pa_iochannel_free(c->io);
if (c->defer_event)
c->protocol->core->mainloop->defer_free(c->defer_event);
static int do_read(struct connection *c) {
assert(c && c->io);
+/* pa_log("READ\n"); */
+
if (c->state == ESD_NEXT_REQUEST) {
ssize_t r;
assert(c->read_data_length < sizeof(c->request));
handler = proto_map+c->request;
- pa_log(__FILE__": executing request #%u\n", c->request);
+/* pa_log(__FILE__": executing request #%u\n", c->request); */
if (!handler->proc) {
pa_log(__FILE__": recieved unimplemented request #%u.\n", c->request);
assert(c->input_memblockq);
+/* pa_log("STREAMING_DATA\n"); */
+
if (!(l = pa_memblockq_missing(c->input_memblockq)))
return 0;
pa_log(__FILE__": read() failed: %s\n", r == 0 ? "EOF" : strerror(errno));
return -1;
}
+
+/* pa_log(__FILE__": read %u\n", r); */
chunk.memblock = c->playback.current_memblock;
chunk.index = c->playback.memblock_index;
static int do_write(struct connection *c) {
assert(c && c->io);
+/* pa_log("WRITE\n"); */
+
if (c->write_data_length) {
ssize_t r;
assert(c->protocol && c->protocol->core && c->protocol->core->mainloop && c->protocol->core->mainloop->defer_enable);
c->protocol->core->mainloop->defer_enable(c->defer_event, 0);
+
+/* pa_log("DOWORK\n"); */
- if (c->dead)
+ if (c->dead || !c->io)
return;
-
+
if (pa_iochannel_is_readable(c->io))
if (do_read(c) < 0)
goto fail;
-
+
if (pa_iochannel_is_writable(c->io))
if (do_write(c) < 0)
goto fail;
-
+
return;
fail:
if (c->state == ESD_STREAMING_DATA && c->sink_input) {
c->dead = 1;
pa_memblockq_prebuf_disable(c->input_memblockq);
- c->protocol->core->mainloop->defer_enable(c->defer_event, 0);
+
+ pa_iochannel_free(c->io);
+ c->io = NULL;
+
} else
connection_free(c);
}
struct connection *c = userdata;
assert(io && c && c->io == io);
+/* pa_log("IO\n"); */
+
do_work(c);
}
struct connection *c = userdata;
assert(a && c && c->defer_event == e);
+/* pa_log("DEFER\n"); */
+
do_work(c);
}
struct connection*c = i->userdata;
assert(i && c && length);
+/* pa_log("DROP\n"); */
+
pa_memblockq_drop(c->input_memblockq, chunk, length);
/* do something */