/home/docs/checkouts/readthedocs.org/user_builds/advanced-micro-devices-composable-kernel/checkouts/develop/include/rapidjson/istreamwrapper.h Source File

/home/docs/checkouts/readthedocs.org/user_builds/advanced-micro-devices-composable-kernel/checkouts/develop/include/rapidjson/istreamwrapper.h Source File#

Composable Kernel: /home/docs/checkouts/readthedocs.org/user_builds/advanced-micro-devices-composable-kernel/checkouts/develop/include/rapidjson/istreamwrapper.h Source File

Go to the documentation of this file.

 // Tencent is pleased to support the open source community by making RapidJSON available.
 //
 // Copyright (C) 2015 THL A29 Limited, a Tencent company, and Milo Yip.
 //
 // Licensed under the MIT License (the "License"); you may not use this file except
 // in compliance with the License. You may obtain a copy of the License at
 //
 // http://opensource.org/licenses/MIT
 //
 // Unless required by applicable law or agreed to in writing, software distributed
 // under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
 // CONDITIONS OF ANY KIND, either express or implied. See the License for the
 // specific language governing permissions and limitations under the License.
  
 #ifndef RAPIDJSON_ISTREAMWRAPPER_H_
 #define RAPIDJSON_ISTREAMWRAPPER_H_
  
 #include "stream.h"
 #include <iosfwd>
 #include <ios>
  
 #ifdef __clang__
 RAPIDJSON_DIAG_PUSH
 RAPIDJSON_DIAG_OFF(padded)
 #elif defined(_MSC_VER)
 RAPIDJSON_DIAG_PUSH
 RAPIDJSON_DIAG_OFF(4351) // new behavior: elements of array 'array' will be default initialized
 #endif
  
 RAPIDJSON_NAMESPACE_BEGIN
  
  
 template <typename StreamType>
 class BasicIStreamWrapper
 {
     public:
     typedef typename StreamType::char_type Ch;
  
  
     BasicIStreamWrapper(StreamType& stream)
         : stream_(stream),
           buffer_(peekBuffer_),
           bufferSize_(4),
           bufferLast_(0),
           current_(buffer_),
           readCount_(0),
           count_(0),
           eof_(false)
     {
         Read();
     }
  
  
     BasicIStreamWrapper(StreamType& stream, char* buffer, size_t bufferSize)
         : stream_(stream),
           buffer_(buffer),
           bufferSize_(bufferSize),
           bufferLast_(0),
           current_(buffer_),
           readCount_(0),
           count_(0),
           eof_(false)
     {
         RAPIDJSON_ASSERT(bufferSize >= 4);
         Read();
     }
  
     Ch Peek() const { return *current_; }
     Ch Take()
     {
         Ch c = *current_;
         Read();
         return c;
     }
     size_t Tell() const { return count_ + static_cast<size_t>(current_ - buffer_); }
  
     // Not implemented
     void Put(Ch) { RAPIDJSON_ASSERT(false); }
     void Flush() { RAPIDJSON_ASSERT(false); }
     Ch* PutBegin()
     {
         RAPIDJSON_ASSERT(false);
         return 0;
     }
     size_t PutEnd(Ch*)
     {
         RAPIDJSON_ASSERT(false);
         return 0;
     }
  
     // For encoding detection only.
     const Ch* Peek4() const { return (current_ + 4 - !eof_ <= bufferLast_) ? current_ : 0; }
  
     private:
     BasicIStreamWrapper();
     BasicIStreamWrapper(const BasicIStreamWrapper&);
     BasicIStreamWrapper& operator=(const BasicIStreamWrapper&);
  
     void Read()
     {
         if(current_ < bufferLast_)
             ++current_;
         else if(!eof_)
         {
             count_ += readCount_;
             readCount_  = bufferSize_;
             bufferLast_ = buffer_ + readCount_ - 1;
             current_    = buffer_;
  
             if(!stream_.read(buffer_, static_cast<std::streamsize>(bufferSize_)))
             {
                 readCount_                            = static_cast<size_t>(stream_.gcount());
                 *(bufferLast_ = buffer_ + readCount_) = '\0';
                 eof_                                  = true;
             }
         }
     }
  
     StreamType& stream_;
     Ch peekBuffer_[4], *buffer_;
     size_t bufferSize_;
     Ch* bufferLast_;
     Ch* current_;
     size_t readCount_;
     size_t count_; 
     bool eof_;
 };
  
 typedef BasicIStreamWrapper<std::istream> IStreamWrapper;
 typedef BasicIStreamWrapper<std::wistream> WIStreamWrapper;
  
 #if defined(__clang__) || defined(_MSC_VER)
 RAPIDJSON_DIAG_POP
 #endif
  
 RAPIDJSON_NAMESPACE_END
  
 #endif // RAPIDJSON_ISTREAMWRAPPER_H_