Tmp: Ignore unreachable endpoints in UCX

franzpoeschel · franzpoeschel · commit ca621d22e03b · 2024-04-04T11:44:33.000-04:00
Todo: Better than doing this, initialize endpoints on demand only
diff --git a/source/adios2/toolkit/sst/dp/ucx_dp.c b/source/adios2/toolkit/sst/dp/ucx_dp.c
@@ -397,9 +397,8 @@ static void UcxProvideWriterDataToReader(CP_Services Svcs, DP_RS_Stream RS_Strea
         if (status != UCS_OK)
         {
             Svcs->verbose(RS_Stream->CP_Stream, DPCriticalVerbose,
-                          "UCX Error during ucp_ep_create() with: %s.\n",
+                          "UCX Error during ucp_ep_create() with: %s. Let's ignore....\n",
                           ucs_status_string(status));
-            return;
         }
         Svcs->verbose(RS_Stream->CP_Stream, DPTraceVerbose,
                       "Received contact info for WS_stream %p, WSR Rank %d\n",

Original file line number	Diff line number	Diff line change
`@@ -397,9 +397,8 @@ static void UcxProvideWriterDataToReader(CP_Services Svcs, DP_RS_Stream RS_Strea`
`397`	`397`	`if (status != UCS_OK)`
`398`	`398`	`{`
`399`	`399`	`Svcs->verbose(RS_Stream->CP_Stream, DPCriticalVerbose,`
`400`		`- "UCX Error during ucp_ep_create() with: %s.\n",`
	`400`	`+ "UCX Error during ucp_ep_create() with: %s. Let's ignore....\n",`
`401`	`401`	`ucs_status_string(status));`
`402`		`- return;`
`403`	`402`	`}`
`404`	`403`	`Svcs->verbose(RS_Stream->CP_Stream, DPTraceVerbose,`
`405`	`404`	`"Received contact info for WS_stream %p, WSR Rank %d\n",`