execserver/xsPosixFileReader.hpp

   1 #ifndef _XSPOSIXFILEREADER_HPP
   2 #define _XSPOSIXFILEREADER_HPP
   3 /*-------------------------------------------------------------------------
   4  * drawElements Quality Program Execution Server
   5  * ---------------------------------------------
   6  *
   7  * Copyright 2014 The Android Open Source Project
   8  *
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  *
  21  *//*!
  22  * \file
  23  * \brief File Reader.
  24  *//*--------------------------------------------------------------------*/
  25
  26 #include "xsDefs.hpp"
  27 #include "deFile.h"
  28 #include "deThread.hpp"
  29
  30 namespace xs
  31 {
  32 namespace posix
  33 {
  34
  35 class FileReader : public de::Thread
  36 {
  37 public:
  38                                                         FileReader                      (int blockSize, int numBlocks);
  39                                                         ~FileReader                     (void);
  40
  41         void                                    start                           (const char* filename);
  42         void                                    stop                            (void);
  43
  44         bool                                    isRunning                       (void) const                                    { return m_isRunning;                                   }
  45         int                                             read                            (deUint8* dst, int numBytes)    { return m_buf.tryRead(numBytes, dst);  }
  46
  47         void                                    run                                     (void);
  48
  49 private:
  50         deFile*                                 m_file;
  51         ThreadedByteBuffer              m_buf;
  52         bool                                    m_isRunning;
  53 };
  54
  55 } // posix
  56 } // xs
  57
  58 #endif // _XSPOSIXFILEREADER_HPP