XPSocketClass.h

/* START_LICENSE_HEADER

Copyright (C) 2000 Martin Piper, original design and program code
Copyright (C) 2001 Replica Software

This program file is copyright (C) Replica Software and can only be used under license.
For more information visit: http://www.replicanet.com/
Or email: info@replicanet.com

END_LICENSE_HEADER */
#include "RNPlatform/Inc/MemoryTracking.h"
/* A class implementation of the C style XPSocket library */
#ifndef __XPSOCKETCLASS_H__
#define __XPSOCKETCLASS_H__

#include "XPSocket.h"

namespace RNReplicaNet
{

class XPSocket
{
public:
friend class XPSocketUrgent;
//friend class XPStream;
    XPSocket();

    virtual ~XPSocket();

    static int GetLastError(void);

    virtual int Create(void);

    int Connect(const XPAddress &addr);

    int Send(const char *data);

    int Send(const char *data,const int len);

    int Recv(char *const data,const int maxlen);

    int Close(void);

    int Listen(const int port = XPSOCK_PORT_ANY);

    int Listen(const XPAddress &addr);

    XPSocket *Accept(void);

    int SetSendBuffer(const int size);

    int SetRecvBuffer(const int size);

    int GetAddress(XPAddress *const addr);

    int GetPeerAddress(XPAddress *const addr);

    static int GetMaxPacketSize(void)   {return XPSOCK_MAXPACKETSIZE;};

    int MutateSocket(XPSocket *socket);

    bool IsAlive(void);

    t_XPSocket *GetSocketPointer(void);

private:

    t_XPSocket *mSocket;            
    enum SocketState
    {
        TypeUndefined = 0,
        TypeTCP = 1,
        TypeUDP = 2
    };                              
    SocketState mSocketState;       
};

/* A macro to make our life easier */
#define SOCKET_ASSERT_TYPE(x) \
    if (mSocketState == (x))    \
    {   \
        assert(0 && "XPSOCK_ILLEGALOPERATION"); \
        asocket_lasterror = XPSOCK_ILLEGALOPERATION;    \
        return XPSOCK_EERROR;   \
    }   \
    if ((x) == TypeUDP) \
    {   \
        mSocketState = TypeTCP; \
    }   \
    else    \
    {   \
        mSocketState = TypeUDP; \
    }

#define SOCKET_ASSERT_TYPEP(x) \
    if (mSocketState == (x))    \
    {   \
        assert(0 && "XPSOCK_ILLEGALOPERATION"); \
        asocket_lasterror = XPSOCK_ILLEGALOPERATION;    \
        return pcXPSOCK_EERROR; \
    }   \
    if ((x) == TypeUDP) \
    {   \
        mSocketState = TypeTCP; \
    }   \
    else    \
    {   \
        mSocketState = TypeUDP; \
    }

#define pcXPSOCK_EERROR  ((RNReplicaNet::XPSocket *) XPSOCK_EERROR) 
} // namespace RNXPSockets

#endif