Bufferfstream.h

Go to the documentation of this file.

// Bufferfstream.h
//////////////////////////////////////////////////////////////////////
//          (c) Copyright 2002 Brown Deer Technology, LLC.
//                        All rights reserved.
//////////////////////////////////////////////////////////////////////

#ifndef BUFFERFSTREAM_H
#define BUFFERFSTREAM_H

#ifdef USE_STD
#include <iostream>
#include <fstream>
#include <string>
using namespace std;
#else
#include <iostream.h>
#include <fstream.h>
#include <string.h>
#endif

#include "utility.h"
#include "BufferBase.h"
#include "BufferfstreamManager.h"

class Bufferfstream : public BufferBase
{
   public:

      string isa() const { return "Bufferfstream"; }

      Bufferfstream();

      Bufferfstream( const Bufferfstream& rhs );

      Bufferfstream( BufferBase& buf );

      ~Bufferfstream();

      Bufferfstream& operator = ( Bufferfstream& rhs );

      void seekp( int pos, const BufferBase::SeekDir dir = beg );
      void seekg( int pos, const BufferBase::SeekDir dir = beg );

      void put( char c );
      void get( char& c );
      char get();

      void put( int i, char c );
      void get( int i, char& c );
      char get( int i );

      void erase();

   protected:
      int _handle;
      string _filename;
      fstream* _fs;

};

inline
Bufferfstream::Bufferfstream()
  : BufferBase(), _fs( new fstream )
{
   _handle = BufferfstreamManager::Instance()->get_handle();
   char ctmp[2*2+1];
   inttohex( _handle, ctmp, 2 );
   _filename = "~bfs";
   _filename += ctmp;
   _fs->open( _filename.c_str(), ios::out );
   _fs->close();
//   _fs->open( _filename.c_str(), ios::in | ios::app );
   _fs->open( _filename.c_str(), ios::in | ios::out );
}

inline
Bufferfstream::Bufferfstream( const Bufferfstream& rhs )
  : BufferBase(rhs),  _fs( new fstream )
{
   _handle = BufferfstreamManager::Instance()->get_handle();
   char ctmp[2*2+1];
   inttohex( _handle, ctmp, 2 );
   _filename = "~bfs";
   _filename += ctmp;
   _fs->open( _filename.c_str(), ios::out );
   _fs->close();
//   _fs->open( _filename.c_str(), ios::in | ios::app );
   _fs->open( _filename.c_str(), ios::in | ios::out );
   rhs._fs->seekg(0);
   for( int i = 0; i < rhs._size; ++i ) _fs->put( rhs._fs->get() );
}

inline
Bufferfstream::Bufferfstream( BufferBase& buf )
  : BufferBase(buf), _fs( new fstream )
{
   _handle = BufferfstreamManager::Instance()->get_handle();
   char ctmp[2*2+1];
   inttohex( _handle, ctmp, 2 );
   _filename = "~bfs";
   _filename += ctmp;
   _fs->open( _filename.c_str(), ios::out );
   _fs->close();
//   _fs->open( _filename.c_str(), ios::in | ios::app );
   _fs->open( _filename.c_str(), ios::in | ios::out );
   erase();
   (*this) << buf;
}

inline
Bufferfstream::~Bufferfstream() 
{
   _fs->close();
   if ( _fs != 0 ) { delete _fs; _fs = 0; }
   BufferfstreamManager::free_handle(_handle);
}

inline
Bufferfstream& Bufferfstream::operator = ( Bufferfstream& rhs )
{
   if ( this != &rhs ) {
      BufferBase::operator=(rhs);
      erase();
      _fs->seekp(0);
      _fs->seekg(0);
      (*this) << rhs; 
   }
   return *this;
}

inline
void Bufferfstream::seekp( int pos, BufferBase::SeekDir dir ) 
{
   BufferBase::seekp( pos, dir );
   if ( !fail() ) _fs->seekp(_putpos);
}

inline
void Bufferfstream::seekg( int pos, BufferBase::SeekDir dir ) 
{ 
   BufferBase::seekg( pos, dir );
   if ( !fail() ) _fs->seekg(_getpos);
}

inline 
void Bufferfstream::put( char c ) 
{
//   cout << "Bufferfstream::puting " << _putpos << ' ' << int((unsigned char)c) << endl;
   seekp(_putpos);
   if ( !fail() ) { 
      _fs->put(c);
      BufferBase::put(c);
   }
   else setstate( BufferBase::failbit );
}

inline
void Bufferfstream::get( char& c ) 
{ 
   seekg(_getpos);
   if ( !fail() ) {
      _fs->get(c);
      BufferBase::get(c);
//      cout << "Bufferfstream::got " << _fs->tellg()-1 << ' ' << int((unsigned char)c) << endl;
   }
   else setstate( BufferBase::failbit );
}

inline char Bufferfstream::get() { return BufferBase::get(); }

inline void Bufferfstream::put(int i, char c ) { BufferBase::put(i,c); }
inline void Bufferfstream::get(int i, char& c) { BufferBase::get(i,c); }
inline char Bufferfstream::get(int i) { return BufferBase::get(i); }

inline
void Bufferfstream::erase() 
{ 
   BufferBase::erase();
   _fs->close();
   _fs->open( _filename.c_str(), ios::out );
   _fs->close();
//   _fs->open( _filename.c_str(), ios::in | ios::app );
   _fs->open( _filename.c_str(), ios::in | ios::out );
}

#endif

---