lmsg/TransportMsg.hh

/* -*- mode: c++; c-basic-offset: 4; -*- */
#ifndef LMSG_TRANSPORTMSG_HH
#define LMSG_TRANSPORTMSG_HH

#include "lmsg/MsgTypes.hh"

namespace lmsg {
  class Buffer;
  class BufferPool;
  class Message;
  class MsgAddr;
  class MsgHeader;
  class Socket;
  class SocketPool;

  class TransportMsg {
  public:

    enum openflags {o_none, o_client=1, o_async=2};

    TransportMsg(void);

    ~TransportMsg(void);

    MsgAddr getAddr(void) const;

    MsgAddr getReplyAddr(void) const;

    bool    isConnected(void) const;

    bool    isOpen(void) const;

    index_type getDebug(void) const;

    error_type open(long flags, const MsgAddr* addr=0);

    void    close(void);

    error_type connect(const MsgAddr& addr);

    error_type disconnect(void);

    error_type receive(MsgHeader& from, char* b, size_type maxlen, 
                    wtime_type timeout=-1.0);

    error_type receive(MsgHeader& from, Message& msg, wtime_type timeout=-1.0);

    error_type receive(Buffer** Data, wtime_type timeout=-1.0);

    error_type send(const MsgHeader& to, const char* b);

    error_type send(const MsgHeader& to, const Message& b);

    error_type waitMsg(wtime_type Timeout) const;

    static error_type waitAny(wtime_type Timeout, int N, const TransportMsg* list[]);

    void Purge(void);

    void setSocketPool(SocketPool* pool);

    void setBufferPool(BufferPool* pool);

    void setDebug(index_type level);

    void setReplyAddr(const MsgAddr& ad);

  private:
    error_type send(Buffer* b);

  private:
    SocketPool* mSockPool;
    Socket*     mSocket;
    BufferPool* mBuffPool;
    index_type     mDebug;
    MsgAddr     mReplyAddr;
  };

} // namespace lmsg

//======================================  Inline methods
inline bool
lmsg::TransportMsg::isOpen(void) const {
    return (mSocket != 0);
}

inline lmsg::index_type
lmsg::TransportMsg::getDebug(void) const {
    return mDebug;
}

inline lmsg::MsgAddr
lmsg::TransportMsg::getReplyAddr(void) const {
    return mReplyAddr;
}

#endif // LMSG_SOCKET_HH

---