diff options
author | Lennart Poettering <lennart@poettering.net> | 2007-10-27 12:59:59 +0000 |
---|---|---|
committer | Lennart Poettering <lennart@poettering.net> | 2007-10-27 12:59:59 +0000 |
commit | 55e4a3e221ef2adbc53a7c00a2e2fade2390036e (patch) | |
tree | 91611f2165d40e09d692c84c88472dc6452f2999 /src/pulsecore/pstream.c | |
parent | c4d9a2bf858e1603649352fce0551cbdcbfaad0c (diff) |
modernize pa_iochannel a bit, add pa_iochannel_get_send_fd()
git-svn-id: file:///home/lennart/svn/public/pulseaudio/branches/lennart@1957 fefdeb5f-60dc-0310-8127-8f9354f1896f
Diffstat (limited to 'src/pulsecore/pstream.c')
-rw-r--r-- | src/pulsecore/pstream.c | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/pulsecore/pstream.c b/src/pulsecore/pstream.c index 333012c0..9d32a363 100644 --- a/src/pulsecore/pstream.c +++ b/src/pulsecore/pstream.c @@ -217,12 +217,12 @@ static void io_callback(pa_iochannel*io, void *userdata) { static void defer_callback(pa_mainloop_api *m, pa_defer_event *e, void*userdata) { pa_pstream *p = userdata; - + pa_assert(p); pa_assert(PA_REFCNT_VALUE(p) > 0); pa_assert(p->defer_event == e); pa_assert(p->mainloop == m); - + do_something(p); } @@ -244,7 +244,7 @@ pa_pstream *pa_pstream_new(pa_mainloop_api *m, pa_iochannel *io, pa_mempool *poo p->mainloop = m; p->defer_event = m->defer_new(m, defer_callback, p); m->defer_enable(p->defer_event, 0); - + p->send_queue = pa_queue_new(); p->write.current = NULL; @@ -266,7 +266,7 @@ pa_pstream *pa_pstream_new(pa_mainloop_api *m, pa_iochannel *io, pa_mempool *poo p->revoke_callback_userdata = NULL; p->release_callback = NULL; p->release_callback_userdata = NULL; - + p->mempool = pool; p->use_shm = 0; @@ -335,7 +335,7 @@ void pa_pstream_send_packet(pa_pstream*p, pa_packet *packet, const pa_creds *cre if (!(i = pa_flist_pop(PA_STATIC_FLIST_GET(items)))) i = pa_xnew(struct item_info, 1); - + i->type = PA_PSTREAM_ITEM_PACKET; i->packet = pa_packet_ref(packet); @@ -365,7 +365,7 @@ void pa_pstream_send_memblock(pa_pstream*p, uint32_t channel, int64_t offset, pa length = chunk->length; bsm = pa_mempool_block_size_max(p->mempool); - + while (length > 0) { struct item_info *i; size_t n; @@ -662,7 +662,7 @@ static int do_read(pa_pstream *p) { #ifdef HAVE_CREDS { - int b = 0; + pa_bool_t b = 0; if ((r = pa_iochannel_read_with_creds(p->io, d, l, &p->read_creds, &b)) <= 0) goto fail; @@ -970,7 +970,7 @@ void pa_pstream_unlink(pa_pstream *p) { if (p->dead) return; - + p->dead = 1; if (p->import) { @@ -991,7 +991,7 @@ void pa_pstream_unlink(pa_pstream *p) { if (p->defer_event) { p->mainloop->defer_free(p->defer_event); p->defer_event = NULL; - } + } p->die_callback = NULL; p->drain_callback = NULL; |