X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/bff0c1c16b4447b3503aa48d11b15243154ed51a..a844d6ba059b98ad6a5317e85a9c69402353b0a9:/include/simgrid/s4u/comm.hpp diff --git a/include/simgrid/s4u/comm.hpp b/include/simgrid/s4u/comm.hpp index 891d3000bd..1083fbe2ae 100644 --- a/include/simgrid/s4u/comm.hpp +++ b/include/simgrid/s4u/comm.hpp @@ -1,5 +1,4 @@ -/* Copyright (c) 2006-2015. The SimGrid Team. - * All rights reserved. */ +/* Copyright (c) 2006-2016. 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. */ @@ -30,18 +29,18 @@ public: public: - /*! tanke a range of s4u::Comm* (last excluded) and return when one of them is finished. The return value is an iterator on the finished Comms. */ + /*! take a range of s4u::Comm* (last excluded) and return when one of them is finished. The return value is an iterator on the finished Comms. */ template static I wait_any(I first, I last) { // Map to dynar: - xbt_dynar_t comms = xbt_dynar_new(sizeof(simgrid::simix::Synchro*), NULL); + xbt_dynar_t comms = xbt_dynar_new(sizeof(simgrid::kernel::activity::ActivityImpl*), NULL); for(I iter = first; iter != last; iter++) { Comm& comm = **iter; if (comm.state_ == inited) comm.start(); xbt_assert(comm.state_ == started); - xbt_dynar_push_as(comms, simgrid::simix::Synchro*, comm.pimpl_); + xbt_dynar_push_as(comms, simgrid::kernel::activity::ActivityImpl*, comm.pimpl_); } // Call the underlying simcall: int idx = simcall_comm_waitany(comms, -1); @@ -59,13 +58,13 @@ public: I wait_any_for(I first, I last, double timeout) { // Map to dynar: - xbt_dynar_t comms = xbt_dynar_new(sizeof(simgrid::simix::Synchro*), NULL); + xbt_dynar_t comms = xbt_dynar_new(sizeof(simgrid::kernel::activity::ActivityImpl*), NULL); for(I iter = first; iter != last; iter++) { Comm& comm = **iter; if (comm.state_ == inited) comm.start(); xbt_assert(comm.state_ == started); - xbt_dynar_push_as(comms, simgrid::simix::Synchro*, comm.pimpl_); + xbt_dynar_push_as(comms, simgrid::kernel::activity::ActivityImpl*, comm.pimpl_); } // Call the underlying simcall: int idx = simcall_comm_waitany(comms, timeout); @@ -120,9 +119,9 @@ private: /* FIXME: expose these elements in the API */ int detached_ = 0; - int (*matchFunction_)(void *, void *, smx_synchro_t) = nullptr; + int (*matchFunction_)(void *, void *, smx_activity_t) = nullptr; void (*cleanFunction_)(void *) = nullptr; - void (*copyDataFunction_)(smx_synchro_t, void*, size_t) = nullptr; + void (*copyDataFunction_)(smx_activity_t, void*, size_t) = nullptr; smx_process_t sender_ = nullptr; smx_process_t receiver_ = nullptr;