0fabbcb404
- since ensight format is always float and also always written component-wise, perform the double -> float narrowing when extracting the components. This reduces the amount of data transferred between processors. ENH: avoid vtk/ensight parallel communication of empty messages - since ensight writes by element type (eg, tet, hex, polyhedral) the individual written field sections will tend to be relatively sparse. Skip zero-size messages, which should help reduce some of the synchronization bottlenecks. ENH: use 'data chunking' when writing ensight files in parallel - since ensight fields are written on a per-element basis, the corresponding segment can become rather sparsely distributed. With 'data chunking', we attempt to get as many send/recv messages in before flushing the buffer for writing. This should make the sequential send/recv less affected by the IO time. ENH: allow use of an external buffer when writing ensight components STYLE: remove last vestiges of autoPtr<ensightFile> for output routines
133 lines
4.8 KiB
C
133 lines
4.8 KiB
C
/*---------------------------------------------------------------------------*\
|
|
========= |
|
|
\\ / F ield | OpenFOAM: The Open Source CFD Toolbox
|
|
\\ / O peration |
|
|
\\ / A nd | www.openfoam.com
|
|
\\/ M anipulation |
|
|
-------------------------------------------------------------------------------
|
|
Copyright (C) 2018-2022 OpenCFD Ltd.
|
|
-------------------------------------------------------------------------------
|
|
License
|
|
This file is part of OpenFOAM, distributed under GPL-3.0-or-later.
|
|
|
|
Description
|
|
Code chunk for post-processing conversion of cloud(s) to Ensight
|
|
|
|
\*---------------------------------------------------------------------------*/
|
|
|
|
// Cloud field data output
|
|
if (doLagrangian)
|
|
{
|
|
// Lagrangian
|
|
const auto& cloudFields = regionCloudFields[regioni];
|
|
const auto& cloudNames = regionCloudNames[regioni];
|
|
|
|
for (const word& cloudName : cloudNames)
|
|
{
|
|
const HashTable<word>& theseCloudFields = cloudFields[cloudName];
|
|
|
|
fileNameList currentCloudDirs
|
|
(
|
|
readDir
|
|
(
|
|
runTime.timePath()/regionDir/cloud::prefix,
|
|
fileName::DIRECTORY
|
|
)
|
|
);
|
|
|
|
Info<< "Cloud " << cloudName << " (";
|
|
|
|
const bool cloudExists =
|
|
returnReduceOr(currentCloudDirs.found(cloudName));
|
|
|
|
{
|
|
autoPtr<ensightFile> os = ensCase.newCloud(cloudName);
|
|
|
|
ensightOutput::writeCloudPositions
|
|
(
|
|
os.ref(),
|
|
mesh,
|
|
cloudName,
|
|
cloudExists
|
|
);
|
|
|
|
Info<< " positions";
|
|
if (!cloudExists)
|
|
{
|
|
Info<< "{0}"; // report empty field
|
|
}
|
|
}
|
|
|
|
// Field order may differ on individual processors, so sort by name
|
|
for (const word& fieldName : theseCloudFields.sortedToc())
|
|
{
|
|
const word& fieldType = theseCloudFields[fieldName];
|
|
|
|
IOobject fieldObject
|
|
(
|
|
fieldName,
|
|
mesh.time().timeName(),
|
|
cloud::prefix/cloudName,
|
|
mesh,
|
|
IOobject::MUST_READ
|
|
);
|
|
|
|
bool fieldExists = cloudExists; // No field without positions
|
|
if (cloudExists)
|
|
{
|
|
// Want MUST_READ (globally) and valid=false (locally),
|
|
// but that combination does not work.
|
|
// So check the header and sync globally
|
|
|
|
const bool oldParRun = Pstream::parRun(false);
|
|
fieldExists = fieldObject.typeHeaderOk<IOField<scalar>>(false);
|
|
Pstream::parRun(oldParRun); // Restore parallel state
|
|
Pstream::reduceOr(fieldExists);
|
|
}
|
|
|
|
bool wrote = false;
|
|
do
|
|
{
|
|
#undef ensight_WRITE_CLOUD_FIELD
|
|
#define ensight_WRITE_CLOUD_FIELD(PrimitiveType) \
|
|
\
|
|
if (fieldType == IOField<PrimitiveType>::typeName) \
|
|
{ \
|
|
autoPtr<ensightFile> os = \
|
|
ensCase.newCloudData<PrimitiveType> \
|
|
( \
|
|
cloudName, \
|
|
fieldName \
|
|
); \
|
|
\
|
|
wrote = ensightOutput::readWriteCloudField<PrimitiveType> \
|
|
( \
|
|
os.ref(), \
|
|
fieldObject, \
|
|
fieldExists \
|
|
); \
|
|
break; \
|
|
}
|
|
|
|
ensight_WRITE_CLOUD_FIELD(scalar);
|
|
ensight_WRITE_CLOUD_FIELD(vector);
|
|
|
|
#undef ensight_WRITE_CLOUD_FIELD
|
|
} while (false);
|
|
|
|
if (wrote)
|
|
{
|
|
Info<< ' ' << fieldName;
|
|
if (!fieldExists)
|
|
{
|
|
Info<< "{0}"; // report empty field
|
|
}
|
|
}
|
|
}
|
|
Info<< " )" << nl;
|
|
}
|
|
}
|
|
|
|
|
|
// ************************************************************************* //
|