Skip to content

Commit 98ac213

Browse files
Fix mapper map_task for DCR shard case.
1 parent 94033b6 commit 98ac213

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/mapper.cc

+4-1
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,10 @@ void FuzzMapper::map_task(const MapperContext ctx, const Task &task,
126126
log_map.debug() << "map_task: Selected variant " << output.chosen_variant;
127127

128128
// TODO: assign to variant's correct processor kind
129-
if (rng.uniform_range(0, 1) == 0) {
129+
if (input.shard_processor.exists()) {
130+
log_map.debug() << "map_task: Mapping to shard proc";
131+
output.target_procs.push_back(input.shard_processor);
132+
} else if (rng.uniform_range(0, 1) == 0) {
130133
log_map.debug() << "map_task: Mapping to all local procs";
131134
output.target_procs.insert(output.target_procs.end(), local_procs.begin(),
132135
local_procs.end());

0 commit comments

Comments
 (0)