mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-02 09:01:46 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pstream: Use pa_xnew0 in initialization

Browse source 
...for simplicity.

Signed-off-by: David Henningsson <david.henningsson@canonical.com>
This commit is contained in:
David Henningsson 2014-04-15 11:52:22 +02:00
parent a5ba31bf96
commit d3f2bfa21b
1 changed files with 1 additions and 29 deletions
Download patch file Download diff file Expand all files Collapse all files

30
src/pulsecore/pstream.c
View file

@ -237,11 +237,10 @@ pa_pstream *pa_pstream_new(pa_mainloop_api *m, pa_iochannel *io, pa_mempool *poo
pa_assert(io); pa_assert(io);
pa_assert(pool); pa_assert(pool);
p = pa_xnew(pa_pstream, 1); p = pa_xnew0(pa_pstream, 1);
PA_REFCNT_INIT(p); PA_REFCNT_INIT(p);
p->io = io; p->io = io;
pa_iochannel_set_callback(io, io_callback, p); pa_iochannel_set_callback(io, io_callback, p);
p->dead = false;
p->mainloop = m; p->mainloop = m;
p->defer_event = m->defer_new(m, defer_callback, p); p->defer_event = m->defer_new(m, defer_callback, p);
@ -249,41 +248,14 @@ pa_pstream *pa_pstream_new(pa_mainloop_api *m, pa_iochannel *io, pa_mempool *poo
p->send_queue = pa_queue_new(); p->send_queue = pa_queue_new();
p->write.current = NULL;
p->write.index = 0;
pa_memchunk_reset(&p->write.memchunk);
p->read.memblock = NULL;
p->read.packet = NULL;
p->read.index = 0;
p->receive_packet_callback = NULL;
p->receive_packet_callback_userdata = NULL;
p->receive_memblock_callback = NULL;
p->receive_memblock_callback_userdata = NULL;
p->drain_callback = NULL;
p->drain_callback_userdata = NULL;
p->die_callback = NULL;
p->die_callback_userdata = NULL;
p->revoke_callback = NULL;
p->revoke_callback_userdata = NULL;
p->release_callback = NULL;
p->release_callback_userdata = NULL;
p->mempool = pool; p->mempool = pool;
p->use_shm = false;
p->export = NULL;
/* We do importing unconditionally */ /* We do importing unconditionally */
p->import = pa_memimport_new(p->mempool, memimport_release_cb, p); p->import = pa_memimport_new(p->mempool, memimport_release_cb, p);
pa_iochannel_socket_set_rcvbuf(io, pa_mempool_block_size_max(p->mempool)); pa_iochannel_socket_set_rcvbuf(io, pa_mempool_block_size_max(p->mempool));
pa_iochannel_socket_set_sndbuf(io, pa_mempool_block_size_max(p->mempool)); pa_iochannel_socket_set_sndbuf(io, pa_mempool_block_size_max(p->mempool));
#ifdef HAVE_CREDS
p->send_creds_now = false;
p->read_creds_valid = false;
#endif
return p; return p;
} }