X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1e83888c1aed0b9146b5ae78ad474f374d28a769..fa19d0ae9393f2f40864104eb2af3fa46015f1a2:/src/kernel/activity/CommImpl.hpp?ds=sidebyside diff --git a/src/kernel/activity/CommImpl.hpp b/src/kernel/activity/CommImpl.hpp index bbf350c10e..55828307c9 100644 --- a/src/kernel/activity/CommImpl.hpp +++ b/src/kernel/activity/CommImpl.hpp @@ -1,22 +1,22 @@ -/* Copyright (c) 2007-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2019. 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. */ -#ifndef SIMIX_SYNCHRO_COMM_HPP -#define SIMIX_SYNCHRO_COMM_HPP +#ifndef SIMGRID_KERNEL_ACTIVITY_COMM_HPP +#define SIMGRID_KERNEL_ACTIVITY_COMM_HPP #include "src/kernel/activity/ActivityImpl.hpp" -#include "surf/surf.h" +#include "src/simix/ActorImpl.hpp" +#include "surf/surf.hpp" -typedef enum { SIMIX_COMM_SEND, SIMIX_COMM_RECEIVE, SIMIX_COMM_READY, SIMIX_COMM_DONE } e_smx_comm_type_t; +enum e_smx_comm_type_t { SIMIX_COMM_SEND, SIMIX_COMM_RECEIVE, SIMIX_COMM_READY, SIMIX_COMM_DONE }; namespace simgrid { namespace kernel { namespace activity { -XBT_PUBLIC_CLASS CommImpl : public ActivityImpl -{ +class XBT_PUBLIC CommImpl : public ActivityImpl { ~CommImpl() override; public: @@ -39,29 +39,30 @@ public: bool detached = false; /* If detached or not */ void (*clean_fun)(void*) = nullptr; /* Function to clean the detached src_buf if something goes wrong */ - int (*match_fun)(void*, void*, smx_activity_t) = nullptr; /* Filter function used by the other side. It is used when - looking if a given communication matches my needs. For that, myself must match the - expectations of the other side, too. See */ + int (*match_fun)(void*, void*, simgrid::kernel::activity::CommImpl*) = + nullptr; /* Filter function used by the other side. It is used when +looking if a given communication matches my needs. For that, myself must match the +expectations of the other side, too. See */ void (*copy_data_fun)(smx_activity_t, void*, size_t) = nullptr; /* Surf action data */ - surf_action_t surf_comm = nullptr; /* The Surf communication action encapsulated */ - surf_action_t src_timeout = nullptr; /* Surf's actions to instrument the timeouts */ - surf_action_t dst_timeout = nullptr; /* Surf's actions to instrument the timeouts */ - smx_actor_t src_proc = nullptr; - smx_actor_t dst_proc = nullptr; - double rate = 0.0; - double task_size = 0.0; + resource::Action* surf_action_ = nullptr; /* The Surf communication action encapsulated */ + resource::Action* src_timeout_ = nullptr; /* Surf's actions to instrument the timeouts */ + resource::Action* dst_timeout_ = nullptr; /* Surf's actions to instrument the timeouts */ + actor::ActorImplPtr src_actor_ = nullptr; + actor::ActorImplPtr dst_actor_ = nullptr; + double rate_ = 0.0; + double task_size_ = 0.0; /* Data to be transfered */ - void* src_buff = nullptr; - void* dst_buff = nullptr; - size_t src_buff_size = 0; - size_t* dst_buff_size = nullptr; + void* src_buff_ = nullptr; + void* dst_buff_ = nullptr; + size_t src_buff_size_ = 0; + size_t* dst_buff_size_ = nullptr; bool copied = false; /* whether the data were already copied */ - void* src_data = nullptr; /* User data associated to communication */ - void* dst_data = nullptr; + void* src_data_ = nullptr; /* User data associated to the communication */ + void* dst_data_ = nullptr; }; } }