The ROme OpTimistic Simulator  3.0.0
A General-Purpose Multithreaded Parallel/Distributed Simulation Platform
msg_queue.h
Go to the documentation of this file.
1 
11 #pragma once
12 
13 #include <core/core.h>
14 #include <lp/msg.h>
15 
16 extern void msg_queue_global_init(void);
17 extern void msg_queue_global_fini(void);
18 extern void msg_queue_init(void);
19 extern void msg_queue_fini(void);
20 extern struct lp_msg *msg_queue_extract(void);
21 extern simtime_t msg_queue_time_peek(void);
22 extern void msg_queue_insert(struct lp_msg *msg);
simtime_t
double simtime_t
The type used to represent logical time in the simulation.
Definition: core.h:62
msg_queue_global_fini
void msg_queue_global_fini(void)
Finalizes the message queue at the node level.
Definition: msg_queue.c:85
msg_queue_time_peek
simtime_t msg_queue_time_peek(void)
Peeks the timestamp of the next message from the queue.
Definition: msg_queue.c:137
lp_msg
A model simulation message.
Definition: msg.h:34
msg.h
Message management functions.
msg_queue_global_init
void msg_queue_global_init(void)
Initializes the message queue at the node level.
Definition: msg_queue.c:46
msg_queue_init
void msg_queue_init(void)
Initializes the message queue for the current thread.
Definition: msg_queue.c:54
msg_queue_insert
void msg_queue_insert(struct lp_msg *msg)
Inserts a message in the queue.
Definition: msg_queue.c:168
msg_queue_extract
struct lp_msg * msg_queue_extract(void)
Extracts the next message from the queue.
Definition: msg_queue.c:98
core.h
Core ROOT-Sim functionalities.
msg_queue_fini
void msg_queue_fini(void)
Finalizes the message queue for the current thread.
Definition: msg_queue.c:66