---

oscl_socket.h

Go to the documentation of this file.

// -*- c++ -*-
// = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = =

//                     O S C L _ S O C K E T

// = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = = =

#ifndef OSCL_SOCKET_H_INCLUDED
#define OSCL_SOCKET_H_INCLUDED

#ifndef OSCLCONFIG_IO_H_INCLUDED
#include "osclconfig_io.h"
#endif

#ifndef OSCL_SOCKET_TYPES_H_INCLUDED
#include "oscl_socket_types.h"
#endif

#ifndef OSCL_HEAPBASE_H_INCLUDED
#include "oscl_heapbase.h"
#endif

#ifndef OSCL_DEFALLOC_H_INCLUDED
#include "oscl_defalloc.h"
#endif

#ifndef OSCL_VECTOR_H_INCLUDED
#include "oscl_vector.h"
#endif

#ifndef OSCL_MEM_H_INCLUDED
#include "oscl_mem.h"
#endif

class OsclSocketServI;

class OsclSocketServ : public HeapBase
{
    public:
        OSCL_IMPORT_REF static OsclSocketServ *NewL(Oscl_DefAlloc &alloc);

        OSCL_IMPORT_REF ~OsclSocketServ();

        OSCL_IMPORT_REF int32 Connect(uint32 aMessageSlots = 8);

        OSCL_IMPORT_REF void Close(bool aCleanup = true);

    private:
        OsclSocketServ(Oscl_DefAlloc &alloc): iServ(NULL), iAlloc(alloc) {}

        OsclSocketServI *iServ;
        Oscl_DefAlloc &iAlloc;

        friend class OsclTCPSocket;
        friend class OsclUDPSocket;
        friend class OsclDNS;

};


class OsclUDPSocketI;

class OsclUDPSocket : public HeapBase
{
    public:
        OSCL_IMPORT_REF static OsclUDPSocket *NewL(Oscl_DefAlloc &alloc,
                OsclSocketServ& aServ,
                OsclSocketObserver *aObserver,
                uint32 aId);

        OSCL_IMPORT_REF ~OsclUDPSocket();

        OSCL_IMPORT_REF int32 Close();

        OSCL_IMPORT_REF int32 Bind(OsclNetworkAddress& aAddress);

        OSCL_IMPORT_REF int32 Join(OsclNetworkAddress& aAddress);

        OSCL_IMPORT_REF TPVSocketEvent BindAsync(OsclNetworkAddress& aAddress
                , int32 aTimeoutMsec = (-1));

        OSCL_IMPORT_REF void CancelBind();

        OSCL_IMPORT_REF uint8 *GetRecvData(int32 *aLength);

        OSCL_IMPORT_REF uint8 *GetSendData(int32 *aLength);

        OSCL_IMPORT_REF TPVSocketEvent SendTo(const uint8* aPtr, uint32 aLen,
                                              OsclNetworkAddress& aAddress,
                                              int32 aTimeoutMsec = -1);
        OSCL_IMPORT_REF void CancelSendTo();

        OSCL_IMPORT_REF TPVSocketEvent RecvFrom(uint8* aPtr, uint32 aMaxLen,
                                                OsclNetworkAddress& aAddress,
                                                int32 aTimeoutMsec = -1,
                                                uint32 aMultiRecvLimit = 0,
                                                Oscl_Vector<uint32, OsclMemAllocator>* aPacketLen = NULL,
                                                Oscl_Vector<OsclNetworkAddress, OsclMemAllocator>* aPacketSource = NULL);
        OSCL_IMPORT_REF void CancelRecvFrom();

        OSCL_IMPORT_REF int32 SetRecvBufferSize(uint32 size);

    private:
        OsclUDPSocket(Oscl_DefAlloc &alloc): iUDPSocket(NULL), iAlloc(alloc) {}
        OsclUDPSocketI *iUDPSocket;
        Oscl_DefAlloc &iAlloc;
};

class OsclTCPSocketI;

class OsclTCPSocket : public HeapBase
{
    public:
        OSCL_IMPORT_REF static OsclTCPSocket *NewL(Oscl_DefAlloc &alloc,
                OsclSocketServ& aServ,
                OsclSocketObserver *aObserver,
                uint32 aId);

        OSCL_IMPORT_REF ~OsclTCPSocket();


        OSCL_IMPORT_REF int32 Close();

        OSCL_IMPORT_REF int32 Bind(OsclNetworkAddress& aAddress);

        OSCL_IMPORT_REF TPVSocketEvent BindAsync(OsclNetworkAddress& aAddress
                , int32 aTimeoutMsec = (-1));

        OSCL_IMPORT_REF void CancelBind();

        OSCL_IMPORT_REF int32 Listen(int32 aQueueSize);

        OSCL_IMPORT_REF TPVSocketEvent ListenAsync(int32 aQueueSize, int32 aTimeoutMsec = (-1));

        OSCL_IMPORT_REF void CancelListen();

        OSCL_IMPORT_REF OsclTCPSocket *GetAcceptedSocketL(uint32 aId);

        OSCL_IMPORT_REF uint8 *GetRecvData(int32 *aLength);

        OSCL_IMPORT_REF uint8 *GetSendData(int32 *aLength);

        OSCL_IMPORT_REF TPVSocketEvent Connect(OsclNetworkAddress& aAddress,
                                               int32 aTimeoutMsec = -1);

        OSCL_IMPORT_REF void CancelConnect();

        OSCL_IMPORT_REF TPVSocketEvent Shutdown(TPVSocketShutdown aHow,
                                                int32 aTimeoutMsec = -1);

        OSCL_IMPORT_REF void CancelShutdown();

        OSCL_IMPORT_REF TPVSocketEvent Accept(int32 aTimeout = -1);

        OSCL_IMPORT_REF void CancelAccept();

        OSCL_IMPORT_REF TPVSocketEvent Send(const uint8* aPtr, uint32 aLen,
                                            int32 aTimeoutMsec = -1);

        OSCL_IMPORT_REF void CancelSend();

        OSCL_IMPORT_REF TPVSocketEvent Recv(uint8* aPtr, uint32 aMaxLen,
                                            int32 aTimeoutMsec = -1);

        OSCL_IMPORT_REF void CancelRecv();

    private:
        static OsclTCPSocket *NewL(Oscl_DefAlloc &alloc, OsclTCPSocketI* aSocket);

    private:
        OsclTCPSocket(Oscl_DefAlloc &alloc): iTCPSocket(NULL), iAlloc(alloc) {}
        OsclTCPSocketI *iTCPSocket;
        Oscl_DefAlloc &iAlloc;
};

#endif

---