Subversion Repositories an-fpga-implementation-of-low-latency-noc-based-mpsoc

/*
 * messages.h
 *
 *  Created on: Dec 13, 2009
 *      Author: sam
 */
 
#ifndef MESSAGES_H_
#define MESSAGES_H_
 
#include "socketstream.h"
#include <stdint.h>
 
#define INVALID_MESSAGE -1
#define INITIALIZE_REQ  0
#define INITIALIZE_RES  1
#define STEP_REQ  		2
#define STEP_RES  		3
#define INJECT_REQ  	4
#define INJECT_RES  	5
#define EJECT_REQ  		6
#define EJECT_RES  		7
#define QUIT_REQ  		8
#define QUIT_RES  		9
 
struct StreamMessage
{
    int size;
    int type;
    StreamMessage() :
        size(-1), type(INVALID_MESSAGE)
    {
    }
 
    /*
     * Message sending function.
     */
    friend SocketStream& operator<<(SocketStream& os, StreamMessage& msg);
 
    /*
     * Message receiving function. Use this function if you don't know the message type in advance
     * NOTE: must destroy msg using Message::destroy(Message*)
     */
    friend SocketStream& operator>>(SocketStream& is, StreamMessage*& msg);
 
    /*
     * Message receiving function. Use this function if you know the message type in advance
     */
    friend SocketStream& operator>>(SocketStream& is, StreamMessage& msg);
 
    static void destroy(StreamMessage* msg);
};
 
struct InitializeReqMsg: StreamMessage
{
    InitializeReqMsg()
    {
        size = sizeof(InitializeReqMsg);
        type = INITIALIZE_REQ;
    }
};
 
struct InitializeResMsg: StreamMessage
{
    InitializeResMsg()
    {
        size = sizeof(InitializeResMsg);
        type = INITIALIZE_RES;
    }
};
 
struct StepReqMsg: StreamMessage
{
	StepReqMsg()
    {
        size = sizeof(StepReqMsg);
        type = STEP_REQ;
    }
};
 
struct StepResMsg: StreamMessage
{
	StepResMsg()
    {
        size = sizeof(StepResMsg);
        type = STEP_RES;
    }
};
 
struct InjectReqMsg: StreamMessage
{
	InjectReqMsg()
    {
        size = sizeof(InjectReqMsg);
        type = INJECT_REQ;
    }
	int source;
	int dest;
	int id;
	int packetSize;
	int network;
	int cl;
	int miss_pred;
	int msgType;
	int coType;
	unsigned long long address;
};
 
struct InjectResMsg: StreamMessage
{
	InjectResMsg()
    {
        size = sizeof(InjectResMsg);
        type = INJECT_RES;
    }
};
 
struct EjectReqMsg: StreamMessage
{
	EjectReqMsg()
    {
        size = sizeof(EjectReqMsg);
        type = EJECT_REQ;
    }
};
 
struct EjectResMsg: StreamMessage
{
	EjectResMsg()
    {
        size = sizeof(EjectResMsg);
        type = EJECT_RES;
    }
	int id;
	int remainingRequests;
	int source;
	int dest;
	int packetSize;
	int network;
	int cl;
	int miss_pred;
 
};
 
struct QuitReqMsg: StreamMessage
{
	QuitReqMsg()
    {
        size = sizeof(QuitReqMsg);
        type = QUIT_REQ;
    }
};
 
struct QuitResMsg: StreamMessage
{
	QuitResMsg()
    {
        size = sizeof(QuitResMsg);
        type = QUIT_RES;
    }
};
 
#endif /* MESSAGES_H_ */