Skip to content
Snippets Groups Projects
Commit 0e1c1acf authored by Jammer, Tim's avatar Jammer, Tim
Browse files

fix which type is send and which one recv

parent 4f144486
No related branches found
No related tags found
No related merge requests found
...@@ -53,12 +53,12 @@ def get_correct_case(type_1, size_1, send_func, recv_func, comm): ...@@ -53,12 +53,12 @@ def get_correct_case(type_1, size_1, send_func, recv_func, comm):
comm_var_name = get_intercomm(comm, tm) comm_var_name = get_intercomm(comm, tm)
type_var_1, buf_name_1, type_var_2, buf_name_2 = get_type_buffers(tm, type_1, type_1, size_1, size_1) type_var_1, buf_name_1, type_var_2, buf_name_2 = get_type_buffers(tm, type_1, type_1, size_1, size_1)
call = tm.get_instruction(identifier="MPICALL", rank_excuting=0) call = tm.get_instruction(identifier="MPICALL", rank_excuting=1)
call.set_arg("buf", buf_name_1) call.set_arg("buf", buf_name_1)
call.set_arg("datatype", type_var_1) call.set_arg("datatype", type_var_1)
call.set_arg("count", size_1) call.set_arg("count", size_1)
call.set_arg("comm", comm_var_name) call.set_arg("comm", comm_var_name)
call = tm.get_instruction(identifier="MPICALL", rank_excuting=1) call = tm.get_instruction(identifier="MPICALL", rank_excuting=0)
call.set_arg("buf", buf_name_2) call.set_arg("buf", buf_name_2)
call.set_arg("datatype", type_var_2) call.set_arg("datatype", type_var_2)
call.set_arg("count", size_1) call.set_arg("count", size_1)
...@@ -79,13 +79,13 @@ def get_global_missmatch(type_1, type_2, size_1, size_2, send_func, recv_func, c ...@@ -79,13 +79,13 @@ def get_global_missmatch(type_1, type_2, size_1, size_2, send_func, recv_func, c
comm_var_name = get_intercomm(comm, tm) comm_var_name = get_intercomm(comm, tm)
type_var_1, buf_name_1, type_var_2, buf_name_2 = get_type_buffers(tm, type_1, type_2, size_1, size_2) type_var_1, buf_name_1, type_var_2, buf_name_2 = get_type_buffers(tm, type_1, type_2, size_1, size_2)
call = tm.get_instruction(identifier="MPICALL", rank_excuting=0) call = tm.get_instruction(identifier="MPICALL", rank_excuting=1)
call.set_has_error() call.set_has_error()
call.set_arg("buf", buf_name_1) call.set_arg("buf", buf_name_1)
call.set_arg("datatype", type_var_1) call.set_arg("datatype", type_var_1)
call.set_arg("count", size_1) call.set_arg("count", size_1)
call.set_arg("comm", comm_var_name) call.set_arg("comm", comm_var_name)
call = tm.get_instruction(identifier="MPICALL", rank_excuting=1) call = tm.get_instruction(identifier="MPICALL", rank_excuting=0)
call.set_has_error() call.set_has_error()
call.set_arg("buf", buf_name_2) call.set_arg("buf", buf_name_2)
call.set_arg("datatype", type_var_2) call.set_arg("datatype", type_var_2)
...@@ -196,6 +196,7 @@ class DtypeMissmatch(ErrorGenerator): ...@@ -196,6 +196,7 @@ class DtypeMissmatch(ErrorGenerator):
correct_types_checked = set() correct_types_checked = set()
for type_1, type_2, send_func, recv_func, comm in combinations_to_use: for type_1, type_2, send_func, recv_func, comm in combinations_to_use:
# local missmatch only for one communicator # local missmatch only for one communicator
if comm == "MPI_COMM_WORLD": if comm == "MPI_COMM_WORLD":
yield get_local_missmatch(type_1, type_2, send_func, recv_func) yield get_local_missmatch(type_1, type_2, send_func, recv_func)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment