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
[surf] Remove sg_platf_storage_type_cb
[simgrid.git]
/
src
/
simix
/
smx_io.c
diff --git
a/src/simix/smx_io.c
b/src/simix/smx_io.c
index
97b1fc4
..
241e569
100644
(file)
--- a/
src/simix/smx_io.c
+++ b/
src/simix/smx_io.c
@@
-1,11
+1,10
@@
-/* Copyright (c) 2007-2010, 2012-201
4
. The SimGrid Team.
+/* Copyright (c) 2007-2010, 2012-201
5
. The SimGrid Team.
* All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
#include "smx_private.h"
* All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
#include "smx_private.h"
-//#include "surf/storage_private.h"
#include "xbt/sysdep.h"
#include "xbt/log.h"
#include "xbt/dict.h"
#include "xbt/sysdep.h"
#include "xbt/log.h"
#include "xbt/dict.h"
@@
-50,215
+49,202
@@
void SIMIX_storage_destroy(void *s)
}
//SIMIX FILE READ
}
//SIMIX FILE READ
-void
SIMIX_pre_file_read(smx_simcall_t simcall, smx_file_t fd, sg_size_t size, smx
_host_t host)
+void
simcall_HANDLER_file_read(smx_simcall_t simcall, smx_file_t fd, sg_size_t size, sg
_host_t host)
{
{
- smx_
action_t action = SIMIX_file_read(simcall->issuer,
fd, size, host);
- xbt_fifo_push(
action
->simcalls, simcall);
- simcall->issuer->waiting_
action = action
;
+ smx_
synchro_t synchro = SIMIX_file_read(
fd, size, host);
+ xbt_fifo_push(
synchro
->simcalls, simcall);
+ simcall->issuer->waiting_
synchro = synchro
;
}
}
-smx_
action_t SIMIX_file_read(smx_process_t process, smx_file_t fd, sg_size_t size, smx
_host_t host)
+smx_
synchro_t SIMIX_file_read(smx_file_t fd, sg_size_t size, sg
_host_t host)
{
{
- smx_
action_t action
;
+ smx_
synchro_t synchro
;
/* check if the host is active */
/* check if the host is active */
- if (surf_
resource_get_state(surf_workstation
_resource_priv(host)) != SURF_RESOURCE_ON) {
+ if (surf_
host_get_state(surf_host
_resource_priv(host)) != SURF_RESOURCE_ON) {
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
- sg_host_name(host));
+ sg_host_
get_
name(host));
}
}
- action = xbt_mallocator_get(simix_global->action_mallocator);
- action->type = SIMIX_ACTION_IO;
- action->name = NULL;
-#ifdef HAVE_TRACING
- action->category = NULL;
-#endif
+ synchro = xbt_mallocator_get(simix_global->synchro_mallocator);
+ synchro->type = SIMIX_SYNC_IO;
+ synchro->name = NULL;
+ synchro->category = NULL;
-
action
->io.host = host;
-
action->io.surf_io = surf_workstation
_read(host, fd->surf_file, size);
+
synchro
->io.host = host;
+
synchro->io.surf_io = surf_host
_read(host, fd->surf_file, size);
- surf_action_set_data(
action->io.surf_io, action
);
- XBT_DEBUG("Create io
action %p", action
);
+ surf_action_set_data(
synchro->io.surf_io, synchro
);
+ XBT_DEBUG("Create io
synchro %p", synchro
);
- return
action
;
+ return
synchro
;
}
//SIMIX FILE WRITE
}
//SIMIX FILE WRITE
-void
SIMIX_pre_file_write(smx_simcall_t simcall, smx_file_t fd, sg_size_t size, smx
_host_t host)
+void
simcall_HANDLER_file_write(smx_simcall_t simcall, smx_file_t fd, sg_size_t size, sg
_host_t host)
{
{
- smx_
action_t action = SIMIX_file_write(simcall->issuer,
fd, size, host);
- xbt_fifo_push(
action
->simcalls, simcall);
- simcall->issuer->waiting_
action = action
;
+ smx_
synchro_t synchro = SIMIX_file_write(
fd, size, host);
+ xbt_fifo_push(
synchro
->simcalls, simcall);
+ simcall->issuer->waiting_
synchro = synchro
;
}
}
-smx_
action_t SIMIX_file_write(smx_process_t process, smx_file_t fd, sg_size_t size, smx
_host_t host)
+smx_
synchro_t SIMIX_file_write(smx_file_t fd, sg_size_t size, sg
_host_t host)
{
{
- smx_
action_t action
;
+ smx_
synchro_t synchro
;
/* check if the host is active */
/* check if the host is active */
- if (surf_
resource_get_state(surf_workstation
_resource_priv(host)) != SURF_RESOURCE_ON) {
+ if (surf_
host_get_state(surf_host
_resource_priv(host)) != SURF_RESOURCE_ON) {
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
- sg_host_name(host));
+ sg_host_
get_
name(host));
}
}
- action = xbt_mallocator_get(simix_global->action_mallocator);
- action->type = SIMIX_ACTION_IO;
- action->name = NULL;
-#ifdef HAVE_TRACING
- action->category = NULL;
-#endif
+ synchro = xbt_mallocator_get(simix_global->synchro_mallocator);
+ synchro->type = SIMIX_SYNC_IO;
+ synchro->name = NULL;
+ synchro->category = NULL;
-
action
->io.host = host;
-
action->io.surf_io = surf_workstation
_write(host, fd->surf_file, size);
+
synchro
->io.host = host;
+
synchro->io.surf_io = surf_host
_write(host, fd->surf_file, size);
- surf_action_set_data(
action->io.surf_io, action
);
- XBT_DEBUG("Create io
action %p", action
);
+ surf_action_set_data(
synchro->io.surf_io, synchro
);
+ XBT_DEBUG("Create io
synchro %p", synchro
);
- return
action
;
+ return
synchro
;
}
//SIMIX FILE OPEN
}
//SIMIX FILE OPEN
-void
SIMIX_pre_file_open(smx_simcall_t simcall, const char* fullpath, smx
_host_t host)
+void
simcall_HANDLER_file_open(smx_simcall_t simcall, const char* fullpath, sg
_host_t host)
{
{
- smx_
action_t action = SIMIX_file_open(simcall->issuer,
fullpath, host);
- xbt_fifo_push(
action
->simcalls, simcall);
- simcall->issuer->waiting_
action = action
;
+ smx_
synchro_t synchro = SIMIX_file_open(
fullpath, host);
+ xbt_fifo_push(
synchro
->simcalls, simcall);
+ simcall->issuer->waiting_
synchro = synchro
;
}
}
-smx_
action_t SIMIX_file_open(smx_process_t process, const char* fullpath, smx
_host_t host)
+smx_
synchro_t SIMIX_file_open(const char* fullpath, sg
_host_t host)
{
{
- smx_
action_t action
;
+ smx_
synchro_t synchro
;
/* check if the host is active */
/* check if the host is active */
- if (surf_
resource_get_state(surf_workstation
_resource_priv(host)) != SURF_RESOURCE_ON) {
+ if (surf_
host_get_state(surf_host
_resource_priv(host)) != SURF_RESOURCE_ON) {
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
- sg_host_name(host));
+ sg_host_
get_
name(host));
}
}
- action = xbt_mallocator_get(simix_global->action_mallocator);
- action->type = SIMIX_ACTION_IO;
- action->name = NULL;
-#ifdef HAVE_TRACING
- action->category = NULL;
-#endif
+ synchro = xbt_mallocator_get(simix_global->synchro_mallocator);
+ synchro->type = SIMIX_SYNC_IO;
+ synchro->name = NULL;
+ synchro->category = NULL;
-
action
->io.host = host;
-
action->io.surf_io = surf_workstation
_open(host, fullpath);
+
synchro
->io.host = host;
+
synchro->io.surf_io = surf_host
_open(host, fullpath);
- surf_action_set_data(
action->io.surf_io, action
);
- XBT_DEBUG("Create io
action %p", action
);
+ surf_action_set_data(
synchro->io.surf_io, synchro
);
+ XBT_DEBUG("Create io
synchro %p", synchro
);
- return
action
;
+ return
synchro
;
}
//SIMIX FILE CLOSE
}
//SIMIX FILE CLOSE
-void
SIMIX_pre_file_close(smx_simcall_t simcall, smx_file_t fd, smx
_host_t host)
+void
simcall_HANDLER_file_close(smx_simcall_t simcall, smx_file_t fd, sg
_host_t host)
{
{
- smx_
action_t action = SIMIX_file_close(simcall->issuer,
fd, host);
- xbt_fifo_push(
action
->simcalls, simcall);
- simcall->issuer->waiting_
action = action
;
+ smx_
synchro_t synchro = SIMIX_file_close(
fd, host);
+ xbt_fifo_push(
synchro
->simcalls, simcall);
+ simcall->issuer->waiting_
synchro = synchro
;
}
}
-smx_
action_t SIMIX_file_close(smx_process_t process, smx_file_t fd, smx
_host_t host)
+smx_
synchro_t SIMIX_file_close(smx_file_t fd, sg
_host_t host)
{
{
- smx_
action_t action
;
+ smx_
synchro_t synchro
;
/* check if the host is active */
/* check if the host is active */
- if (surf_
resource_get_state(surf_workstation
_resource_priv(host)) != SURF_RESOURCE_ON) {
+ if (surf_
host_get_state(surf_host
_resource_priv(host)) != SURF_RESOURCE_ON) {
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
- sg_host_name(host));
+ sg_host_
get_
name(host));
}
}
- action = xbt_mallocator_get(simix_global->action_mallocator);
- action->type = SIMIX_ACTION_IO;
- action->name = NULL;
-#ifdef HAVE_TRACING
- action->category = NULL;
-#endif
+ synchro = xbt_mallocator_get(simix_global->synchro_mallocator);
+ synchro->type = SIMIX_SYNC_IO;
+ synchro->name = NULL;
+ synchro->category = NULL;
-
action
->io.host = host;
-
action->io.surf_io = surf_workstation
_close(host, fd->surf_file);
+
synchro
->io.host = host;
+
synchro->io.surf_io = surf_host
_close(host, fd->surf_file);
- surf_action_set_data(
action->io.surf_io, action
);
- XBT_DEBUG("Create io
action %p", action
);
+ surf_action_set_data(
synchro->io.surf_io, synchro
);
+ XBT_DEBUG("Create io
synchro %p", synchro
);
- return
action
;
+ return
synchro
;
}
//SIMIX FILE UNLINK
}
//SIMIX FILE UNLINK
-int SIMIX_pre_file_unlink(smx_simcall_t simcall, smx_file_t fd, smx_host_t host)
-{
- return SIMIX_file_unlink(simcall->issuer, fd, host);
-}
-
-int SIMIX_file_unlink(smx_process_t process, smx_file_t fd, smx_host_t host)
+int SIMIX_file_unlink(smx_file_t fd, sg_host_t host)
{
/* check if the host is active */
{
/* check if the host is active */
- if (surf_
resource_get_state(surf_workstation
_resource_priv(host)) != SURF_RESOURCE_ON) {
+ if (surf_
host_get_state(surf_host
_resource_priv(host)) != SURF_RESOURCE_ON) {
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
THROWF(host_error, 0, "Host %s failed, you cannot call this function",
- sg_host_name(host));
+ sg_host_
get_
name(host));
}
}
- int res = surf_
workstation
_unlink(host, fd->surf_file);
+ int res = surf_
host
_unlink(host, fd->surf_file);
xbt_free(fd);
return !!res;
}
xbt_free(fd);
return !!res;
}
-sg_size_t
SIMIX_pre
_file_get_size(smx_simcall_t simcall, smx_file_t fd)
+sg_size_t
simcall_HANDLER
_file_get_size(smx_simcall_t simcall, smx_file_t fd)
{
return SIMIX_file_get_size(simcall->issuer, fd);
}
sg_size_t SIMIX_file_get_size(smx_process_t process, smx_file_t fd)
{
{
return SIMIX_file_get_size(simcall->issuer, fd);
}
sg_size_t SIMIX_file_get_size(smx_process_t process, smx_file_t fd)
{
- s
mx_host_t host = process->smx_
host;
- return surf_
workstation
_get_size(host, fd->surf_file);
+ s
g_host_t host = process->
host;
+ return surf_
host
_get_size(host, fd->surf_file);
}
}
-sg_size_t
SIMIX_pre
_file_tell(smx_simcall_t simcall, smx_file_t fd)
+sg_size_t
simcall_HANDLER
_file_tell(smx_simcall_t simcall, smx_file_t fd)
{
return SIMIX_file_tell(simcall->issuer, fd);
}
sg_size_t SIMIX_file_tell(smx_process_t process, smx_file_t fd)
{
{
return SIMIX_file_tell(simcall->issuer, fd);
}
sg_size_t SIMIX_file_tell(smx_process_t process, smx_file_t fd)
{
- s
mx_host_t host = process->smx_
host;
- return surf_
workstation
_file_tell(host, fd->surf_file);
+ s
g_host_t host = process->
host;
+ return surf_
host
_file_tell(host, fd->surf_file);
}
}
-xbt_dynar_t
SIMIX_pre
_file_get_info(smx_simcall_t simcall, smx_file_t fd)
+xbt_dynar_t
simcall_HANDLER
_file_get_info(smx_simcall_t simcall, smx_file_t fd)
{
return SIMIX_file_get_info(simcall->issuer, fd);
}
xbt_dynar_t SIMIX_file_get_info(smx_process_t process, smx_file_t fd)
{
{
return SIMIX_file_get_info(simcall->issuer, fd);
}
xbt_dynar_t SIMIX_file_get_info(smx_process_t process, smx_file_t fd)
{
- s
mx_host_t host = process->smx_
host;
- return surf_
workstation
_get_info(host, fd->surf_file);
+ s
g_host_t host = process->
host;
+ return surf_
host
_get_info(host, fd->surf_file);
}
}
-int
SIMIX_pre
_file_seek(smx_simcall_t simcall, smx_file_t fd, sg_offset_t offset, int origin)
+int
simcall_HANDLER
_file_seek(smx_simcall_t simcall, smx_file_t fd, sg_offset_t offset, int origin)
{
return SIMIX_file_seek(simcall->issuer, fd, offset, origin);
}
int SIMIX_file_seek(smx_process_t process, smx_file_t fd, sg_offset_t offset, int origin)
{
{
return SIMIX_file_seek(simcall->issuer, fd, offset, origin);
}
int SIMIX_file_seek(smx_process_t process, smx_file_t fd, sg_offset_t offset, int origin)
{
- s
mx_host_t host = process->smx_
host;
- return surf_
workstation
_file_seek(host, fd->surf_file, offset, origin);
+ s
g_host_t host = process->
host;
+ return surf_
host
_file_seek(host, fd->surf_file, offset, origin);
}
}
-int
SIMIX_pre
_file_move(smx_simcall_t simcall, smx_file_t file, const char* fullpath)
+int
simcall_HANDLER
_file_move(smx_simcall_t simcall, smx_file_t file, const char* fullpath)
{
return SIMIX_file_move(simcall->issuer, file, fullpath);
}
int SIMIX_file_move(smx_process_t process, smx_file_t file, const char* fullpath)
{
{
return SIMIX_file_move(simcall->issuer, file, fullpath);
}
int SIMIX_file_move(smx_process_t process, smx_file_t file, const char* fullpath)
{
- s
mx_host_t host = process->smx_
host;
- return surf_
workstation
_file_move(host, file->surf_file, fullpath);
+ s
g_host_t host = process->
host;
+ return surf_
host
_file_move(host, file->surf_file, fullpath);
}
sg_size_t SIMIX_storage_get_size(smx_storage_t storage){
}
sg_size_t SIMIX_storage_get_size(smx_storage_t storage){
@@
-266,7
+252,7
@@
sg_size_t SIMIX_storage_get_size(smx_storage_t storage){
return surf_storage_get_size(storage);
}
return surf_storage_get_size(storage);
}
-sg_size_t
SIMIX_pre
_storage_get_free_size(smx_simcall_t simcall, smx_storage_t storage)
+sg_size_t
simcall_HANDLER
_storage_get_free_size(smx_simcall_t simcall, smx_storage_t storage)
{
return SIMIX_storage_get_free_size(simcall->issuer, storage);
}
{
return SIMIX_storage_get_free_size(simcall->issuer, storage);
}
@@
-276,7
+262,7
@@
sg_size_t SIMIX_storage_get_free_size(smx_process_t process, smx_storage_t stora
return surf_storage_get_free_size(storage);
}
return surf_storage_get_free_size(storage);
}
-sg_size_t
SIMIX_pre
_storage_get_used_size(smx_simcall_t simcall, smx_storage_t storage)
+sg_size_t
simcall_HANDLER
_storage_get_used_size(smx_simcall_t simcall, smx_storage_t storage)
{
return SIMIX_storage_get_used_size(simcall->issuer, storage);
}
{
return SIMIX_storage_get_used_size(simcall->issuer, storage);
}
@@
-286,51
+272,36
@@
sg_size_t SIMIX_storage_get_used_size(smx_process_t process, smx_storage_t stora
return surf_storage_get_used_size(storage);
}
return surf_storage_get_used_size(storage);
}
-xbt_dict_t SIMIX_pre_storage_get_properties(smx_simcall_t simcall, smx_storage_t storage){
- return SIMIX_storage_get_properties(storage);
-}
xbt_dict_t SIMIX_storage_get_properties(smx_storage_t storage){
xbt_assert((storage != NULL), "Invalid parameters (simix storage is NULL)");
return surf_resource_get_properties(surf_storage_resource_priv(storage));
}
xbt_dict_t SIMIX_storage_get_properties(smx_storage_t storage){
xbt_assert((storage != NULL), "Invalid parameters (simix storage is NULL)");
return surf_resource_get_properties(surf_storage_resource_priv(storage));
}
-const char* SIMIX_pre_storage_get_name(smx_simcall_t simcall, smx_storage_t storage){
- return SIMIX_storage_get_name(storage);
-}
-
const char* SIMIX_storage_get_name(smx_storage_t storage){
xbt_assert((storage != NULL), "Invalid parameters");
return sg_storage_name(storage);
}
const char* SIMIX_storage_get_name(smx_storage_t storage){
xbt_assert((storage != NULL), "Invalid parameters");
return sg_storage_name(storage);
}
-xbt_dict_t SIMIX_pre_storage_get_content(smx_simcall_t simcall, smx_storage_t storage){
- return SIMIX_storage_get_content(storage);
-}
-
xbt_dict_t SIMIX_storage_get_content(smx_storage_t storage){
xbt_assert((storage != NULL), "Invalid parameters (simix storage is NULL)");
return surf_storage_get_content(storage);
}
xbt_dict_t SIMIX_storage_get_content(smx_storage_t storage){
xbt_assert((storage != NULL), "Invalid parameters (simix storage is NULL)");
return surf_storage_get_content(storage);
}
-const char* SIMIX_pre_storage_get_host(smx_simcall_t simcall, smx_storage_t storage){
- return SIMIX_storage_get_host(storage);
-}
-
const char* SIMIX_storage_get_host(smx_storage_t storage){
xbt_assert((storage != NULL), "Invalid parameters");
return surf_storage_get_host(storage);
}
const char* SIMIX_storage_get_host(smx_storage_t storage){
xbt_assert((storage != NULL), "Invalid parameters");
return surf_storage_get_host(storage);
}
-void SIMIX_post_io(smx_
action_t action
)
+void SIMIX_post_io(smx_
synchro_t synchro
)
{
xbt_fifo_item_t i;
smx_simcall_t simcall;
{
xbt_fifo_item_t i;
smx_simcall_t simcall;
- xbt_fifo_foreach(
action
->simcalls,i,simcall,smx_simcall_t) {
+ xbt_fifo_foreach(
synchro
->simcalls,i,simcall,smx_simcall_t) {
switch (simcall->call) {
case SIMCALL_FILE_OPEN: {
smx_file_t tmp = xbt_new(s_smx_file_t,1);
switch (simcall->call) {
case SIMCALL_FILE_OPEN: {
smx_file_t tmp = xbt_new(s_smx_file_t,1);
- tmp->surf_file = surf_storage_action_get_file(
action
->io.surf_io);
+ tmp->surf_file = surf_storage_action_get_file(
synchro
->io.surf_io);
simcall_file_open__set__result(simcall, tmp);
break;
}
simcall_file_open__set__result(simcall, tmp);
break;
}
@@
-339,11
+310,11
@@
void SIMIX_post_io(smx_action_t action)
simcall_file_close__set__result(simcall, 0);
break;
case SIMCALL_FILE_WRITE:
simcall_file_close__set__result(simcall, 0);
break;
case SIMCALL_FILE_WRITE:
- simcall_file_write__set__result(simcall, surf_action_get_cost(
action
->io.surf_io));
+ simcall_file_write__set__result(simcall, surf_action_get_cost(
synchro
->io.surf_io));
break;
case SIMCALL_FILE_READ:
break;
case SIMCALL_FILE_READ:
- simcall_file_read__set__result(simcall, surf_action_get_cost(
action
->io.surf_io));
+ simcall_file_read__set__result(simcall, surf_action_get_cost(
synchro
->io.surf_io));
break;
default:
break;
default:
@@
-351,14
+322,14
@@
void SIMIX_post_io(smx_action_t action)
}
}
}
}
- switch (surf_action_get_state(
action
->io.surf_io)) {
+ switch (surf_action_get_state(
synchro
->io.surf_io)) {
case SURF_ACTION_FAILED:
case SURF_ACTION_FAILED:
-
action
->state = SIMIX_FAILED;
+
synchro
->state = SIMIX_FAILED;
break;
case SURF_ACTION_DONE:
break;
case SURF_ACTION_DONE:
-
action
->state = SIMIX_DONE;
+
synchro
->state = SIMIX_DONE;
break;
default:
break;
default:
@@
-366,28
+337,28
@@
void SIMIX_post_io(smx_action_t action)
break;
}
break;
}
- SIMIX_io_finish(
action
);
+ SIMIX_io_finish(
synchro
);
}
}
-void SIMIX_io_destroy(smx_
action_t action
)
+void SIMIX_io_destroy(smx_
synchro_t synchro
)
{
{
- XBT_DEBUG("Destroy
action %p", action
);
- if (
action
->io.surf_io)
- surf_action_unref(
action
->io.surf_io);
- xbt_mallocator_release(simix_global->
action_mallocator, action
);
+ XBT_DEBUG("Destroy
synchro %p", synchro
);
+ if (
synchro
->io.surf_io)
+ surf_action_unref(
synchro
->io.surf_io);
+ xbt_mallocator_release(simix_global->
synchro_mallocator, synchro
);
}
}
-void SIMIX_io_finish(smx_
action_t action
)
+void SIMIX_io_finish(smx_
synchro_t synchro
)
{
xbt_fifo_item_t item;
smx_simcall_t simcall;
{
xbt_fifo_item_t item;
smx_simcall_t simcall;
- xbt_fifo_foreach(
action
->simcalls, item, simcall, smx_simcall_t) {
+ xbt_fifo_foreach(
synchro
->simcalls, item, simcall, smx_simcall_t) {
- switch (
action
->state) {
+ switch (
synchro
->state) {
case SIMIX_DONE:
case SIMIX_DONE:
- /* do nothing,
action
done */
+ /* do nothing,
synchro
done */
break;
case SIMIX_FAILED:
break;
case SIMIX_FAILED:
@@
-399,18
+370,18
@@
void SIMIX_io_finish(smx_action_t action)
break;
default:
break;
default:
- xbt_die("Internal error in SIMIX_io_finish: unexpected
action
state %d",
- (int)
action
->state);
+ xbt_die("Internal error in SIMIX_io_finish: unexpected
synchro
state %d",
+ (int)
synchro
->state);
}
}
- if (surf_
resource_get_state(surf_workstation_resource_priv(simcall->issuer->smx_
host)) != SURF_RESOURCE_ON) {
+ if (surf_
host_get_state(surf_host_resource_priv(simcall->issuer->
host)) != SURF_RESOURCE_ON) {
simcall->issuer->context->iwannadie = 1;
}
simcall->issuer->context->iwannadie = 1;
}
- simcall->issuer->waiting_
action
= NULL;
+ simcall->issuer->waiting_
synchro
= NULL;
SIMIX_simcall_answer(simcall);
}
/* We no longer need it */
SIMIX_simcall_answer(simcall);
}
/* We no longer need it */
- SIMIX_io_destroy(
action
);
+ SIMIX_io_destroy(
synchro
);
}
}