diff --git a/bin/tools/foamCreateCompletionCache b/bin/tools/foamCreateCompletionCache
index 7cc535afd9af04efe3dadd4674f171f376616649..51d67d159fd71f5c383b0716f34744c94662f25f 100755
--- a/bin/tools/foamCreateCompletionCache
+++ b/bin/tools/foamCreateCompletionCache
@@ -6,7 +6,7 @@
# \\ / A nd | www.openfoam.com
# \\/ M anipulation |
#------------------------------------------------------------------------------
-# Copyright (C) 2017-2023 OpenCFD Ltd.
+# Copyright (C) 2017-2025 OpenCFD Ltd.
#------------------------------------------------------------------------------
# License
# This file is part of OpenFOAM, distributed under GPL-3.0-or-later.
@@ -168,6 +168,7 @@ extractOptions()
-e '/^-doc-source/d; /^-help-man/d;' \
-e '/^-hostRoots /d; /^-roots /d;' \
-e '/^-lib /d; /^-no-libs /d;' \
+ -e '/^-mpi-.*/d;' \
-e '/^-[a-z]*-switch /d;' \
-e 'y/,/ /; s/=.*$/=/;' \
-e '/^-[^ ]* </{ s/^\(-[^ ]* <\).*$/\1/; p; d }' \
diff --git a/bin/tools/help-filter b/bin/tools/help-filter
index df91b04d15de76c32342a215df4430efcef90c3b..4d68ea06c0c72bf9596c11e47ba1a63545101871 100755
--- a/bin/tools/help-filter
+++ b/bin/tools/help-filter
@@ -28,6 +28,7 @@ sed -ne '1,/^[Oo]ptions:/d' \
-e '/^-doc-source/d; /^-help-man/d;' \
-e '/^-hostRoots /d; /^-roots /d;' \
-e '/^-lib /d; /^-no-libs /d;' \
+ -e '/^-mpi-.*/d;' \
-e '/^-[a-z]*-switch /d;' \
-e 'y/,/ /; s/=.*$/=/;' \
-e '/^-[^ ]* </{ s/^\(-[^ ]* <\).*$/\1/; p; d }' \
diff --git a/src/OpenFOAM/global/argList/argList.C b/src/OpenFOAM/global/argList/argList.C
index d04c26860aa200608448048a8fb655c5abac7266..65a7625387aefc6f873e4be4f2a8d2f494f18f09 100644
--- a/src/OpenFOAM/global/argList/argList.C
+++ b/src/OpenFOAM/global/argList/argList.C
@@ -192,6 +192,18 @@ Foam::argList::initValidTables::initValidTables()
"name"
);
+ argList::addBoolOption
+ (
+ "mpi-split-by-appnum",
+ "Split world communicator based on the APPNUM",
+ true // advanced option
+ );
+ validParOptions.set
+ (
+ "mpi-split-by-appnum",
+ ""
+ );
+
// Some standard option aliases (with or without version warnings)
// argList::addOptionCompat
diff --git a/src/Pstream/mpi/UPstream.C b/src/Pstream/mpi/UPstream.C
index 1b051b072fb2d20c3583dd8e591edaf3ae14b557..d6a359267e05b0b8d9da17103cd82199497cd7b5 100644
--- a/src/Pstream/mpi/UPstream.C
+++ b/src/Pstream/mpi/UPstream.C
@@ -261,34 +261,54 @@ bool Foam::UPstream::init(int& argc, char**& argv, const bool needsThread)
PstreamGlobals::printDataTypes();
}
+ // Check argument list for local world and/or split-by-appnum
+ // - Extract world name and filter out '-world <name>' from argv list
+ // - Filter out '-mpi-split-by-appnum' from argv list
+
+ word worldName;
+ bool split_by_appnum = false;
- // Check argument list for local world
- label worldIndex = -1;
for (int argi = 1; argi < argc; ++argi)
{
if (strcmp(argv[argi], "-world") == 0)
{
- worldIndex = argi;
if (argi+1 >= argc)
{
FatalErrorInFunction
<< "Missing world name for option '-world'" << nl
<< Foam::abort(FatalError);
}
- break;
+ worldName = argv[argi+1];
+
+ // Remove two arguments (-world name)
+ for (int i = argi+2; i < argc; ++i)
+ {
+ argv[i-2] = argv[i];
+ }
+ --argi; // re-examine
+ argc -= 2;
+ }
+ else if (strcmp(argv[argi], "-mpi-split-by-appnum") == 0)
+ {
+ split_by_appnum = true;
+
+ // Remove one argument
+ for (int i = argi+1; i < argc; ++i)
+ {
+ argv[i-1] = argv[i];
+ }
+ --argi; // re-examine
+ --argc;
}
}
- // Extract world name and filter out '-world <name>' from argv list
- word worldName;
- if (worldIndex != -1)
+ const bool hasLocalWorld(!worldName.empty());
+
+ if (hasLocalWorld && split_by_appnum)
{
- worldName = argv[worldIndex+1];
- for (label i = worldIndex+2; i < argc; i++)
- {
- argv[i-2] = argv[i];
- }
- argc -= 2;
+ FatalErrorInFunction
+ << "Cannot specify both -world and -mpi-split-by-appnum" << nl
+ << Foam::abort(FatalError);
}
int numProcs = 0, globalRanki = 0;
@@ -314,7 +334,7 @@ bool Foam::UPstream::init(int& argc, char**& argv, const bool needsThread)
<< " world:" << worldName << endl;
}
- if (worldIndex == -1 && numProcs <= 1)
+ if (numProcs <= 1 && !(hasLocalWorld || split_by_appnum))
{
FatalErrorInFunction
<< "attempt to run parallel on 1 processor"
@@ -324,7 +344,7 @@ bool Foam::UPstream::init(int& argc, char**& argv, const bool needsThread)
// Initialise parallel structure
setParRun(numProcs, provided_thread_support == MPI_THREAD_MULTIPLE);
- if (worldIndex != -1)
+ if (hasLocalWorld)
{
// Using local worlds.
// During startup, so commWorld() == commGlobal()
@@ -333,7 +353,7 @@ bool Foam::UPstream::init(int& argc, char**& argv, const bool needsThread)
// Gather the names of all worlds and determine unique names/indices.
//
- // Minimize communication and use low-level MPI to relying on any
+ // Minimize communication and use low-level MPI to avoid relying on any
// OpenFOAM structures which not yet have been created
{
@@ -452,6 +472,107 @@ bool Foam::UPstream::init(int& argc, char**& argv, const bool needsThread)
Pout.prefix() = '[' + worldName + '/' + Foam::name(worldRanki) + "] ";
Perr.prefix() = Pout.prefix();
}
+ else if (split_by_appnum)
+ {
+ // Using APPNUM
+ // During startup, so commWorld() == commGlobal()
+ const auto mpiGlobalComm =
+ PstreamGlobals::MPICommunicators_[UPstream::commGlobal()];
+
+ int myAppNum(0);
+
+ {
+ void* val;
+ int flag;
+
+ MPI_Comm_get_attr(mpiGlobalComm, MPI_APPNUM, &val, &flag);
+ if (flag)
+ {
+ myAppNum = *static_cast<int*>(val);
+ }
+ else
+ {
+ myAppNum = 0;
+ Perr<< "UPstream::init : used -mpi-split-by-appnum "
+ << " with a single application!!" << endl;
+ }
+ }
+
+ // Gather the appnum and determine unique values
+ //
+ // Minimize communication and use low-level MPI to avoid relying on any
+ // OpenFOAM structures which not yet have been created
+
+ List<int> allAppNum(numProcs);
+ allAppNum[globalRanki] = myAppNum;
+
+ // Gather everything
+ MPI_Allgather
+ (
+ MPI_IN_PLACE, 0, MPI_INT,
+ allAppNum.data(), 1, MPI_INT,
+ mpiGlobalComm
+ );
+
+ DynamicList<label> subRanks;
+ forAll(allAppNum, proci)
+ {
+ if (allAppNum[proci] == myAppNum)
+ {
+ subRanks.push_back(proci);
+ }
+ }
+
+ // New world communicator with comm-global as its parent.
+ // - the updated (const) world comm does not change after this.
+
+ UPstream::constWorldComm_ =
+ UPstream::newCommunicator(UPstream::commGlobal(), subRanks);
+
+ UPstream::worldComm = UPstream::constWorldComm_;
+ UPstream::warnComm = UPstream::constWorldComm_;
+
+ const int worldRanki = UPstream::myProcNo(UPstream::constWorldComm_);
+
+ // MPI_COMM_SELF : the processor number wrt the new world communicator
+ if (procIDs_[UPstream::commSelf()].size())
+ {
+ procIDs_[UPstream::commSelf()].front() = worldRanki;
+ }
+
+ // Name the old world communicator as '<openfoam:global>'
+ // - it is the inter-world communicator
+ if (MPI_COMM_NULL != mpiGlobalComm)
+ {
+ MPI_Comm_set_name(mpiGlobalComm, "<openfoam:global>");
+ }
+
+ const auto mpiWorldComm =
+ PstreamGlobals::MPICommunicators_[UPstream::constWorldComm_];
+
+ const word commName("app=" + Foam::name(myAppNum));
+
+ if (MPI_COMM_NULL != mpiWorldComm)
+ {
+ MPI_Comm_set_name(mpiWorldComm, commName.data());
+ }
+
+ if (UPstream::debug)
+ {
+ // Check
+ int newRanki, newSize;
+ MPI_Comm_rank(mpiWorldComm, &newRanki);
+ MPI_Comm_size(mpiWorldComm, &newSize);
+
+ Perr<< "UPstream::init : app:" << myAppNum
+ << " using local communicator:" << constWorldComm_
+ << " rank " << newRanki << " of " << newSize << endl;
+ }
+
+ // Override Pout prefix (move to setParRun?)
+ Pout.prefix() = '[' + commName + '/' + Foam::name(worldRanki) + "] ";
+ Perr.prefix() = Pout.prefix();
+ }
else
{
// All processors use world 0