DCFsbifstream.h

Go to the documentation of this file.

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

#ifndef DCFSBIFSTREAM_H
#define DCFSBIFSTREAM_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 "DCFsbistream.h"

template < class Data_t >
class DCFsbifstream : public DCFsbistream<Data_t> {
   public:
      DCFsbifstream( const string& = "_\0" );
      ~DCFsbifstream();
      void filenamebase( const string& );
      bool isopen();
      void open();
      void close();
      void initmfilepos();
      void findmpacket( DCFmpacketBase&,  const char, const int );
   private:
      int _lenfilenamebase;
      string _filenamebase;
      string _filenamesb;
      ifstream* _ifs;
      int* _mfilepos;
};

template < class Data_t >
DCFsbifstream<Data_t>::DCFsbifstream( const string& filenamebase ) 
  : DCFsbistream<Data_t>( *( _ifs = new ifstream ) ) 
{
    _lenfilenamebase = filenamebase.size();
    _filenamebase = filenamebase;
    _mfilepos = new int[256];
};

template < class Data_t >
DCFsbifstream<Data_t>::~DCFsbifstream() 
{
   (*_ifs).close();
   delete [] _mfilepos; _mfilepos = 0;
   delete _ifs; _ifs = 0;
};

template < class Data_t >
void DCFsbifstream<Data_t>::filenamebase( const string& filenamebase ) 
{
    _lenfilenamebase = filenamebase.size();
    _filenamebase = filenamebase;
};

template < class Data_t >
bool DCFsbifstream<Data_t>::isopen() { return (*_ifs).is_open(); }

template < class Data_t >
void DCFsbifstream<Data_t>::open() 
{
   if (isopen()) close();
   dcfsbfilename( _blocknum, _filenamebase, _filenamesb );
   (*_ifs).open( _filenamesb.c_str() );
   DCFsbistream<Data_t>::open();
   initmfilepos();
//#ifdef STORM_DEBUG
   descr();
//#endif
};

template < class Data_t >
void DCFsbifstream<Data_t>::close() { (*_ifs).close(); }

template < class Data_t >
void DCFsbifstream<Data_t>::initmfilepos() 
{
   for( int i = 0; i < 256; i++ ) { _mfilepos[i] = (*_is).tellg(); }
#ifdef STORM_DEBUG
   cout << " initial seek pos " << _mfilepos[0] << '\n';
#endif
};

template < class Data_t >
void DCFsbifstream<Data_t>::findmpacket(
  DCFmpacketBase& mp,
  const char mcode,
  const int n
) 
{
   bool found = false;
   bool missing = false;
   bool eof = false;
   int nextfilepos;
   bytepack bp;

#ifdef STORM_DEBUG
   cout << "DCFsbifstream.findmpacket(): SEARCHING FOR : mcode "
        << int( (unsigned char)(mcode) ) << '\n';
#endif

   mp.clear();
   (*_is).seekg( _mfilepos[ int( (unsigned char)(mcode) ) ], ios::beg );
   int i0 = (*_is).tellg();

   while ( (*_is).good() & !found & !missing & !eof ) {
      nextfilepos = (*_is).tellg();
      (*_is) >> mp; 
#ifdef STORM_DEBUG
      cout << "DCFsbifstream.findmpacket(): mp.mcode() mp.empty() "
           << int( (unsigned char)(mp.mcode()) ) << ' ' << mp.empty() << '\n';
#endif
      if ( mp.empty() ) { 
         (*_is) >> bp( 0, _bplen_n ); _finalstep = bp;
//       cout << "FINALSTEP " << _finalstep << '\n';
         eof = true; 
      }
      if ( ( mp.mcode() == mcode ) && ( mp.n() == n ) ) {
         found=true; 
      }
      if ( ( mp.mcode() == mcode ) && ( mp.n() > n ) ) {
         missing=true; 
         mp.reset(); 
      }
   }

   int i1=(*_is).tellg();
   if (found) {
      _mfilepos[ int( (unsigned char)(mcode) ) ] = (*_is).tellg();
   }
   else {
      _mfilepos[ int( (unsigned char)(mcode) ) ] = nextfilepos;
   }

#ifdef STORM_DEBUG
   cout << "DCFsbifstream.findmpacket(): mcode _result_ _mfilepos[mcode] "
        << int( (unsigned char)(mcode) );
   if (found)  cout << " FOUND ";
   if (missing) cout << " MISSING ";
   if (eof) cout << " EOF ";
   cout << _mfilepos[ int( (unsigned char)(mcode) ) ] << ' ' << n << '\n';
#endif
};

#endif

---