Searched refs:threadStream (Results 1 – 1 of 1) sorted by relevance
49 deThreadInStream* threadStream = (deThreadInStream*)arg; in inStreamCopy() local51 deUint8* buffer = malloc(sizeof(deUint8) * (size_t)threadStream->bufferSize); in inStreamCopy()59 readResult = deInStream_read(threadStream->input, buffer, threadStream->bufferSize, &read); in inStreamCopy()66 deOutStream_write(&(threadStream->producerStream), buffer, read - written, &wrote); in inStreamCopy()77 deOutStream_flush(&(threadStream->producerStream)); in inStreamCopy()78 deRingbuffer_stop(threadStream->ringbuffer); in inStreamCopy()85 deThreadInStream* threadStream = (deThreadInStream*)stream; in threadInStream_read() local86 return deInStream_read(&(threadStream->consumerStream), buf, bufSize, numRead); in threadInStream_read()91 deThreadInStream* threadStream = (deThreadInStream*)stream; in threadInStream_getError() local94 return deInStream_getError(&(threadStream->consumerStream)); in threadInStream_getError()[all …]