tcparchivestream.hpp

/************************************************************************************
 *    This file is part of the MynahSA streaming and archiving toolkit              *
 *    Copyright (C) 2006 Mynah-Software Ltd. All Rights Reserved.                   *
 *                                                                                  *
 *    This program is free software; you can redistribute it and/or modify          *
 *    it under the terms of the GNU General Public License, version 2               *
 *    as published by the Free Software Foundation.                                 *
 *                                                                                  *
 *    This program is distributed in the hope that it will be useful,               *
 *    but WITHOUT ANY WARRANTY; without even the implied warranty of                *
 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                 *
 *    GNU General Public License for more details.                                  *
 *                                                                                  *
 *    You should have received a copy of the GNU General Public License along       *
 *    with this program; if not, write to the Free Software Foundation, Inc.,       *
 *    51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.                   *
 *                                                                                  *
 ************************************************************************************/

#ifndef __tcp_archive_stream_hpp
#define __tcp_archive_stream_hpp

#include <mynahsa/iarchive.hpp>
#include <mynahsa/oarchive.hpp>
#include <mynahsa/itcpstream.hpp>
#include <mynahsa/otcpstream.hpp>
#include <mynahsa/archivestreambase.hpp>


#include <iostream>

namespace MynahSA { 

  typedef IArchive<ITCPStream> ITCPArchiveStream;
  
  typedef OArchive<OTCPStream> OTCPArchiveStream;
  
  class TCPArchiveStream : public ArchiveStreamBase, 
                           public ITCPArchiveStream, 
                           public OTCPArchiveStream {
  
  public:
  
    TCPArchiveStream(int sd);
  
    TCPArchiveStream(const TCPArchiveStream& s);
  
    ~TCPArchiveStream();
  
    bool is_open() const;
    
    void close();
    
    void registerConstructor(const std::string& name, 
                             const SHARED_PTR<Archive::ArchiveConstructor>& cons);
    
    void clearUPR();
    
    
  private:
    int _sd;
    
    ITCPStream is;
    OTCPStream os;
  
  };
};


#endif