Merge pull request pmodels#7300 from hzhou/2502_sched_tag

hzhou · web-flow · commit c820cd680907 · 2025-02-13T12:08:32.000-06:00
mpid/sched: match communicator when checking tag space

Approved-by: Ken Raffenetti
diff --git a/src/mpid/common/sched/mpidu_sched.c b/src/mpid/common/sched/mpidu_sched.c
@@ -178,8 +178,10 @@ int MPIDU_Sched_next_tag(MPIR_Comm * comm_ptr, int *tag)
     if (start != MPI_UNDEFINED) {
         MPID_THREAD_CS_ENTER(VCI, MPIDIU_THREAD_SCHED_LIST_MUTEX);
         DL_FOREACH(all_schedules.head, elt) {
-            if (elt->tag >= start && elt->tag < end) {
-                MPIR_ERR_SETANDJUMP(mpi_errno, MPI_ERR_OTHER, "**toomanynbc");
+            if (comm_ptr == elt->req->comm) {
+                if (elt->tag >= start && elt->tag < end) {
+                    MPIR_ERR_SETANDJUMP(mpi_errno, MPI_ERR_OTHER, "**toomanynbc");
+                }
             }
         }
         MPID_THREAD_CS_EXIT(VCI, MPIDIU_THREAD_SCHED_LIST_MUTEX);

Original file line number	Diff line number	Diff line change
`@@ -178,8 +178,10 @@ int MPIDU_Sched_next_tag(MPIR_Comm * comm_ptr, int *tag)`
`178`	`178`	`if (start != MPI_UNDEFINED) {`
`179`	`179`	`MPID_THREAD_CS_ENTER(VCI, MPIDIU_THREAD_SCHED_LIST_MUTEX);`
`180`	`180`	`DL_FOREACH(all_schedules.head, elt) {`
`181`		`- if (elt->tag >= start && elt->tag < end) {`
`182`		`- MPIR_ERR_SETANDJUMP(mpi_errno, MPI_ERR_OTHER, "**toomanynbc");`
	`181`	`+ if (comm_ptr == elt->req->comm) {`
	`182`	`+ if (elt->tag >= start && elt->tag < end) {`
	`183`	`+ MPIR_ERR_SETANDJUMP(mpi_errno, MPI_ERR_OTHER, "**toomanynbc");`
	`184`	`+ }`
`183`	`185`	`}`
`184`	`186`	`}`
`185`	`187`	`MPID_THREAD_CS_EXIT(VCI, MPIDIU_THREAD_SCHED_LIST_MUTEX);`