lmsg/Socket.hh

/* -*- mode: c++; c-basic-offset: 4; -*- */
#ifndef LMSG_SOCKET_HH
#define LMSG_SOCKET_HH
#include "lmsg/MsgTypes.hh"
#include "lmsg/MsgAddr.hh"

namespace lmsg {
  class Buffer;
  class BufferPool;
  class SocketPool;

  class Socket {
  public:

    typedef struct sockaddr_in   ipsock_t;

    Socket(void);

    virtual ~Socket(void);

    MsgAddr getAddr(void) const;

    int getDebug(void) const;

    MsgAddr getPartner(void) const;

    int getRecvBuf(void) const;

    int getSendBuf(void) const;

    bool isConnected(void) const;

    bool isOpen(void) const;

    virtual error_type async(bool enable=true);

    virtual error_type bind(const MsgAddr* addr);

    virtual error_type connect(const MsgAddr& addr);

    virtual error_type disconnect(void);

    virtual error_type read(char* data, size_type len);

    virtual error_type receive(Buffer** Data);

    virtual error_type receive(Buffer* Data);

    virtual error_type send(Buffer* b);

    virtual error_type send(const MsgAddr& to, Buffer* b);

    error_type wait(wtime_type maxtime) const;

    static error_type waitAny(wtime_type maxtime, int N, const Socket* list[]);

    void setDebug(int level);

    void setPool(BufferPool* pool);

    void setPool(SocketPool* pool);

    error_type setRecvBuf(int nBytes);

    error_type setSendBuf(int nBytes);

    void Return(void);

  protected:
    MsgAddr     myAddr;
    MsgAddr     mPartner;
    BufferPool* mBPool;
    bool        mConnected;
    int         mSocket;

  private:
    SocketPool* mSPool;
    int         mDebug;
  };
} // namespace lmsg

inline int
lmsg::Socket::getDebug(void) const {
    return mDebug;
}

inline bool
lmsg::Socket::isConnected(void) const {
    return mConnected;
}

inline bool
lmsg::Socket::isOpen(void) const {
    return mSocket>=0;
}

#endif // LMSG_SOCKET_HH

---