Search  

---

C:/temp/src/j2k/QNX4/Fred/TRAIN.TXT

Go to the documentation of this file.

/* A bit like a LinkList class Comp352,
   so you can send in one shot a queue of task to be done
*/

#define bool  int

class Message { 
public:
    Message();
    ~Message();

    void AppendMessage( Message* msg ); // Append a msg
    void DeleteMessages();          // Delete a msg linklist

protected:
    Message* next;
};  

class TrainMessage : public Message {
public:
    TrainMessage();
    ~TrainMessage();

protected:
    TrainInfo*  new_train_info;
    int     request;
    int     nbRequests;
};

class TrainInfo : public Info {
public:
    TrainInfo();
    TrainInfo( int ID, char* name, ... );

    TrainInfo( TrainInfo&  info );
    ~TrainInfo();

protected:
    int         ID;
    char*       name;
    char*       color;

// Position Tracker class ?
    double      speed;  
    bool        direction;
    int         prev_track;
    int         current_track;
    int         next_track;

    int         serial_id;
    int         serial_speed;
    bool        serial_done;

    Position*   origin;
    Position*   destination;

    bool        running;    // Running or sleeping ?
    
    TrainInfo*  prev;       // Previous Train
    TrainInfo*  next;       // Next Train

    TrainInfo*  prevState;  // Previous State
    TrainInfo*  nextState;  // Next State

    TrainGUI*   traingui;

    Timer*      timer;

// Might go in Info Class
    long        action;     // Code for the Action, 0 = NOP

    double      last_update;     // in microseconds
    double      normal_update;   // Make an average 
                     // if the delay is too long, then refresh...
}

class Train : public Thread {
public:
        Train();
        Train( int ID );
        ~Train();
    void run();

protected:
    (void*)functions[26]( TrainInfo* info );

    void        initfunctions();

    int         train_ID;
    TrainInfo*  current_train_info;
    TrainInfo*  buffer_;
};

Train::Train() {
    train_ID = -1;
    initfunctions();
}

void Train::initfunctions() {
    // Not sure of the syntax  ={

    *functions[0] = Train::nop( ... );      
    *functions[1] = Train::change_speed( ... );
    *functions[2] = Train::change_direction( ... );
}

void Train::run()
{
    pid_t pid;
    int   task = 0;

    while(1)
    {
        const char* response;
        
        if((pid = Receive(0, buffer_, sizeof(buffer_))) < 0) 
        {

            printf("ERROR--code %d\n", errno);
            return;
        } else {
            task = buffer_->action;
            if ( task >= 0  &&  task < 26 ) {
                functions[task]( buffer_ ); // Call the function to do...
            } else {
                printf("Illegal task message request: %d", task );
            }
        }

        printf("Got from %d: %s\n", pid, buffer_);
        // send back
        Reply(pid, response, strlen(response)+1);
    }
    // send response and die
    Reply(pid, ok_response, sizeof(ok_response));
}

---