mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-10-29 05:40:23 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

when transferring large memory chunks of a pa_pstream, split them up

Browse source 
git-svn-id: file:///home/lennart/svn/public/pulseaudio/trunk@1300 fefdeb5f-60dc-0310-8127-8f9354f1896f
This commit is contained in:
Lennart Poettering 2006-08-19 18:57:33 +00:00
parent 79b26280cc
commit c0b3e8b346
1 changed files with 29 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

40
src/pulsecore/pstream.c
View file

@ -78,7 +78,8 @@ enum {
typedef uint32_t pa_pstream_descriptor[PA_PSTREAM_DESCRIPTOR_MAX]; typedef uint32_t pa_pstream_descriptor[PA_PSTREAM_DESCRIPTOR_MAX];
#define PA_PSTREAM_DESCRIPTOR_SIZE (PA_PSTREAM_DESCRIPTOR_MAX*sizeof(uint32_t)) #define PA_PSTREAM_DESCRIPTOR_SIZE (PA_PSTREAM_DESCRIPTOR_MAX*sizeof(uint32_t))
#define FRAME_SIZE_MAX PA_SCACHE_ENTRY_SIZE_MAX /* allow uploading a single sample in one frame at max */ #define FRAME_SIZE_MAX_ALLOW PA_SCACHE_ENTRY_SIZE_MAX /* allow uploading a single sample in one frame at max */
#define FRAME_SIZE_MAX_USE (1024*64)
struct item_info { struct item_info {
enum { enum {
@ -323,7 +324,7 @@ void pa_pstream_send_packet(pa_pstream*p, pa_packet *packet, const pa_creds *cre
} }
void pa_pstream_send_memblock(pa_pstream*p, uint32_t channel, int64_t offset, pa_seek_mode_t seek_mode, const pa_memchunk *chunk) { void pa_pstream_send_memblock(pa_pstream*p, uint32_t channel, int64_t offset, pa_seek_mode_t seek_mode, const pa_memchunk *chunk) {
struct item_info *i; size_t length, idx;
assert(p); assert(p);
assert(p->ref >= 1); assert(p->ref >= 1);
@ -333,19 +334,34 @@ void pa_pstream_send_memblock(pa_pstream*p, uint32_t channel, int64_t offset, pa
if (p->dead) if (p->dead)
return; return;
i = pa_xnew(struct item_info, 1); length = chunk->length;
i->type = PA_PSTREAM_ITEM_MEMBLOCK; idx = 0;
i->chunk = *chunk;
i->channel = channel; while (length > 0) {
i->offset = offset; struct item_info *i;
i->seek_mode = seek_mode; size_t n;
i = pa_xnew(struct item_info, 1);
i->type = PA_PSTREAM_ITEM_MEMBLOCK;
n = length < FRAME_SIZE_MAX_USE ? length : FRAME_SIZE_MAX_USE;
i->chunk.index = chunk->index + idx;
i->chunk.length = n;
i->chunk.memblock = pa_memblock_ref(chunk->memblock);
i->channel = channel;
i->offset = offset;
i->seek_mode = seek_mode;
#ifdef HAVE_CREDS #ifdef HAVE_CREDS
i->with_creds = 0; i->with_creds = 0;
#endif #endif
pa_memblock_ref(i->chunk.memblock); pa_queue_push(p->send_queue, i);
idx += n;
length -= n;
}
pa_queue_push(p->send_queue, i);
p->mainloop->defer_enable(p->defer_event, 1); p->mainloop->defer_enable(p->defer_event, 1);
} }
@ -599,7 +615,7 @@ static int do_read(pa_pstream *p) {
length = ntohl(p->read.descriptor[PA_PSTREAM_DESCRIPTOR_LENGTH]); length = ntohl(p->read.descriptor[PA_PSTREAM_DESCRIPTOR_LENGTH]);
if (length > FRAME_SIZE_MAX) { if (length > FRAME_SIZE_MAX_ALLOW) {
pa_log_warn("Recieved invalid frame size : %lu", (unsigned long) length); pa_log_warn("Recieved invalid frame size : %lu", (unsigned long) length);
return -1; return -1;
} }