X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ea74f5d95928a521a588737e81f1de94eef25d19..8bf7ffc43ad5507982e924a7f05bbb13c89965cb:/src/smpi/include/smpi_request.hpp diff --git a/src/smpi/include/smpi_request.hpp b/src/smpi/include/smpi_request.hpp index e3a30898a3..9b0a6ccab9 100644 --- a/src/smpi/include/smpi_request.hpp +++ b/src/smpi/include/smpi_request.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2010-2022. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2010-2023. 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. */ @@ -11,8 +11,7 @@ #include -namespace simgrid{ -namespace smpi{ +namespace simgrid::smpi { struct smpi_mpi_generalized_request_funcs_t { MPI_Grequest_query_function *query_fn; @@ -48,10 +47,11 @@ class Request : public F2C { bool detached_; MPI_Request detached_sender_; int refcount_; + std::vector message_id_; MPI_Op op_; std::unique_ptr generalized_funcs; std::vector nbc_requests_; - s4u::Host* src_host_ = nullptr; //!< save simgrid's source host since it can finished before the recv + s4u::Host* src_host_ = nullptr; //!< save SimGrid's source host since it can finished before the recv static bool match_common(MPI_Request req, MPI_Request sender, MPI_Request receiver); static bool match_types(MPI_Datatype stype, MPI_Datatype rtype); @@ -67,7 +67,7 @@ public: int tag() const { return tag_; } int flags() const { return flags_; } bool detached() const { return detached_; } - std::string name() const override { return std::string("MPI_Request"); } + std::string name() const override { return "MPI_Request"; } MPI_Datatype type() const { return type_; } void print_request(const char* message) const; void start(); @@ -102,6 +102,8 @@ public: static void sendrecv(const void* sendbuf, int sendcount, MPI_Datatype sendtype, int dst, int sendtag, void* recvbuf, int recvcount, MPI_Datatype recvtype, int src, int recvtag, MPI_Comm comm, MPI_Status* status); + static void isendrecv(const void* sendbuf, int sendcount, MPI_Datatype sendtype, int dst, int sendtag, void* recvbuf, + int recvcount, MPI_Datatype recvtype, int src, int recvtag, MPI_Comm comm, MPI_Request* request); static void startall(int count, MPI_Request* requests); @@ -128,8 +130,6 @@ public: static Request* f2c(int); }; - -} -} +} // namespace simgrid::smpi #endif