---

FastmsgLink.h

Go to the documentation of this file.

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

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

class FastmsgLink: public MPS::Connection {
private:
  ref<Mailbox> me;
  ref<Mailbox> other;
  int corrId;

public:
  FastmsgLink(string const &serverName, MPS::Address const &a);

  // Connection methods.
  virtual MPS::OutputStream *getOutputStream();
  virtual MPS::InputStream *getInputStream();
  virtual void releaseOutputStream(MPS::OutputStream *stream);
  virtual void releaseInputStream(MPS::InputStream *stream);
};

#endif

---