communication.h

Go to the documentation of this file.

#pragma once

#include <core/core.h>

#define SLAB_MSG_SIZE       512

enum _control_msgs {
    RESERVED_MSG_CODE = 65532,
    TOPOLOGY_UPDATE,        
    ABM_UPDATE,         
    ABM_VISITING,           
    ABM_LEAVING,            
    MIN_VALUE_CONTROL = 65537,  
    RENDEZVOUS_START,       
    RENDEZVOUS_ACK,         
    RENDEZVOUS_UNBLOCK,     
    RENDEZVOUS_ROLLBACK,        
    RENDEZVOUS_GET_PAGE,        
    RENDEZVOUS_GET_PAGE_ACK,    
    RENDEZVOUS_PAGE_WRITE_BACK, 
    MAX_VALUE_CONTROL       
};

#define is_control_msg(type)    (type >= MIN_VALUE_CONTROL && type != RENDEZVOUS_START)


enum _mpi_tags {
    MSG_NEW_GVT = 100,  
    MSG_FINI        
};

#define INIT_OUTGOING_MSG 8

struct lp_struct;

typedef struct _outgoing_t {
    msg_t **outgoing_msgs;      
    unsigned int size;      
    unsigned int max_size;      
    simtime_t *min_in_transit;  
} outgoing_t;



extern void ParallelScheduleNewEvent(unsigned int, simtime_t, unsigned int, void *, unsigned int);
extern void communication_init(void);
extern void communication_fini(void);
extern void Send(msg_t * msg);
extern void insert_outgoing_msg(msg_t * msg);
extern void send_outgoing_msgs(struct lp_struct *);
extern void send_antimessages(struct lp_struct *, simtime_t);

extern void msg_hdr_release(msg_hdr_t * msg);
extern msg_t *get_msg_from_slab(struct lp_struct *);
extern msg_hdr_t *get_msg_hdr_from_slab(struct lp_struct *);
extern void pack_msg(msg_t ** msg, GID_t sender, GID_t receiver, int type, simtime_t timestamp, simtime_t send_time, size_t size, void *payload);
extern void msg_to_hdr(msg_hdr_t * hdr, msg_t * msg);
extern void hdr_to_msg(msg_hdr_t * hdr, msg_t * msg);
extern void msg_release(msg_t * msg);
extern void dump_msg_content(msg_t * msg);


#ifndef NDEBUG
extern void validate_msg(msg_t * msg);
#else
#define validate_msg(msg)
#endif