A
lgorithmique
N
umérique
D
istribuée
Public GIT Repository
projects
/
simgrid.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
SMPI: move pending_send_request_queue from global to host data
[simgrid.git]
/
src
/
smpi
/
smpi_global.c
diff --git
a/src/smpi/smpi_global.c
b/src/smpi/smpi_global.c
index
6c83e20
..
0d1b432
100644
(file)
--- a/
src/smpi/smpi_global.c
+++ b/
src/smpi/smpi_global.c
@@
-161,7
+161,6
@@
void smpi_global_init()
smpi_message_free, smpi_message_reset);
// queues
smpi_message_free, smpi_message_reset);
// queues
- smpi_global->pending_send_request_queues = xbt_new(xbt_fifo_t, size);
smpi_global->received_message_queues = xbt_new(xbt_fifo_t, size);
// sender/receiver processes
smpi_global->received_message_queues = xbt_new(xbt_fifo_t, size);
// sender/receiver processes
@@
-177,7
+176,6
@@
void smpi_global_init()
smpi_global->do_once_mutex = SIMIX_mutex_init();
for (i = 0; i < size; i++) {
smpi_global->do_once_mutex = SIMIX_mutex_init();
for (i = 0; i < size; i++) {
- smpi_global->pending_send_request_queues[i] = xbt_fifo_new();
smpi_global->received_message_queues[i] = xbt_fifo_new();
}
smpi_global->received_message_queues[i] = xbt_fifo_new();
}
@@
-245,11
+243,9
@@
void smpi_global_destroy()
SIMIX_mutex_destroy(smpi_global->do_once_mutex);
for (i = 0; i < size; i++) {
SIMIX_mutex_destroy(smpi_global->do_once_mutex);
for (i = 0; i < size; i++) {
- xbt_fifo_free(smpi_global->pending_send_request_queues[i]);
xbt_fifo_free(smpi_global->received_message_queues[i]);
}
xbt_fifo_free(smpi_global->received_message_queues[i]);
}
- xbt_free(smpi_global->pending_send_request_queues);
xbt_free(smpi_global->received_message_queues);
xbt_free(smpi_global);
xbt_free(smpi_global->received_message_queues);
xbt_free(smpi_global);