X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/21fe278c8460849931b37ccde22e944edec46f71..b6dde5ff6f208b83545a4b4e9e81712d0d8617a1:/src/smpi/include/smpi_request.hpp diff --git a/src/smpi/include/smpi_request.hpp b/src/smpi/include/smpi_request.hpp index cc6458393c..7196af7eb1 100644 --- a/src/smpi/include/smpi_request.hpp +++ b/src/smpi/include/smpi_request.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2010-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2010-2020. 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. */ @@ -41,7 +41,7 @@ class Request : public F2C { bool truncated_; size_t real_size_; MPI_Comm comm_; - smx_activity_t action_; + simgrid::kernel::activity::ActivityImplPtr action_; unsigned flags_; bool detached_; MPI_Request detached_sender_; @@ -51,6 +51,7 @@ class Request : public F2C { smpi_mpi_generalized_request_funcs generalized_funcs; MPI_Request* nbc_requests_; int nbc_requests_size_; + static bool match_common(MPI_Request req, MPI_Request sender, MPI_Request receiver); public: Request() = default; @@ -111,12 +112,12 @@ public: static int waitall(int count, MPI_Request requests[], MPI_Status status[]); static int waitsome(int incount, MPI_Request requests[], int* indices, MPI_Status status[]); - static int match_send(void* a, void* b, kernel::activity::CommImpl* ignored); - static int match_recv(void* a, void* b, kernel::activity::CommImpl* ignored); + static bool match_send(void* a, void* b, kernel::activity::CommImpl* ignored); + static bool match_recv(void* a, void* b, kernel::activity::CommImpl* ignored); static int grequest_start( MPI_Grequest_query_function *query_fn, MPI_Grequest_free_function *free_fn, MPI_Grequest_cancel_function *cancel_fn, void *extra_state, MPI_Request *request); static int grequest_complete( MPI_Request request); - static int get_status(MPI_Request req, int* flag, MPI_Status * status); + static int get_status(const Request* req, int* flag, MPI_Status* status); static void free_f(int id); static Request* f2c(int);