char *vm_name = argv[1];
char *dst_pm_name = argv[2];
- msg_vm_t vm = MSG_get_host_by_name(vm_name);
- msg_host_t dst_pm = MSG_get_host_by_name(dst_pm_name);
+ msg_vm_t vm = MSG_host_by_name(vm_name);
+ msg_host_t dst_pm = MSG_host_by_name(dst_pm_name);
vm_migrate(vm, dst_pm);
{
msg_host_t host = NULL;
msg_task_t task1 = NULL;
- host = MSG_get_host_by_name("MyHost1");
+ host = MSG_host_by_name("MyHost1");
XBT_INFO("Energetic profile: %s",
// =========== Turn the other host off ==========
XBT_INFO("Turning MyHost2 off, and sleeping another 10 seconds. MyHost2 dissipated %.0f J so far.",
- MSG_host_get_consumed_energy(MSG_get_host_by_name("MyHost2")) );
- MSG_host_off(MSG_get_host_by_name("MyHost2"));
+ MSG_host_get_consumed_energy(MSG_host_by_name("MyHost2")) );
+ MSG_host_off(MSG_host_by_name("MyHost2"));
start = MSG_get_clock();
MSG_process_sleep(10);
XBT_INFO("Done sleeping (duration: %.2f s). Current peak speed=%.0E flop/s; Energy dissipated=%.0f J",
}
static int onoff(int argc, char *argv[]) {
- msg_host_t host1 = MSG_get_host_by_name("MyHost1");
+ msg_host_t host1 = MSG_host_by_name("MyHost1");
XBT_INFO("Energetic profile: %s",
MSG_host_get_property_value(host1,"watt_per_state"));
// Verify the default pstate is set to 0
- host = MSG_get_host_by_name("MyHost2");
+ host = MSG_host_by_name("MyHost2");
int nb2 = MSG_host_get_nb_pstates(host);
XBT_INFO("Count of Processor states=%d", nb2);
msg_host_t src, dest;
src= MSG_host_self();
- dest = MSG_get_host_by_name(argv[3]);
+ dest = MSG_host_by_name(argv[3]);
if (atoi(argv[5])){
XBT_INFO("Move '%s' (of size %llu) from '%s' to '%s'", filename,
MSG_file_get_size(file), MSG_host_get_name(src),
slaves = xbt_new0(msg_host_t, slaves_count);
for (i = 4; i < argc; i++) {
- slaves[i - 4] = MSG_get_host_by_name(argv[i]);
+ slaves[i - 4] = MSG_host_by_name(argv[i]);
if (slaves[i - 4] == NULL) {
XBT_INFO("Unknown host %s. Stopping Now!", argv[i]);
abort();
slaves = xbt_new0(msg_host_t, slaves_count);
for (i = 4; i < argc; i++) {
- slaves[i - 4] = MSG_get_host_by_name(argv[i]);
+ slaves[i - 4] = MSG_host_by_name(argv[i]);
if (slaves[i - 4] == NULL) {
XBT_INFO("Unknown host %s. Stopping Now! ", argv[i]);
abort();
slaves = xbt_new0(msg_host_t, slaves_count);
for (i = 4; i < argc; i++) {
- slaves[i - 4] = MSG_get_host_by_name(argv[i]);
+ slaves[i - 4] = MSG_host_by_name(argv[i]);
if (slaves[i - 4] == NULL) {
XBT_INFO("Unknown host %s. Stopping Now! ", argv[i]);
abort();
slaves = xbt_new0(msg_host_t, slaves_count);
for (i = 0; i < argc; i++) {
- slaves[i] = MSG_get_host_by_name(argv[i]);
+ slaves[i] = MSG_host_by_name(argv[i]);
if (slaves[i] == NULL) {
XBT_INFO("Unknown host %s. Stopping Now! ", argv[i]);
abort();
MSG_process_auto_restart_set(process, TRUE);
hostname_list[i] = (char*) MSG_host_get_name(host);
}
- host_master = MSG_get_host_by_name("host_master");
+ host_master = MSG_host_by_name("host_master");
MSG_process_create_with_arguments("master", master, NULL, host_master,
xbt_dynar_length(host_dynar),
hostname_list);
slaves = xbt_new0(msg_host_t, slaves_count);
for (i = 4; i < argc; i++) {
- slaves[i - 4] = MSG_get_host_by_name(argv[i]);
+ slaves[i - 4] = MSG_host_by_name(argv[i]);
xbt_assert(slaves[i - 4] != NULL, "Unknown host %s. Stopping Now! ",
argv[i]);
}
slaves = xbt_new0(msg_host_t, slaves_count);
for (i = 1; i < argc; i++) {
- slaves[i - 1] = MSG_get_host_by_name(argv[i]);
+ slaves[i - 1] = MSG_host_by_name(argv[i]);
if (slaves[i - 1] == NULL) {
XBT_INFO("Unknown host %s. Stopping Now! ", argv[i]);
abort();
msg_process_t bob = NULL;
XBT_INFO("Hello!");
- bob = MSG_process_create("slave", slave, NULL, MSG_get_host_by_name("Fafard"));
+ bob = MSG_process_create("slave", slave, NULL, MSG_host_by_name("Fafard"));
MSG_process_sleep(10.0);
XBT_INFO("Resume process");
slaves = xbt_new0(msg_host_t, slaves_count);
for (i = 0; i < argc; i++) {
- slaves[i] = MSG_get_host_by_name(argv[i]);
+ slaves[i] = MSG_host_by_name(argv[i]);
if (slaves[i] == NULL) {
XBT_INFO("Unknown host %s. Stopping Now! ", argv[i]);
abort();
msg_task_t task;
XBT_INFO
("I'll look for a new job on another machine where the grass is greener.");
- MSG_process_migrate(MSG_process_self(), MSG_get_host_by_name("Boivin"));
+ MSG_process_migrate(MSG_process_self(), MSG_host_by_name("Boivin"));
XBT_INFO("Yeah, found something to do");
task = MSG_task_create("job", 98095000, 0, NULL);
MSG_task_destroy(task);
MSG_process_sleep(2);
XBT_INFO("Moving back home after work");
- MSG_process_migrate(MSG_process_self(), MSG_get_host_by_name("Jacquelin"));
- MSG_process_migrate(MSG_process_self(), MSG_get_host_by_name("Boivin"));
+ MSG_process_migrate(MSG_process_self(), MSG_host_by_name("Jacquelin"));
+ MSG_process_migrate(MSG_process_self(), MSG_host_by_name("Boivin"));
MSG_process_sleep(4);
xbt_mutex_acquire(mutex);
process_to_migrate = MSG_process_self();
xbt_mutex_acquire(mutex);
XBT_INFO("Wait a bit before migrating the emigrant.");
while (process_to_migrate == NULL) xbt_cond_wait(cond, mutex);
- MSG_process_migrate(process_to_migrate, MSG_get_host_by_name("Jacquelin"));
+ MSG_process_migrate(process_to_migrate, MSG_host_by_name("Jacquelin"));
XBT_INFO("I moved the emigrant");
MSG_process_resume(process_to_migrate);
xbt_mutex_release(mutex);
XBT_DEBUG("host_list_size=%d", host_list_size);
m_host_list = calloc(host_list_size, sizeof(msg_host_t));
for (i = 1; i <= host_list_size; i++) {
- m_host_list[i - 1] = MSG_get_host_by_name(argv[i]);
+ m_host_list[i - 1] = MSG_host_by_name(argv[i]);
xbt_assert(m_host_list[i - 1] != NULL,
"Unknown host %s. Stopping Now! ", argv[i]);
}
XBT_DEBUG("host_list_size=%d", host_list_size);
m_host_list = calloc(host_list_size, sizeof(msg_host_t));
for (i = 1; i <= host_list_size; i++) {
- m_host_list[i - 1] = MSG_get_host_by_name(argv[i]);
+ m_host_list[i - 1] = MSG_host_by_name(argv[i]);
xbt_assert(m_host_list[i - 1] != NULL,
"Unknown host %s. Stopping Now! ", argv[i]);
}
static void test_host(const char*hostname)
{
- msg_host_t thehost = MSG_get_host_by_name(hostname);
+ msg_host_t thehost = MSG_host_by_name(hostname);
xbt_dict_t props = MSG_host_get_properties(thehost);
xbt_dict_cursor_t cursor = NULL;
char *key, *data;
XBT_INFO("host = %s", argv[1]);
- host = MSG_get_host_by_name(argv[1]);
+ host = MSG_host_by_name(argv[1]);
if (host == NULL) {
XBT_INFO("Unknown host %s. Stopping Now! ", argv[1]);
destination = (char*)MSG_task_get_data (task);
MSG_task_destroy (task);
if (!destination) break; //there is no destination, die
- MSG_process_migrate(MSG_process_self(), MSG_get_host_by_name(destination));
+ MSG_process_migrate(MSG_process_self(), MSG_host_by_name(destination));
MSG_process_sleep(2); // I am tired, have to sleep for 2 seconds
free (destination);
task = NULL;
XBT_PUBLIC(void) MSG_as_router_set_property_value(const char* asr, const char *name, char *value,void_f_pvoid_t free_ctn);
/************************** Host handling ***********************************/
-XBT_PUBLIC(msg_host_t) MSG_host_get_by_name(const char *name);
-#define MSG_get_host_by_name(n) MSG_host_get_by_name(n) /* Rewrite the old name into the new one transparently */
+XBT_PUBLIC(msg_host_t) MSG_host_by_name(const char *name);
+#define MSG_get_host_by_name(n) MSG_host_by_name(n) /* Rewrite the old name into the new one transparently */
XBT_PUBLIC(msg_error_t) MSG_host_set_data(msg_host_t host, void *data);
XBT_PUBLIC(void *) MSG_host_get_data(msg_host_t host);
XBT_PUBLIC(const char *) MSG_host_get_name(msg_host_t host);
}
const char *name = (*env)->GetStringUTFChars(env, jname, 0);
/* get the host by name (the hosts are created during the grid resolution) */
- host = MSG_get_host_by_name(name);
+ host = MSG_host_by_name(name);
if (!host) { /* invalid name */
jxbt_throw_host_not_found(env, name);
}
/* bind/retrieve the msg host */
- host = MSG_get_host_by_name(hostname);
+ host = MSG_host_by_name(hostname);
if (!(host)) { /* not bound */
jxbt_throw_host_not_found(env, hostname);
{
const char *name = luaL_checkstring(L, 1);
XBT_DEBUG("Getting Host from name...");
- msg_host_t msg_host = MSG_get_host_by_name(name);
+ msg_host_t msg_host = MSG_host_by_name(name);
if (!msg_host) {
luaL_error(L, "null Host : MSG_get_host_by_name failed");
}
args = xbt_str_split_str( lua_tostring(L,-1) , ",");
lua_pop(L, 1);
- // FIXME: hackish to go under MSG that way
- msg_host_t host = MSG_host_get_by_name(host_id);
+ msg_host_t host = MSG_host_by_name(host_id);
if (!host) {
XBT_ERROR("no host '%s' found",host_id);
return -1;
prop_value = lua_tostring(L,-1);
lua_pop(L, 1);
- msg_host_t host = MSG_host_get_by_name(name);
+ msg_host_t host = MSG_host_by_name(name);
if (!host) {
XBT_ERROR("no host '%s' found",name);
return -1;
* \param name the name of an host.
* \return the corresponding host
*/
-msg_host_t MSG_host_get_by_name(const char *name)
+msg_host_t MSG_host_by_name(const char *name)
{
return (msg_host_t) xbt_lib_get_elm_or_null(host_lib,name);
}
/* Find the host where the file is physically located and read it */
msg_storage_t storage_src =(msg_storage_t) xbt_lib_get_elm_or_null(storage_lib, file_priv->storageId);
msg_storage_priv_t storage_priv_src = MSG_storage_priv(storage_src);
- msg_host_t attached_host = MSG_get_host_by_name(storage_priv_src->hostname);
+ msg_host_t attached_host = MSG_host_by_name(storage_priv_src->hostname);
read_size = simcall_file_read(file_priv->simdata->smx_file, size, attached_host);
if(strcmp(storage_priv_src->hostname, MSG_host_get_name(MSG_host_self()))){
/* Find the host where the file is physically located (remote or local)*/
msg_storage_t storage_src =(msg_storage_t) xbt_lib_get_elm_or_null(storage_lib, file_priv->storageId);
msg_storage_priv_t storage_priv_src = MSG_storage_priv(storage_src);
- msg_host_t attached_host = MSG_get_host_by_name(storage_priv_src->hostname);
+ msg_host_t attached_host = MSG_host_by_name(storage_priv_src->hostname);
if(strcmp(storage_priv_src->hostname, MSG_host_get_name(MSG_host_self()))){
/* the file is hosted on a remote host, initiate a communication between src and dest hosts for data transfer */
(msg_storage_t) xbt_lib_get_elm_or_null(storage_lib,
file_priv->storageId);
msg_storage_priv_t storage_priv_src = MSG_storage_priv(storage_src);
- msg_host_t attached_host = MSG_get_host_by_name(storage_priv_src->hostname);
+ msg_host_t attached_host = MSG_host_by_name(storage_priv_src->hostname);
int res = simcall_file_unlink(file_priv->simdata->smx_file, attached_host);
return res;
}
/* Find the host where the file is physically located and read it */
msg_storage_t storage_src =(msg_storage_t) xbt_lib_get_elm_or_null(storage_lib, file_priv->storageId);
msg_storage_priv_t storage_priv_src = MSG_storage_priv(storage_src);
- msg_host_t attached_host = MSG_get_host_by_name(storage_priv_src->hostname);
+ msg_host_t attached_host = MSG_host_by_name(storage_priv_src->hostname);
MSG_file_seek(file, 0, SEEK_SET);
read_size = simcall_file_read(file_priv->simdata->smx_file, file_priv->size, attached_host);
/* Mount point found, retrieve the host the storage is attached to */
msg_storage_priv_t storage_dest_priv = MSG_storage_priv(storage_dest);
host_name_dest = (char*)storage_dest_priv->hostname;
- host_dest = MSG_get_host_by_name(host_name_dest);
+ host_dest = MSG_host_by_name(host_name_dest);
}else{
XBT_WARN("Can't find mount point for '%s' on destination host '%s'", fullpath, SIMIX_host_get_name(host));
xbt_dict_t properties, int auto_restart,
smx_process_t parent_process)
{
- msg_host_t host = MSG_get_host_by_name(hostname);
+ msg_host_t host = MSG_host_by_name(hostname);
msg_process_t p = MSG_process_create_with_environment(name, code, data,
host, argc, argv,
properties);
msg_vm_t MSG_vm_get_by_name(const char *name)
{
- return MSG_get_host_by_name(name);
+ return MSG_host_by_name(name);
}
/** \ingroup m_vm_management
char mailbox[256];
msg_task_t task = NULL;
- msg_host_t jupiter = MSG_get_host_by_name("Jupiter");
+ msg_host_t jupiter = MSG_host_by_name("Jupiter");
sprintf(mailbox, "jupi");
task = MSG_task_create("task on", task_comp_size, task_comm_size, NULL);
char **argvF = xbt_new(char*, 2);
argvF[0] = xbt_strdup("slave");
- MSG_process_create_with_arguments("slave", slave, NULL, MSG_get_host_by_name("Jupiter"), 1, argvF);
+ MSG_process_create_with_arguments("slave", slave, NULL, MSG_host_by_name("Jupiter"), 1, argvF);
task = MSG_task_create("task on with proc", task_comp_size, task_comm_size, NULL);
XBT_INFO("Sending \"%s\"", task->name);
{
xbt_ex_t e;
TRY {
- msg_host_t jupiter = MSG_get_host_by_name("Jupiter");
+ msg_host_t jupiter = MSG_host_by_name("Jupiter");
XBT_INFO("Master starting");
MSG_process_sleep(0.5);
{
xbt_ex_t e;
TRY {
- msg_host_t jupiter = MSG_get_host_by_name("Jupiter");
+ msg_host_t jupiter = MSG_host_by_name("Jupiter");
XBT_INFO("Master waiting");
if(MSG_process_sleep(1)) {
XBT_ERROR("Unexpected error while sleeping");
char **argvF;
argvF = xbt_new(char*, 2);
argvF[0] = xbt_strdup("process_daemon");
- msg_host_t jupiter = MSG_get_host_by_name("Jupiter");
+ msg_host_t jupiter = MSG_host_by_name("Jupiter");
test = 1;
// Create a process running a simple task on a host and turn the host off during the execution of the process.
MSG_process_sleep(10);
argvF = xbt_new(char*, 2);
argvF[0] = xbt_strdup("commRX");
- MSG_process_create_with_arguments("commRX", commRX, NULL, MSG_get_host_by_name("Tremblay"), 1, argvF);
+ MSG_process_create_with_arguments("commRX", commRX, NULL, MSG_host_by_name("Tremblay"), 1, argvF);
argvF = xbt_new(char*, 2);
argvF[0] = xbt_strdup("commTX");
MSG_process_create_with_arguments("commTX", commTX, NULL, jupiter, 1, argvF);
MSG_process_create_with_arguments("commRX", commRX, NULL, jupiter, 1, argvF);
argvF = xbt_new(char*, 2);
argvF[0] = xbt_strdup("commTX");
- MSG_process_create_with_arguments("commTX", commTX, NULL, MSG_get_host_by_name("Tremblay"), 1, argvF);
+ MSG_process_create_with_arguments("commTX", commTX, NULL, MSG_host_by_name("Tremblay"), 1, argvF);
XBT_INFO(" number of processes: %d", MSG_process_get_number());
MSG_process_sleep(10);
XBT_INFO(" Turn Jupiter off");
MSG_create_environment(argv[1]);
MSG_function_register("host", host);
- storage_info(MSG_get_host_by_name(xbt_strdup("host")));
+ storage_info(MSG_host_by_name(xbt_strdup("host")));
for(i = 0 ; i<10; i++){
- MSG_process_create(xbt_strdup("host"), host, NULL, MSG_get_host_by_name(xbt_strdup("host")));
+ MSG_process_create(xbt_strdup("host"), host, NULL, MSG_host_by_name(xbt_strdup("host")));
}
res = MSG_main();
- storage_info(MSG_get_host_by_name(xbt_strdup("host")));
+ storage_info(MSG_host_by_name(xbt_strdup("host")));
XBT_INFO("Simulation time %g", MSG_get_clock());
if (res == MSG_OK)