1 /*------------------------------------------------------------------------- 2 * drawElements Stream Library 3 * --------------------------- 4 * 5 * Copyright 2014 The Android Open Source Project 6 * 7 * Licensed under the Apache License, Version 2.0 (the "License"); 8 * you may not use this file except in compliance with the License. 9 * You may obtain a copy of the License at 10 * 11 * http://www.apache.org/licenses/LICENSE-2.0 12 * 13 * Unless required by applicable law or agreed to in writing, software 14 * distributed under the License is distributed on an "AS IS" BASIS, 15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 16 * See the License for the specific language governing permissions and 17 * limitations under the License. 18 * 19 *//*! 20 * \file 21 * \brief Stream copying thread 22 *//*--------------------------------------------------------------------*/ 23 #include "deStreamCpyThread.h" 24 25 #include <stdio.h> 26 #include <stdlib.h> 27 28 void cpyStream (void* arg) 29 { 30 deStreamCpyThread* thread = (deStreamCpyThread*)arg; 31 deUint8* buffer = malloc(sizeof(deUint8) * (size_t)thread->bufferSize); 32 33 for(;;) 34 { 35 deInt32 read = 0; 36 deInt32 written = 0; 37 deStreamResult readResult = DE_STREAMRESULT_ERROR; 38 39 readResult = deInStream_read(thread->input, buffer, thread->bufferSize, &read); 40 DE_ASSERT(readResult != DE_STREAMRESULT_ERROR); 41 while (written < read) 42 { 43 deInt32 wrote = 0; 44 deOutStream_write(thread->output, buffer, read - written, &wrote); 45 46 /* \todo [mika] Handle errors */ 47 written += wrote; 48 } 49 50 if (readResult == DE_STREAMRESULT_END_OF_STREAM) 51 { 52 break; 53 } 54 } 55 56 deOutStream_flush(thread->output); 57 free(buffer); 58 } 59 60 deStreamCpyThread* deStreamCpyThread_create (deInStream* input, deOutStream* output, deInt32 bufferSize) 61 { 62 deStreamCpyThread* thread = malloc(sizeof(deStreamCpyThread)); 63 64 DE_ASSERT(thread); 65 DE_ASSERT(input); 66 DE_ASSERT(output); 67 68 thread->input = input; 69 thread->output = output; 70 thread->bufferSize = bufferSize; 71 thread->thread = deThread_create(cpyStream, thread, DE_NULL); 72 73 return thread; 74 } 75 76 void deStreamCpyThread_destroy (deStreamCpyThread* thread) 77 { 78 deThread_destroy(thread->thread); 79 80 free(thread); 81 } 82 83 void deStreamCpyThread_join (deStreamCpyThread* thread) 84 { 85 deThread_join(thread->thread); 86 } 87
