MCFsbistream.h

Go to the documentation of this file.

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

#ifndef MCFSBISTREAM_H
#define MCFSBISTREAM_H

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

#include "MCFsbistreamBase.h"
#include "MCFmp.h"
#include "MCF_Code.h"

template <class Rtmra_t>
class MCFsbistream : public MCFsbistreamBase 
{
   public:
      typedef typename Rtmra_t::DataType Data_t;
      MCFsbistream( istream& is = cin );
      ~MCFsbistream() {}
      MCFsbistream<Rtmra_t>& operator>>( Rtmra_t& );
      MCFsbistream<Rtmra_t>& jump_read( int, Rtmra_t& );
};

template < class Rtmra_t >
MCFsbistream<Rtmra_t>::MCFsbistream( istream& is) 
  : MCFsbistreamBase( is ) 
{
   _datatype_code = DataType_Code<Data_t>::eval(); 
}

template < class Rtmra_t >
MCFsbistream<Rtmra_t>& MCFsbistream<Rtmra_t>::operator>>( Rtmra_t& x ) 
{

   MCFmp<Rtmra_t> mp( _bplen_mpsizeb, _bplen_coef, _bplen_n, _bplen_a );

   int m = x.imcycle();
   bool bob = ( m == x.mmax() );

#ifdef STORM_DEBUG
   cout << "MCFsbistream<Rtmra_t>::operator>>(): m bob "
        << m << ' ' << bob << '\n';
#endif

   if (bob) {
      _sbn = ( ( x.mrastep() + 1 ) >> x.mmax() );
      open();
      if ( ! _openfail ) {
         mp.set( _bplen_mpsizeb, _bplen_coef, _bplen_n, _bplen_a );
         findmpacket( mp, char(m), 0 );
         mp.replace(x);
      }
   }

   if ( ! _openfail ) {
      int n;
      while (m) {
         n = ( ( x.mrastep() + 1 ) & ( ( 1 << x.mmax() ) - 1 ) ) >> m;
         findmpacket( mp, char( 0x80 | m ), n );
         mp.replace(x);
         m--;
      }
   }
   return *this;
};

template < class Rtmra_t >
MCFsbistream<Rtmra_t>& MCFsbistream<Rtmra_t>::jump_read( 
  int mrastep, Rtmra_t& x 
) 
{
   x.mrastep( mrastep-1 );

   MCFmp<Rtmra_t> mp( _bplen_mpsizeb, _bplen_coef, _bplen_n, _bplen_a );

   int m = x.imcycle();
   bool bob = ( m == x.mmax() );

#ifdef STORM_DEBUG
   cout << "MCFsbistream<Rtmra_t>::jump_read(): m bob "
        << m << ' ' << bob << '\n';
#endif

   _sbn = ( ( x.mrastep() + 1 ) >> x.mmax() );
   open();

   if ( ! _openfail ) {
      mp.set( _bplen_mpsizeb, _bplen_coef, _bplen_n, _bplen_a );
      findmpacket( mp, char( x.mmax() ), 0 );
      mp.replace(x);

      int n;
      for( int m = x.mmax(); m > 0; --m ) {
         n = ( ( x.mrastep() + 1 ) & ( ( 1 << x.mmax() ) - 1 ) ) >> m;
         findmpacket( mp, char( 0x80 | m ), n );
         mp.replace(x);
      }
   }

   return *this;
};

#endif

---