/* 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 "src/kernel/activity/SynchroIo.hpp"
+#include "src/kernel/activity/IoImpl.hpp"
#include "simgrid/kernel/resource/Action.hpp"
#include "src/simix/smx_io_private.hpp"
void simgrid::kernel::activity::IoImpl::suspend()
{
- if (surf_io)
- surf_io->suspend();
+ if (surf_action_ != nullptr)
+ surf_action_->suspend();
}
void simgrid::kernel::activity::IoImpl::resume()
{
- if (surf_io)
- surf_io->resume();
+ if (surf_action_ != nullptr)
+ surf_action_->resume();
}
void simgrid::kernel::activity::IoImpl::post()
for (smx_simcall_t const& simcall : simcalls_) {
switch (simcall->call) {
case SIMCALL_STORAGE_WRITE:
- simcall_storage_write__set__result(simcall, surf_io->get_cost());
+ simcall_storage_write__set__result(simcall, surf_action_->get_cost());
break;
case SIMCALL_STORAGE_READ:
- simcall_storage_read__set__result(simcall, surf_io->get_cost());
+ simcall_storage_read__set__result(simcall, surf_action_->get_cost());
break;
default:
break;
}
}
- switch (surf_io->get_state()) {
+ switch (surf_action_->get_state()) {
case simgrid::kernel::resource::Action::State::FAILED:
state_ = SIMIX_FAILED;
break;
void resume() override;
void post() override;
- simgrid::kernel::resource::Action* surf_io = nullptr;
- };
-
-}}} // namespace simgrid::kernel::activity
+ simgrid::kernel::resource::Action* surf_action_ = nullptr;
+};
+}
+}
+} // namespace simgrid::kernel::activity
#endif
#include "mc/mc.h"
#include "smx_private.hpp"
+#include "src/kernel/activity/IoImpl.hpp"
#include "src/kernel/activity/SleepImpl.hpp"
-#include "src/kernel/activity/SynchroIo.hpp"
#include "src/kernel/activity/SynchroRaw.hpp"
#include "src/mc/mc_replay.hpp"
#include "src/mc/remote/Client.hpp"
#include "src/kernel/activity/CommImpl.hpp"
#include "src/kernel/activity/ExecImpl.hpp"
+#include "src/kernel/activity/IoImpl.hpp"
#include "src/kernel/activity/SleepImpl.hpp"
-#include "src/kernel/activity/SynchroIo.hpp"
#include "src/kernel/activity/SynchroRaw.hpp"
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_popping, simix,
#include "mc/mc.h"
#include "simgrid/s4u/Engine.hpp"
#include "simgrid/s4u/Host.hpp"
+
+#include "../kernel/activity/IoImpl.hpp"
#include "simgrid/sg_config.hpp"
#include "smx_private.hpp"
#include "src/kernel/activity/SleepImpl.hpp"
-#include "src/kernel/activity/SynchroIo.hpp"
#include "src/kernel/activity/SynchroRaw.hpp"
#include "src/mc/mc_record.hpp"
#include "src/mc/mc_replay.hpp"
#include "simgrid/s4u/Host.hpp"
#include "simgrid/s4u/Storage.hpp"
+
#include "smx_private.hpp"
+#include "src/kernel/activity/IoImpl.hpp"
#include "src/simix/smx_io_private.hpp"
#include "src/surf/HostImpl.hpp"
#include "src/surf/StorageImpl.hpp"
#include "src/surf/surf_interface.hpp"
#include "surf/surf.hpp"
-#include "src/kernel/activity/SynchroIo.hpp"
-
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_io, simix, "Logging specific to SIMIX (io)");
void simcall_HANDLER_storage_read(smx_simcall_t simcall, surf_storage_t st, sg_size_t size)
smx_activity_t SIMIX_storage_read(surf_storage_t st, sg_size_t size)
{
simgrid::kernel::activity::IoImpl* synchro = new simgrid::kernel::activity::IoImpl();
- synchro->surf_io = st->read(size);
+ synchro->surf_action_ = st->read(size);
- synchro->surf_io->set_data(synchro);
+ synchro->surf_action_->set_data(synchro);
XBT_DEBUG("Create io synchro %p", synchro);
return synchro;
smx_activity_t SIMIX_storage_write(surf_storage_t st, sg_size_t size)
{
simgrid::kernel::activity::IoImpl* synchro = new simgrid::kernel::activity::IoImpl();
- synchro->surf_io = st->write(size);
- synchro->surf_io->set_data(synchro);
+ synchro->surf_action_ = st->write(size);
+ synchro->surf_action_->set_data(synchro);
XBT_DEBUG("Create io synchro %p", synchro);
return synchro;
{
simgrid::kernel::activity::IoImplPtr io = boost::static_pointer_cast<simgrid::kernel::activity::IoImpl>(synchro);
XBT_DEBUG("Destroy synchro %p", synchro.get());
- if (io->surf_io)
- io->surf_io->unref();
+ if (io->surf_action_)
+ io->surf_action_->unref();
}
void SIMIX_io_finish(smx_activity_t synchro)
src/kernel/activity/CommImpl.hpp
src/kernel/activity/ExecImpl.cpp
src/kernel/activity/ExecImpl.hpp
+ src/kernel/activity/IoImpl.cpp
+ src/kernel/activity/IoImpl.hpp
src/kernel/activity/MailboxImpl.cpp
src/kernel/activity/MailboxImpl.hpp
src/kernel/activity/MutexImpl.cpp
src/kernel/activity/MutexImpl.hpp
src/kernel/activity/SleepImpl.cpp
src/kernel/activity/SleepImpl.hpp
- src/kernel/activity/SynchroIo.cpp
- src/kernel/activity/SynchroIo.hpp
src/kernel/activity/SynchroRaw.cpp
src/kernel/activity/SynchroRaw.hpp