DCFsbostream.h

Go to the documentation of this file.

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

#ifndef DCFSBOSTREAM_H
#define DCFSBOSTREAM_H

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

#include "DCFutility.h"
#include "DCFencode.h"
#include "DCFmpacket.h"

#include "DCFsbostreamBase.h"

template < class Data_t >
class DCFsbostream : public DCFsbostreamBase 
{
   public:
      DCFsbostream( const string& = "_\0", ostream& = cout );
      virtual void close();
      virtual void final( Data_t& );
      DCFsbostream<Data_t>& operator << ( Data_t& );
      void descr( ostream& os = cout );
      virtual void outheader();

   public:
      DCFencode<Data_t> _enc;
};

template <class Data_t>
DCFsbostream<Data_t>::DCFsbostream( const string& descript, ostream& os ) 
  : DCFsbostreamBase( descript, os ) 
{
   _enctype = _enc.enctype();
   _encsizeb = _enc.encsizeb();
};

template <class Data_t>
void DCFsbostream<Data_t>:: close() 
{
   if ( isopen() ) {
      bytepack bp;
      (*_os) << bp( 0, _bplen_sizeb );
      (*_os) << bp( _finalstep, _bplen_n );
      (*_os) << endl;
   }
};

template <class Data_t>
void DCFsbostream<Data_t>:: final( Data_t& x ) 
{
   bool eob = ( x.mcycle() == x.mmax() );
   _lockfinalstep = true;
   while ( !eob ) {
      x.assign( 0.0 );
      x++;
      (*this) << x;
      eob = ( x.mcycle() == x.mmax() );
   }
};

template <class Data_t>
DCFsbostream<Data_t>& DCFsbostream<Data_t>::operator << ( Data_t& x ) 
{
   
   DCFmpacket<Data_t> mp(DCF_DEFAULT_MPACKET,
     _bplen_sizeb, _bplen_n, _enc);

   if ( !isopen() ) open();

   if ( isopen() ) {
      if ( _needheader ) outheader();
      int m = x.mcycle();
      bool eob = ( m == x.mmax() );
      if (eob) { 
         (*_os) << mp( x, char(m) ); 
      }
      while (m) { 
        (*_os) << mp(x,char(0x80|m));
        m--;
      }
      if ( !_lockfinalstep ) {
         _finalstep = x.mrastep() & ( ( 1 << _mmax ) - 1 );
      }
      if (eob) {
         close();
         _blocknum++;
         _needheader = true;
      }
   }
   return *this;
};

template <class Data_t>
void DCFsbostream<Data_t>::descr( ostream& os = cout ) 
{
   DCFsbostreamBase::descr(os);
   _enc.descr(os);
};

template <class Data_t>
void DCFsbostream<Data_t>::outheader() 
{
   DCFsbostreamBase::outheader();
   (*_os) << _enc;
};

// specialization DCFsbostream<DCF::generic>

//class DCF { public: typedef void generic; };

//template <>
//class DCFsbostream< DCF::generic > : public DCFsbostreamBase 
//{
//   public:
//      DCFsbostream( const string& = "_\0", ostream& = cout);
//      virtual void close();
//      virtual void final() {}
//      DCFsbostream<DCF::generic>& operator<<( DCFmpacketBase& );
//      void descr( ostream& os = cout );
//      virtual void outheader();
//
//   public:
//      DCFencode<DCF::generic> _enc;
//};

//template <>
//DCFsbostream< DCF::generic >::DCFsbostream( 
//  const string& descript,
//  ostream& os
//) 
//  : DCFsbostreamBase( descript, os ) 
//{
//   _enctype = _enc.enctype();
//   _encsizeb = _enc.encsizeb();
//}

//template <>
//void DCFsbostream< DCF::generic >:: close() 
//{
//   if (isopen()) {
//      bytepack bp;
//      (*_os) << bp( 0, _bplen_sizeb );
//      (*_os) << bp( _finalstep, _bplen_n );
//      (*_os) << endl;
//   }
//}

//template <>
//DCFsbostream< DCF::generic >& 
//  DCFsbostream< DCF::generic >::operator << ( DCFmpacketBase& mp ) 
//{
//   if ( isopen() ) {
//      if (_needheader) outheader();
//      (*_os) << mp;
//   }
//   return *this;
//}

//template <>
//void DCFsbostream< DCF::generic >::descr( ostream& os ) 
//{
//   DCFsbostreamBase::descr(os);
//   _enc.descr(os);
//}

//template <>
//void DCFsbostream< DCF::generic >::void outheader() 
//{
//   DCFsbostreamBase::outheader();
//   (*_os) << _enc;
//}

#endif

---