MCFsbifstream.h

Go to the documentation of this file.

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

#ifndef MCFSBIFSTREAM_H
#define MCFSBIFSTREAM_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 "MCFsbistream.h"

template < class Rtmra_t >
class MCFsbifstream : public MCFsbistream<Rtmra_t> {
   public:
      MCFsbifstream( const string& = "_\0" );
      ~MCFsbifstream();
      void filenamebase( const string& );
      bool isopen();
      void open();
      void close();
      void initmfilepos();
      void findmpacket( MCFmpBase&,  const char mcode, const int n );
   private:
      string _filenamebase;
      string _filenamesb;
      int* _mfilepos;
};

template < class Rtmra_t >
MCFsbifstream<Rtmra_t>::MCFsbifstream( const string& filenamebase ) 
  : MCFsbistream<Rtmra_t>( *( new ifstream ) ) 
{
    _filenamebase = filenamebase;
    _mfilepos = new int[256];
};

template < class Rtmra_t >
MCFsbifstream<Rtmra_t>::~MCFsbifstream() 
{
   if ( isopen() ) close();
   if ( _mfilepos != 0 ) { delete [] _mfilepos; _mfilepos = 0; }
};

template < class Rtmra_t >
void MCFsbifstream<Rtmra_t>::filenamebase( const string& filenamebase ) 
{
    _filenamebase = filenamebase;
};

template < class Rtmra_t >
bool MCFsbifstream<Rtmra_t>::isopen() 
{ 
   return (*static_cast<ifstream*>(_is)).is_open(); 
}

template < class Rtmra_t >
void MCFsbifstream<Rtmra_t>::open() 
{
   if ( isopen() ) close();
   mcfsbfilename( _sbn, _filenamebase, _filenamesb );
cout << "attempting open " << _filenamesb << endl;
   (*static_cast<ifstream*>(_is)).open( _filenamesb.c_str() );
cout << "attempt open " << _filenamesb << endl;
   if ( !(static_cast<ifstream*>(_is)->good()) ) { 
      _openfail = true; 
   } else {
      _openfail = false;
      MCFsbistream<Rtmra_t>::open();
      initmfilepos();
//#ifdef STORM_DEBUG
      report();
//#endif
   }
};

template < class Rtmra_t >
void MCFsbifstream<Rtmra_t>::close()
{ 
   (*static_cast<ifstream*>(_is)).close(); 
}

template < class Rtmra_t >
void MCFsbifstream<Rtmra_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 Rtmra_t >
void MCFsbifstream<Rtmra_t>::findmpacket( 
  MCFmpBase& mp, const char mcode, const int n
) 
{
   bool found = false;
   bool missing = false;
   bool eof = false;
   int nextfilepos;
   bytepack bp;

#ifdef STORM_DEBUG
   cout << "MCFsbifstream.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 << "MCFsbifstream.findmpacket(): mp.mcode() mp.empty() "
           << int( (unsigned char)(mp.mcode()) ) << ' ' << mp.empty() << '\n';
#endif
//      if ( mp.empty() ) { 
      if ( mp.null() ) { 
         (*_is) >> bp( 0, 4 ); 
         (*_is) >> bp( 0, 4 );
         (*_is) >> bp( 0, _bplen_n ); _finalstep = bp;
#ifdef STORM_DEBUG
         cout << "FINALSTEP " << _finalstep << '\n';
#endif
         eof = true; 
            missing=true;       // TEST
            mp.set( mcode, n ); // TEST
            mp.clear();         // TEST
      }
      else {
         if ( ( mp.mcode() == mcode ) && ( mp.n() == n ) ) {
            found=true; 
         }
         if ( ( mp.mcode() == mcode ) && ( mp.n() > n ) ) {
            missing=true; 
//            mp.reset();       HACK ?
            mp.clear(); 
         }
      }
   }

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

#ifdef STORM_DEBUG
   cout << "MCFsbifstream.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

---