49 	deThreadInStream* threadStream = (deThreadInStream*)arg;  in inStreamCopy()  local
51 	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()  local
86 	return deInStream_read(&(threadStream->consumerStream), buf, bufSize, numRead);  in threadInStream_read()
91 	deThreadInStream* threadStream = (deThreadInStream*)stream;  in threadInStream_getError()  local
94 	return deInStream_getError(&(threadStream->consumerStream));  in threadInStream_getError()
99 	deThreadInStream* threadStream = (deThreadInStream*)stream;  in threadInStream_getStatus()  local
102 	return deInStream_getStatus(&(threadStream->consumerStream));  in threadInStream_getStatus()
108 	deThreadInStream* threadStream = (deThreadInStream*)stream;  in threadStream_deinit()  local
110 	deRingbuffer_stop(threadStream->ringbuffer);  in threadStream_deinit()
112 	deThread_join(threadStream->thread);  in threadStream_deinit()
113 	deThread_destroy(threadStream->thread);  in threadStream_deinit()
115 	deOutStream_deinit(&(threadStream->producerStream));  in threadStream_deinit()
116 	deInStream_deinit(&(threadStream->consumerStream));  in threadStream_deinit()
118 	deRingbuffer_destroy(threadStream->ringbuffer);  in threadStream_deinit()
134 	deThreadInStream* threadStream = DE_NULL;  in deThreadInStream_init()  local
136 	threadStream = malloc(sizeof(deThreadInStream));  in deThreadInStream_init()
137 	DE_ASSERT(threadStream);  in deThreadInStream_init()
139 	threadStream->ringbuffer = deRingbuffer_create(ringbufferBlockSize, ringbufferBlockCount);  in deThreadInStream_init()
140 	DE_ASSERT(threadStream->ringbuffer);  in deThreadInStream_init()
142 	threadStream->bufferSize = ringbufferBlockSize;  in deThreadInStream_init()
143 	threadStream->input = input;  in deThreadInStream_init()
144 	deProducerStream_init(&(threadStream->producerStream), threadStream->ringbuffer);  in deThreadInStream_init()
145 	deConsumerStream_init(&(threadStream->consumerStream), threadStream->ringbuffer);  in deThreadInStream_init()
147 	threadStream->thread		= deThread_create(inStreamCopy, threadStream, DE_NULL);  in deThreadInStream_init()
149 	stream->ioStream.streamData = threadStream;  in deThreadInStream_init()
154 	deThreadOutStream* threadStream = (deThreadOutStream*)stream;  in threadOutStream_write()  local
155 	return deOutStream_write(&(threadStream->producerStream), buf, bufSize, numWritten);  in threadOutStream_write()
160 	deThreadOutStream* threadStream = (deThreadOutStream*)stream;  in threadOutStream_getError()  local
163 	return deOutStream_getError(&(threadStream->producerStream));  in threadOutStream_getError()
168 	deThreadOutStream* threadStream = (deThreadOutStream*)stream;  in threadOutStream_getStatus()  local
171 	return deOutStream_getStatus(&(threadStream->producerStream));  in threadOutStream_getStatus()
176 	deThreadOutStream* threadStream = (deThreadOutStream*)stream;  in threadOutStream_flush()  local
178 	return deOutStream_flush(&(threadStream->producerStream));  in threadOutStream_flush()
192 	deThreadOutStream* threadStream = DE_NULL;  in deThreadOutStream_init()  local
194 	threadStream = malloc(sizeof(deThreadOutStream));  in deThreadOutStream_init()
195 	DE_ASSERT(threadStream);  in deThreadOutStream_init()
197 	threadStream->ringbuffer = deRingbuffer_create(ringbufferBlockSize, ringbufferBlockCount);  in deThreadOutStream_init()
198 	DE_ASSERT(threadStream->ringbuffer);  in deThreadOutStream_init()
200 	deProducerStream_init(&(threadStream->producerStream), threadStream->ringbuffer);  in deThreadOutStream_init()
201 	deConsumerStream_init(&(threadStream->consumerStream), threadStream->ringbuffer);  in deThreadOutStream_init()
203 …threadStream->thread		= deStreamCpyThread_create(&(threadStream->consumerStream), output, ringbuff…  in deThreadOutStream_init()
205 	stream->ioStream.streamData = threadStream;  in deThreadOutStream_init()