otcpstream.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 __o_tcp_stream_hpp
#define __o_tcp_stream_hpp

#include <iostream>

#include <stdexcept>

#include <string>

#include "ostreambase.hpp"


namespace MynahSA { 
  class OTCPStream : public OStreamBase {
  public:
    OTCPStream(int s);
  
    OTCPStream(const OTCPStream& s);
  
    ~OTCPStream();
  
  
    virtual OStreamBase& operator<<(const char);
    virtual OStreamBase& operator<<(const unsigned char);
    
    virtual OStreamBase& operator<<(const short);
    virtual OStreamBase& operator<<(const unsigned short);
    
    virtual OStreamBase& operator<<(const bool);
    
    virtual OStreamBase& operator<<(const int);
    virtual OStreamBase& operator<<(const unsigned int);
    
    virtual OStreamBase& operator<<(const long long);
    virtual OStreamBase& operator<<(const unsigned long long);
    
    virtual OStreamBase& operator<<(const double);
    virtual OStreamBase& operator<<(const float);
    
    virtual OStreamBase& operator<<(const std::string& s);
      
    // using declaration to allow base method to be used.
    using OStreamBase::operator<<;
      
    void flush();
      
  private:
    int _sd;
    
    char* _buffer;
    
    unsigned int _buffPtr;
  
    int tcpWrite(const void* data, unsigned int size);
    
  };

};


#endif