Search  

---

C:/temp/src/j2k/QNX4/Group5/Message.hpp

Go to the documentation of this file.

/***
   NAME
     message
   PURPOSE
     Message stuff.  All we include is a thread that takes messages.
     b_goudre -- Feb 10, 2000: Created.
***/

#ifndef __J2K__Train__Message_HPP__
#define __J2K__Train__Message_HPP__

#include "sthread.hh"

#define MESSAGE_BUFFER_SIZE 30 // grow as needed

class Message_thread : public Schedule_thread
{
private:
  char buffer_[MESSAGE_BUFFER_SIZE];

public:
  Message_thread();
  virtual void run();

  // Note: you shouldn't have to call this directly
  void send(const void* buffer, int length, void* reply, int rlength);

  // This, however, can be called directly...
  int stop();

  typedef int (Message_thread::*method_type)(...);

protected:
  struct message_table_entry {
    int (*marshal)(Message_thread*,
                   method_type,
                   int,
                   char*,
                   pid_type);
     method_type function;
  };

  virtual int message_filter(int m, char* data, pid_type pid) { return 0; }
  virtual const message_table_entry* find_entry(int msg) { return 0; };

  static int dispatch(Message_thread* self,
                      int msg,
                      char* buffer,
                      pid_type pid);
};

// All those do is define a static array in a function
#define DECLARE_MESSAGE_TABLE \
  static const message_table_entry message_table_[]; \
  virtual const message_table_entry* find_entry(int msg) { \
    return &message_table_[msg - 1]; \
  }

#define BEGIN_MESSAGE_TABLE(Cls) \
const Message_thread::message_table_entry Cls::message_table_[] = {

#define MESSAGE(Marshal, Function) \
 { Marshal, (Message_thread::method_type)Function }, //

#define END_MESSAGE_TABLE \
};

#endif

---