---

FastmsgServer.h

Go to the documentation of this file.

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

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

class FastmsgServer: public MailboxRequestThread {
private:
  MPS::Server *server;

public:
  FastmsgServer(MPS::Server *s, Scheduler &sched)
    : MailboxRequestThread(sched),
      server(s)
  {}

  virtual void threadMain();
};

class FastmsgServerFactory: public ThreadFactory {
private:
  MPS::Server *server;

public:
  FastmsgServerFactory(MPS::Server *s)
    : server(s)
  {}

  virtual ref<Thread> createThread(Scheduler &sched) {
    return new FastmsgServer(server, sched);
  }
};

#endif

---