Skip to content
Snippets Groups Projects

RMA Test Cases

Open Simon Schwitanski requested to merge rma into main
@@ -61,30 +61,15 @@ class LocalConcurrencyErrorRMA(ErrorGenerator):
@@ -61,30 +61,15 @@ class LocalConcurrencyErrorRMA(ErrorGenerator):
cf = CorrectParameterFactory()
cf = CorrectParameterFactory()
cfmpi = CorrectMPICallFactory()
cfmpi = CorrectMPICallFactory()
mpi_buf_read = [
"mpi_put",
"mpi_rput",
"mpi_accumulate",
"mpi_raccumulate",
"mpi_get_accumulate",
"mpi_rget_accumulate",
"mpi_fetch_and_op",
"mpi_compare_and_swap"
]
mpi_buf_write = ["mpi_get", "mpi_rget"]
# 7 possible combinations of local buffer accesses (hasconflict = True | False)
# 7 possible combinations of local buffer accesses (hasconflict = True | False)
local_access_combinations: List[Tuple[List[str], List[str], bool]] = [
local_access_combinations: List[Tuple[List[str], List[str], bool]] = [
(mpi_buf_read, ["bufread"], False),
(self.local_origin_addr_read, ["bufread"], False),
(mpi_buf_read, ["bufwrite"], True),
(self.local_origin_addr_read, ["bufwrite"], True),
(mpi_buf_write, ["bufread"], True),
(self.local_origin_addr_write, ["bufread"], True),
(mpi_buf_write, ["bufwrite"], True),
(self.local_origin_addr_write, ["bufwrite"], True),
(mpi_buf_read, mpi_buf_read, False),
(self.local_origin_addr_read, self.local_origin_addr_read, False),
(mpi_buf_read, mpi_buf_write, True),
(self.local_origin_addr_read, self.local_origin_addr_write, True),
(mpi_buf_write, mpi_buf_write, True),
(self.local_origin_addr_write, self.local_origin_addr_write, True),
]
]
for ops1, ops2, hasconflict in local_access_combinations:
for ops1, ops2, hasconflict in local_access_combinations:
Loading