Searched refs:ringbuffer (Results 1 – 3 of 3) sorted by relevance
54 deRingbuffer* ringbuffer = (deRingbuffer*)deCalloc(sizeof(deRingbuffer)); in deRingbuffer_create() local56 DE_ASSERT(ringbuffer); in deRingbuffer_create()60 ringbuffer->blockSize = blockSize; in deRingbuffer_create()61 ringbuffer->blockCount = blockCount; in deRingbuffer_create()62 ringbuffer->buffer = (deUint8*)deMalloc(sizeof(deUint8) * (size_t)blockSize * (size_t)blockCount); in deRingbuffer_create()63 ringbuffer->blockUsage = (deInt32*)deMalloc(sizeof(deUint32) * (size_t)blockCount); in deRingbuffer_create()64 ringbuffer->emptyCount = deSemaphore_create(ringbuffer->blockCount, DE_NULL); in deRingbuffer_create()65 ringbuffer->fullCount = deSemaphore_create(0, DE_NULL); in deRingbuffer_create()67 if (!ringbuffer->buffer || in deRingbuffer_create()68 !ringbuffer->blockUsage || in deRingbuffer_create()[all …]
31 deRingbuffer* ringbuffer; member41 deRingbuffer* ringbuffer; member78 deRingbuffer_stop(threadStream->ringbuffer); in inStreamCopy()110 deRingbuffer_stop(threadStream->ringbuffer); in threadStream_deinit()118 deRingbuffer_destroy(threadStream->ringbuffer); in threadStream_deinit()139 threadStream->ringbuffer = deRingbuffer_create(ringbufferBlockSize, ringbufferBlockCount); in deThreadInStream_init()140 DE_ASSERT(threadStream->ringbuffer); in deThreadInStream_init()144 deProducerStream_init(&(threadStream->producerStream), threadStream->ringbuffer); in deThreadInStream_init()145 deConsumerStream_init(&(threadStream->consumerStream), threadStream->ringbuffer); in deThreadInStream_init()197 threadStream->ringbuffer = deRingbuffer_create(ringbufferBlockSize, ringbufferBlockCount); in deThreadOutStream_init()[all …]
39 void deRingbuffer_stop (deRingbuffer* ringbuffer);40 void deRingbuffer_destroy (deRingbuffer* ringbuffer);