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
sonar cleanups
[simgrid.git]
/
src
/
msg
/
msg_private.h
diff --git
a/src/msg/msg_private.h
b/src/msg/msg_private.h
index 4b799d83a094da7fec99a7578c96a76bc15a2f24..a275943730f6e0067f4d6c97c9b793e0dcf7520d 100644
(file)
--- a/
src/msg/msg_private.h
+++ b/
src/msg/msg_private.h
@@
-38,8
+38,6
@@
typedef struct simdata_task {
/* parallel tasks only */
xbt_free(this->host_list);
/* parallel tasks only */
xbt_free(this->host_list);
-
- xbt_dict_free(&this->affinity_mask_db);
}
void setUsed();
void setNotUsed()
}
void setUsed();
void setNotUsed()
@@
-58,9
+56,6
@@
typedef struct simdata_task {
double bound = 0.0; /* Capping for CPU resource */
double rate = 0.0; /* Capping for network resource */
double bound = 0.0; /* Capping for CPU resource */
double rate = 0.0; /* Capping for network resource */
- /* CPU affinity database of this task */
- xbt_dict_t affinity_mask_db = nullptr; /* smx_host_t host => unsigned long mask */
-
bool isused = false; /* Indicates whether the task is used in SIMIX currently */
int host_nb = 0; /* ==0 if sequential task; parallel task if not */
/******* Parallel Tasks Only !!!! *******/
bool isused = false; /* Indicates whether the task is used in SIMIX currently */
int host_nb = 0; /* ==0 if sequential task; parallel task if not */
/******* Parallel Tasks Only !!!! *******/
@@
-85,7
+80,7
@@
XBT_PRIVATE void __MSG_host_release_file_descriptor_id(msg_host_t host, int id);
typedef struct simdata_process {
msg_host_t m_host; /* the host on which the process is running */
msg_host_t put_host; /* used for debugging purposes */
typedef struct simdata_process {
msg_host_t m_host; /* the host on which the process is running */
msg_host_t put_host; /* used for debugging purposes */
- smx_
synchro
_t waiting_action;
+ smx_
activity
_t waiting_action;
msg_task_t waiting_task;
msg_error_t last_errno; /* the last value returned by a MSG_function */
msg_task_t waiting_task;
msg_error_t last_errno; /* the last value returned by a MSG_function */
@@
-103,7
+98,7
@@
typedef struct process_arg {
} s_process_arg_t, *process_arg_t;
typedef struct msg_comm {
} s_process_arg_t, *process_arg_t;
typedef struct msg_comm {
- smx_
synchro
_t s_comm; /* SIMIX communication object encapsulated (the same for both processes) */
+ smx_
activity
_t s_comm; /* SIMIX communication object encapsulated (the same for both processes) */
msg_task_t task_sent; /* task sent (NULL for the receiver) */
msg_task_t *task_received; /* where the task will be received (NULL for the sender) */
msg_error_t status; /* status of the communication once finished */
msg_task_t task_sent; /* task sent (NULL for the receiver) */
msg_task_t *task_received; /* where the task will be received (NULL for the sender) */
msg_error_t status; /* status of the communication once finished */
@@
-148,7
+143,7
@@
XBT_PRIVATE smx_process_t MSG_process_create_from_SIMIX(const char *name,
const char *hostname, double kill_time,
xbt_dict_t properties, int auto_restart,
smx_process_t parent_process);
const char *hostname, double kill_time,
xbt_dict_t properties, int auto_restart,
smx_process_t parent_process);
-XBT_PRIVATE void MSG_comm_copy_data_from_SIMIX(smx_
synchro
_t comm, void* buff, size_t buff_size);
+XBT_PRIVATE void MSG_comm_copy_data_from_SIMIX(smx_
activity
_t comm, void* buff, size_t buff_size);
XBT_PRIVATE void MSG_post_create_environment();
XBT_PRIVATE void MSG_post_create_environment();