-/* Copyright (c) 2010-2021. 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. */
#include <memory>
-namespace simgrid{
-namespace smpi{
+namespace simgrid::smpi {
struct smpi_mpi_generalized_request_funcs_t {
MPI_Grequest_query_function *query_fn;
bool detached_;
MPI_Request detached_sender_;
int refcount_;
+ std::vector<unsigned int> message_id_;
MPI_Op op_;
std::unique_ptr<smpi_mpi_generalized_request_funcs_t> generalized_funcs;
std::vector<MPI_Request> nbc_requests_;
+ 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);
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();
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);
static Request* f2c(int);
};
-
-}
-}
+} // namespace simgrid::smpi
#endif