Logo AND Algorithmique Numérique Distribuée

Public GIT Repository
The eager limit size itself is part of the RDV protocol.
authorpini <pini@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Fri, 7 May 2010 15:55:38 +0000 (15:55 +0000)
committerpini <pini@48e7efb5-ca39-0410-a469-dd3cf9ba447f>
Fri, 7 May 2010 15:55:38 +0000 (15:55 +0000)
git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@7723 48e7efb5-ca39-0410-a469-dd3cf9ba447f

src/smpi/smpi_base.c

index aeed260..2e192a0 100644 (file)
@@ -61,7 +61,7 @@ static MPI_Request build_request(void* buf, int count, MPI_Datatype datatype, in
   request->complete = 0;
   request->match = MPI_REQUEST_NULL;
   request->flags = flags;
   request->complete = 0;
   request->match = MPI_REQUEST_NULL;
   request->flags = flags;
-  if(request->size <= EAGER_LIMIT) {
+  if(request->size < EAGER_LIMIT) {
     request->ack = MPI_REQUEST_NULL;
   } else {
     request->ack = xbt_new(s_smpi_mpi_request_t, 1);
     request->ack = MPI_REQUEST_NULL;
   } else {
     request->ack = xbt_new(s_smpi_mpi_request_t, 1);
@@ -96,7 +96,7 @@ MPI_Request smpi_mpi_recv_init(void* buf, int count, MPI_Datatype datatype, int
 
 void smpi_mpi_start(MPI_Request request) {
   xbt_assert0(request->complete == 0, "Cannot start a non-finished communication");
 
 void smpi_mpi_start(MPI_Request request) {
   xbt_assert0(request->complete == 0, "Cannot start a non-finished communication");
-  if(request->size > EAGER_LIMIT) {
+  if(request->size >= EAGER_LIMIT) {
     print_request("RDV ack", request->ack);
     smpi_mpi_wait(&request->ack, MPI_STATUS_IGNORE);
   }
     print_request("RDV ack", request->ack);
     smpi_mpi_wait(&request->ack, MPI_STATUS_IGNORE);
   }