msg.h

Go to the documentation of this file.

 
#pragma once
 
#include <core/core.h>
 
#include <stdatomic.h>
#include <stddef.h>
 
#define BASE_PAYLOAD_SIZE 48
 
#define msg_is_before(msg_a, msg_b) ((msg_a)->dest_t < (msg_b)->dest_t)
#define msg_bare_size(msg) (offsetof(struct lp_msg, pl) + (msg)->pl_size)
 
#define msg_id_get(msg, cur_phase)                                      \
        (((uintptr_t)msg) | ((unsigned)(cur_phase) << 1))
#define msg_id_phase_get(msg_id) (((msg_id) >> 1) & 1U)
#define msg_id_anti_phase_get(msg_id) ((msg_id) & 1U)
#define msg_id_anti_phase_set(msg_id, phase)                            \
__extension__({                                                         \
        (msg_id) &= ~((uintptr_t) 1U);                                  \
        (msg_id) |= (phase);                                            \
})
 
struct lp_msg {
        lp_id_t dest;
        simtime_t dest_t;
        uint_fast32_t m_type;
#if LOG_LEVEL <= LOG_DEBUG
        lp_id_t send;
        simtime_t send_t;
#endif
        uint_fast32_t pl_size;
        union {
                atomic_int flags;
                uintptr_t msg_id;
        };
        unsigned char pl[BASE_PAYLOAD_SIZE];
        unsigned char extra_pl[];
};
 
enum msg_flag {
        MSG_FLAG_ANTI           = 1,
        MSG_FLAG_PROCESSED      = 2
};