P2P

P2P cases: Includes all basic P2P cases in MBI and COBE with the following exceptions:

• No Datatype/count related cases
• No Missing/Init-Finalize cases (which where classified as P2P in cobe)
• No P2P + COLL and P2P + RMA cases from MBI
• no OpenMP cases from cobe

Apart from these cases, all P2P errors should be covered

scripts/errors/pt2pt/LocalConcurrency.py

 #! /usr/bin/python3
 
 from scripts.Infrastructure.ErrorGenerator import ErrorGenerator
+from scripts.Infrastructure.Instruction import Instruction
 from scripts.Infrastructure.InstructionBlock import InstructionBlock
 from scripts.Infrastructure.MPICallFactory import MPICallFactory, CorrectMPICallFactory
 from scripts.Infrastructure.CorrectParameter import CorrectParameterFactory, get_matching_recv
@@ -18,9 +19,9 @@ class LocalConcurrencyErrorP2P(ErrorGenerator):
     functions_to_check = ["mpi_irecv",
                           "mpi_isend", "mpi_issend", "mpi_irsend", "mpi_ibsend",
                           "mpi_send_init", "mpi_ssend_init", "mpi_bsend_init", "mpi_rsend_init", "mpi_psend_init",
-                          "mpi_precv_init", "mpi_recv_init"
+                          "mpi_precv_init", "mpi_recv_init", "mpi_imrecv"
                           ]
-    recv_funcs = ["mpi_irecv", "mpi_recv_init", "mpi_precv_init"]
+    recv_funcs = ["mpi_irecv", "mpi_recv_init", "mpi_precv_init", "mpi_imrecv"]
 
     def __init__(self):
         pass
@@ -38,7 +39,10 @@ class LocalConcurrencyErrorP2P(ErrorGenerator):
                 recv_func = send_func
                 send_func = "mpi_isend"
 
-            tm = get_send_recv_template(send_func, recv_func)
+            recv_func_to_use = recv_func
+            if recv_func == "mpi_imrecv":
+                recv_func_to_use = ["mpi_mprobe", "mpi_imrecv"]
+            tm = get_send_recv_template(send_func, recv_func_to_use)
 
             if check_receive:
                 tm.set_description("LocalConcurrency-receive-" + recv_func,
@@ -47,12 +51,16 @@ class LocalConcurrencyErrorP2P(ErrorGenerator):
                 tm.set_description("LocalConcurrency-send-" + send_func,
                                    "usage of send buffer before operation is completed")
 
+            conflicting_inst = Instruction("buf[2]=1;")
+            conflicting_inst.set_has_error()
+            kind = 1
             if check_receive:
-                tm.get_block("MPICALL").get_instruction(kind=0, index=0).set_has_error()
-                tm.get_block("MPICALL").register_instruction("buf[2]=1;" + ERROR_MARKER_COMMENT, kind=1)
-            else:
-                tm.get_block("MPICALL").get_instruction(kind=1, index=0).set_has_error()
-                tm.get_block("MPICALL").register_instruction("buf[2]=1;" + ERROR_MARKER_COMMENT, kind=1)
+                kind = 0
+            idx = 0
+            if recv_func == "mpi_imrecv":
+                idx = 1
+            tm.get_block("MPICALL").get_instruction(kind=kind, index=idx).set_has_error()
+            tm.get_block("MPICALL").register_instruction(conflicting_inst, kind=kind)
 
             yield tm
             if not generate_full_set: