public:
BoostSerialContext(std::function<void()> code,
void_pfn_smxprocess_t cleanup_func,
- smx_process_t process)
+ smx_actor_t process)
: BoostContext(std::move(code), cleanup_func, process) {}
void stop() override;
void suspend() override;
public:
BoostParallelContext(std::function<void()> code,
void_pfn_smxprocess_t cleanup_func,
- smx_process_t process)
+ smx_actor_t process)
: BoostContext(std::move(code), cleanup_func, process) {}
void stop() override;
void suspend() override;
}
smx_context_t BoostContextFactory::create_context(std::function<void()> code,
- void_pfn_smxprocess_t cleanup_func, smx_process_t process)
+ void_pfn_smxprocess_t cleanup_func, smx_actor_t process)
{
BoostContext* context = nullptr;
if (BoostContext::parallel_)
BoostContext::threads_working_ = 0;
xbt_parmap_apply(BoostContext::parmap_,
[](void* arg) {
- smx_process_t process = static_cast<smx_process_t>(arg);
+ smx_actor_t process = static_cast<smx_actor_t>(arg);
BoostContext* context = static_cast<BoostContext*>(process->context);
return context->resume();
},
{
if (xbt_dynar_is_empty(simix_global->process_to_run))
return;
- smx_process_t first_process =
- xbt_dynar_get_as(simix_global->process_to_run, 0, smx_process_t);
+ smx_actor_t first_process =
+ xbt_dynar_get_as(simix_global->process_to_run, 0, smx_actor_t);
BoostContext::process_index_ = 1;
/* execute the first process */
static_cast<BoostContext*>(first_process->context)->resume();
}
BoostContext::BoostContext(std::function<void()> code,
- void_pfn_smxprocess_t cleanup_func, smx_process_t process)
+ void_pfn_smxprocess_t cleanup_func, smx_actor_t process)
: Context(std::move(code), cleanup_func, process)
{
/* execute the next process */
XBT_DEBUG("Run next process");
next_context = static_cast<BoostSerialContext*>(xbt_dynar_get_as(
- simix_global->process_to_run, i, smx_process_t)->context);
+ simix_global->process_to_run, i, smx_actor_t)->context);
}
else {
/* all processes were run, return to maestro */
void BoostParallelContext::suspend()
{
- smx_process_t next_work = (smx_process_t) xbt_parmap_next(parmap_);
+ smx_actor_t next_work = (smx_actor_t) xbt_parmap_next(parmap_);
BoostParallelContext* next_context = nullptr;
if (next_work != nullptr) {