Search  

---

C:/temp/src/j2k/QNX4/MsgTestBGE.cpp

Go to the documentation of this file.

#include "message.hh"

struct int_int_t
{
    int a, b;
};

struct int_int_m
{
    int msg;
    int_int_t data;
};

int unmarshal_int_int_rint( Message_thread*,
                            Message_thread::method_type,
                            int,
                            char*,
                            Message_thread::pid_type);

struct charp_t
{
    char* p;
};

struct charp_m
{
    int msg;
    charp_t data;
};

int unmarshal_charp_rnone( Message_thread*,
                           Message_thread::method_type,
                           int,
                           char*,
                           Message_thread::pid_type);

class Message_test : public Message_thread
{
public:
    int add(int a, int b);
    int subtract(int a, int b);
    void print(const char* s);
    
    enum message_t
    {
        END,
        ADD,                    // int a, b
        SUBTRACT,               // int a, b
        PRINT                   // char* message
    };
protected:
    DECLARE_MESSAGE_TABLE;

};

class Message_test_proxy 
{
    Message_test mt;
public:
    Message_test_proxy()
    {
        mt.start();
    }
    ~Message_test_proxy()
    {
        const int terminate = Message_test::END;
        mt.send(&terminate, sizeof(terminate), NULL, 0);
    }
    int add(int a, int b)
    {
        int_int_m buffer;
        int reply;
   buffer.msg = Message_test::ADD;
        buffer.data.a = a;
        buffer.data.b = b;
        mt.send(&buffer, sizeof(buffer), &reply, sizeof(reply));
        return reply;
    }
    int subtract(int a, int b)
    {
        int_int_m buffer;
        int reply;
   buffer.msg = Message_test::SUBTRACT;
        buffer.data.a = a;
        buffer.data.b = b;
        mt.send(&buffer, sizeof(buffer), &reply, sizeof(reply));
        return reply;
    }
    void print(char* p)
    {
        charp_m buffer;
        int reply;
   buffer.msg = Message_test::PRINT;
        buffer.data.p = p;
        mt.send(&buffer, sizeof(buffer), &reply, sizeof(reply));
    }
};

---