@@ -432,6 +432,7 @@ static void reg_event_hdlr(int sd, short args, void *cbdata)
432
432
}
433
433
index = pmix_globals .events .nhdlrs ;
434
434
evhdlr -> index = index ;
435
+ ++ pmix_globals .events .nhdlrs ;
435
436
evhdlr -> rng .range = range ;
436
437
if (NULL != parray ) {
437
438
evhdlr -> rng .nprocs = nprocs ;
@@ -455,6 +456,7 @@ static void reg_event_hdlr(int sd, short args, void *cbdata)
455
456
goto ack ;
456
457
}
457
458
memcpy (evhdlr -> codes , cd -> codes , cd -> ncodes * sizeof (pmix_status_t ));
459
+ evhdlr -> ncodes = cd -> ncodes ;
458
460
}
459
461
if (firstoverall ) {
460
462
pmix_globals .events .first = evhdlr ;
@@ -502,6 +504,7 @@ static void reg_event_hdlr(int sd, short args, void *cbdata)
502
504
}
503
505
index = pmix_globals .events .nhdlrs ;
504
506
evhdlr -> index = index ;
507
+ ++ pmix_globals .events .nhdlrs ;
505
508
evhdlr -> precedence = location ;
506
509
evhdlr -> locator = locator ;
507
510
evhdlr -> rng .range = range ;
@@ -530,6 +533,7 @@ static void reg_event_hdlr(int sd, short args, void *cbdata)
530
533
goto ack ;
531
534
}
532
535
memcpy (evhdlr -> codes , cd -> codes , cd -> ncodes * sizeof (pmix_status_t ));
536
+ evhdlr -> ncodes = cd -> ncodes ;
533
537
if (1 == cd -> ncodes ) {
534
538
cd -> list = & pmix_globals .events .single_events ;
535
539
} else {
0 commit comments