---

socketc.h

Go to the documentation of this file.

/*
Copyright (C) 1999  Carsten Winkelholz

Address:  FGAN Forschungsgesellschaft f�r Angewandte Naturwissenschaften e. V.
      Neuenahrer Str. 20
      D - 53343 Wachtberg
      
Email:    winkelholz@fgan.de

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.

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., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
*/


#ifndef SOCKETC_H
#define SOCKETC_H

#include "oaw/misc/sockmisc.h"
#include "oaw/misc/stringc.h"
#include "oaw/misc/arrayc.h"

#include "../oawconfig.h"

OAW_BEGIN_NAMESPACE

enum SocketType{
  cStream,
  cDatagramm
};


#define ESOCKETC_BIND_FAILED      0
#define ESOCKETC_LISTEN_FAILED      1
#define ESOCKETC_CREATE_SOCKET_FAILED          2
#define ESOCKETC_ACCEPT_FAILED      3
#define ESOCKETC_CONNECT_FAILED      4
#define ESOCKETC_SETSOCKOPT_FAILED    5
#define ESOCKETC_LOST_CONNECTION    6
#define ESOCKETC_ADDRESS_NOT_EXISTS    7
#define ESOCKETC_SELECT_FAILED      8
#define ESOCKETC_TIMEOUT          9
#define ESOCKETC_DGRAM_SEND_ERROR    10
#define ESOCKETC_DGRAM_READ_ERROR    11
#define ESOCKETC_CLOSE_FAILED    12


class OAW_DLLMAPPING SockAddressC{
public:
  SockAddressC();
  SockAddressC(const StringC& netaddress,const  StringC& endpoint);
  SockAddressC(const SockAddressC&);
  int Set(const StringC& netaddress,const StringC& endpoint);
  int SetNetAddress(const StringC& netaddress);
  void SetEndpoint(const StringC& endpoint);
  SockAddressC& operator = (const SockAddressC&);  
  const int& GetStatus(){return m_status;}
  int SetLocalHost();
  StringC GetIP();
public:
  sockaddr_in m_address;
  int m_status;
};


class OAW_DLLMAPPING SocketC
{
public:
  SocketC();
  
  SocketC(SocketType);
  SocketC(const SocketC&);
  ~SocketC();
  SocketC& operator = (const SocketC&);  
  
  void Bind(const char* endpoint,const char* localIP=0);
  void Listen(int);
  void Connect(SockAddressC& des);
  SocketC Accept(SockAddressC&);

 
  
  void SendLongTo(const long&, const SockAddressC& des);
  void RecvLongFrom(long&, SockAddressC& addr);
  //void SendByteArrayTo(ByteArrayC&, const SockAddressC& des);
  //void RecvByteArrayFrom(ByteArrayC&, SockAddressC& addr, const long&);
  
  long SendTo(const char* data, int len, const SockAddressC& des);
  long RecvFrom(char* data, int buflen, SockAddressC& addr);
  long RecvData(char* data, int buflen);
  
  void Send(char* data, int len);
  void SendString(const StringC&);
  void SendByteArray(ByteArrayC&);
  void SendLong(const long&); 
  
  void Recv(char* data, int buflen);
  void RecvString(StringC&);
  void RecvByteArray(ByteArrayC&);
  void RecvLong(long&);
  
  long GetMaxMsgSize();
  void EnableBroadcast(int);
  void EnableReuseAddress(int);
  void EnableReusePort(int);
  
  SOCKET GetHandle(){return m_socket;}
  
  short ReadyToRead();
  

private:
  SocketC(SOCKET);
  
protected:    
  SOCKET m_socket;
  short m_port;
  SocketType m_type;
  
  sockaddr_in m_localAddress;
  sockaddr_in m_destinationAddress;
};



class OAW_DLLMAPPING SocketFactoryC{
public:
  SocketFactoryC();
  ~SocketFactoryC();
  SOCKET CreateSocket(SocketType type);
  void AddHandleFromAccept(SOCKET);
  void IncHandleCounter(SOCKET);
  void DecHandleCounter(SOCKET);
protected:
  ArrayC<SOCKET> m_handleList;
  ArrayC<int> m_handleCounter;
};


extern SocketFactoryC s_socketFactory;

class ESocketC{
public:
  ESocketC(const long& l){m_errorCode = l;}
  ESocketC(const StringC& s, const long& l){m_errorString = s;m_errorCode = l;}
public:
  StringC m_errorString;
  long m_errorCode;
};




class OAW_DLLMAPPING SocketSetC{
public:
  SocketSetC();
  void Add(SocketC&);
  void Remove(SocketC&);
  int SelectRead(const long&,const long&,ArrayC<long>&);
protected:
  ArrayC<SOCKET> m_socketList;
  fd_set m_fds;
  SOCKET m_max;
};




OAW_END_NAMESPACE

#endif

---