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/Infrastructure/CorrectParameter.py

@@ -17,18 +17,19 @@ class CorrectParameterFactory:
     def __init__(self):
         pass
 
-    def get_buffer_alloc(self)-> AllocCall:
+    def get_buffer_alloc(self) -> AllocCall:
         return AllocCall(self.dtype[0], self.buf_size, self.buf_var_name, use_malloc=False)
 
-    def get_buffer_free(self)->Instruction:
+    def get_buffer_free(self) -> Instruction:
         return get_free(AllocCall(self.dtype[0], self.buf_size, self.buf_var_name, use_malloc=False))
 
-    def get(self, param:str)->str:
+    def get(self, param: str) -> str:
         if param in ["BUFFER", "buf", "buffer", "sendbuf", "recvbuf", "origin_addr"]:
             return self.buf_var_name
         if param in ["COUNT", "count", "sendcount", "recvcount", "origin_count", "target_count", "result_count"]:
             return str(self.buf_size)
-        if param in ["DATATYPE", "datatype", "sendtype", "recvtype", "origin_datatype", "target_datatype", "result_datatype"]:
+        if param in ["DATATYPE", "datatype", "sendtype", "recvtype", "origin_datatype", "target_datatype",
+                     "result_datatype"]:
             return self.dtype[1]
         if param in ["DEST", "dest", "target_rank"]:
             return "0"
@@ -99,9 +100,18 @@ class CorrectParameterFactory:
         print("Not Implemented: " + param)
         assert False, "Param not known"
 
+    def get_initializer(self, variable_type: str) -> str:
+        if variable_type == "int":
+            return "0"
+        if variable_type == "MPI_Request":
+            return "MPI_REQUEST_NULL"
+        # TODO implement other types
+        print("Not Implemented: " + variable_type)
+        assert False, "Param not known"
+
 
 # todo also for send and non default args
-def get_matching_recv(call:MPICall)->MPICall:
+def get_matching_recv(call: MPICall) -> MPICall:
     correct_params = CorrectParameterFactory()
     recv = MPICallFactory().mpi_recv(
         correct_params.get("BUFFER"),
@@ -113,4 +123,4 @@ def get_matching_recv(call:MPICall)->MPICall:
         correct_params.get("STATUS", "MPI_Recv"),
     )
 
-    return recv
+    return recv
\ No newline at end of file