---

FastmsgMessage.h

Go to the documentation of this file.

/* -*- C++ -*- */
#ifndef MPS_Transport_Fastmsg_Message_H
#define MPS_Transport_Fastmsg_Message_H

#include <mps/mps.h>
#include <fastmsg/Mailbox.h>

class FastmsgOutputStream: public MPS::OutputStream {
private:
  ref<Mailbox> me;
  ref<Mailbox> other;
  int corrId;

protected:
  virtual string referenceTransport() const { return "fastmsg"; }

public:
  FastmsgOutputStream(ref<Mailbox> const &_me,
                      ref<Mailbox> const &_other,
                      int _corrId)
    : me(_me),
      other(_other),
      corrId(_corrId)
  {}

  virtual void flush() {
    static int messageType = FastmsgRoot::getMessageType("MPS2");

    int len = getLength();
    ref<Message> msg = Message::create(me, other, messageType,
                                       corrId, len);
    memcpy(msg->getBody(), getBody(), len);
    msg->deliver();
    MPS::OutputStream::flush();
  }
};

class FastmsgInputStream: public MPS::InputStream {
private:
  ref<Message> msg;
  int pos;
  int len;

public:
  FastmsgInputStream(ref<Message> const &_msg)
    : msg(_msg),
      pos(0),
      len(_msg->getLength())
  {}

  virtual int read() {
    if (pos >= len) {
      throw MPS::MPSConnectionClosedException("reading from a fastmsg message");
    }

    return ((char *) msg->getBody())[pos++];
  }
};

#endif

---