Lines Matching refs:thread
30 deStreamCpyThread* thread = (deStreamCpyThread*)arg; in cpyStream() local
31 deUint8* buffer = malloc(sizeof(deUint8) * (size_t)thread->bufferSize); in cpyStream()
39 readResult = deInStream_read(thread->input, buffer, thread->bufferSize, &read); in cpyStream()
44 deOutStream_write(thread->output, buffer, read - written, &wrote); in cpyStream()
56 deOutStream_flush(thread->output); in cpyStream()
62 deStreamCpyThread* thread = malloc(sizeof(deStreamCpyThread)); in deStreamCpyThread_create() local
64 DE_ASSERT(thread); in deStreamCpyThread_create()
68 thread->input = input; in deStreamCpyThread_create()
69 thread->output = output; in deStreamCpyThread_create()
70 thread->bufferSize = bufferSize; in deStreamCpyThread_create()
71 thread->thread = deThread_create(cpyStream, thread, DE_NULL); in deStreamCpyThread_create()
73 return thread; in deStreamCpyThread_create()
76 void deStreamCpyThread_destroy (deStreamCpyThread* thread) in deStreamCpyThread_destroy() argument
78 deThread_destroy(thread->thread); in deStreamCpyThread_destroy()
80 free(thread); in deStreamCpyThread_destroy()
83 void deStreamCpyThread_join (deStreamCpyThread* thread) in deStreamCpyThread_join() argument
85 deThread_join(thread->thread); in deStreamCpyThread_join()