mtserver.h

Go to the documentation of this file.

#ifndef ABA_MTSERVER_H
#define ABA_MTSERVER_H

#include "abacus/abacusroot.h"
#include "abacus/message.h"

#include <ace/Task.h>
#include <ace/SOCK_Acceptor.h>

class ABA_MASTER;


  class  ABA_MTSERVER :  public ACE_Task<ACE_MT_SYNCH>, public ABA_ABACUSROOT  {
    public/

      ABA_MTSERVER(ABA_MASTER *master, int port, int nThreads);

      ~ABA_MTSERVER();

      int open (void*);
      int close (u_long);
 
      int svc();

    protected:
      ABA_MASTER *master_;
      int         port_;
      int         nThreads_;
      ACE_SOCK_Acceptor acceptor_;

      virtual bool svcMessage(ABA_MESSAGE& msg) = 0;
  };


inline int ABA_MTSERVER::close(u_long) { return 0; }

#endif  // ABA_MTSERVER_H

---