Skip to content

Commit 3455256

Browse files
committed
lock before id gen
1 parent d8cb8ce commit 3455256

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/collectives.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -434,11 +434,11 @@ static void CmiClearNodeReduction(CmiReductionID id) {
434434

435435
// lock and unlock are used to support SMP
436436
void CmiNodeReduce(void *msg, int size, CmiReduceMergeFn mergeFn) {
437+
CmiLock(nodeRed.lock);
437438
const CmiReductionID id = CmiGetNextNodeReductionID();
438439

439440
CmiNodeReduction nodeRed =
440441
CsvAccess(_node_reduction_info)[CmiGetReductionIndex(id)];
441-
CmiLock(nodeRed.lock);
442442

443443
CmiReduction *red = CmiGetCreateNodeReduction(id);
444444
CmiInternalNodeReduce(msg, size, mergeFn, red);

0 commit comments

Comments
 (0)