FIX: getLine() line counting (adjustment to 459aaad0f9)

ENH: return ITstream::emptyStream() in a 'bad' state

- to indicate that it is invalid for reading

applications/test/OFstream/Test-OFstream.cxx

@@ -0,0 +1,228 @@
+/*---------------------------------------------------------------------------*\
+  =========                 |
+  \\      /  F ield         | OpenFOAM: The Open Source CFD Toolbox
+   \\    /   O peration     |
+    \\  /    A nd           | www.openfoam.com
+     \\/     M anipulation  |
+-------------------------------------------------------------------------------
+    Copyright (C) 2022 OpenCFD Ltd.
+-------------------------------------------------------------------------------
+License
+    This file is part of OpenFOAM.
+
+    OpenFOAM is free software: you can redistribute it and/or modify it
+    under the terms of the GNU General Public License as published by
+    the Free Software Foundation, either version 3 of the License, or
+    (at your option) any later version.
+
+    OpenFOAM is distributed in the hope that it will be useful, but WITHOUT
+    ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+    FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
+    for more details.
+
+    You should have received a copy of the GNU General Public License
+    along with OpenFOAM.  If not, see <http://www.gnu.org/licenses/>.
+
+Description
+    Test OFstream. Primarily atomic operations
+
+\*---------------------------------------------------------------------------*/
+
+#include "Fstream.H"
+#include "IOstreams.H"
+#include "OSspecific.H"
+#include "argList.H"
+#include "ListOps.H"
+
+using namespace Foam;
+
+void listFiles(const fileName& dir)
+{
+    wordList files = ListOps::create<word>
+    (
+        readDir(dir, fileName::FILE),
+        nameOp<fileName>()
+    );
+
+    Info
+        << nl
+        << "files:" << nl
+        << files << nl
+        << "ls" << nl
+        << "============" << endl;
+    Foam::system("ls -al " + dir);
+    Info<< "============" << endl;
+}
+
+
+// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * //
+// Main program:
+
+int main(int argc, char *argv[])
+{
+    argList::addBoolOption("gz", "Use compression");
+    argList::addBoolOption("append", "Use append mode");
+    argList::addBoolOption("atomic", "Use atomic");
+    argList::addBoolOption("keep", "Do not remove test directory");
+    argList::addOption("write", "file", "test writing to file");
+
+    #include "setRootCase.H"
+
+    const fileName baseDir("Test-OFstream-directory");
+
+    Foam::mkDir(baseDir);
+
+    InfoErr<< "mkdir: " << baseDir << endl;
+
+    IOstreamOption streamOpt;
+
+    if (args.found("gz"))
+    {
+        streamOpt.compression(IOstreamOption::COMPRESSED);
+    }
+
+    IOstreamOption::appendType append =
+    (
+        args.found("append")
+      ? IOstreamOption::APPEND
+      : IOstreamOption::NON_APPEND
+    );
+    IOstreamOption::atomicType atomic =
+    (
+        args.found("atomic")
+      ? IOstreamOption::ATOMIC
+      : IOstreamOption::NON_ATOMIC
+    );
+
+    {
+        OFstream(baseDir/"dummy")() << "Some file content" << endl;
+
+        Foam::ln("dummy", baseDir/"Test2.txt");
+        Foam::ln("dummy", baseDir/"Test3.txt");
+        Foam::ln("dummy", baseDir/"Test4.txt");
+        Foam::ln("dummy", baseDir/"Test4.txt.gz");
+        Foam::ln("dummy", baseDir/"Test5.txt");
+        Foam::ln("dummy", baseDir/"Test5.txt.gz");
+    }
+
+    {
+        OFstream os
+        (
+            atomic,
+            baseDir/"Test1.txt",
+            streamOpt,
+            append
+        );
+
+        os << "=========================" << endl;
+
+        InfoErr<< "open: " << os.name() << endl;
+        InfoErr<< "... sleep" << endl;
+
+        listFiles(baseDir);
+
+        sleep(2);
+
+        os << "+++++++++++++++++++++++++++++++++++" << endl;
+    }
+
+    {
+        OFstream os
+        (
+            atomic,
+            baseDir/"Test2.txt",
+            streamOpt
+            // NON_APPEND
+        );
+
+        os << "=========================" << endl;
+
+        InfoErr<< "open: " << os.name() << endl;
+        InfoErr<< "... sleep" << endl;
+
+        listFiles(baseDir);
+
+        sleep(2);
+
+        os << "+++++++++++++++++++++++++++++++++++" << endl;
+    }
+    {
+        OFstream os
+        (
+            atomic,
+            baseDir/"Test3.txt",
+            streamOpt,
+            IOstreamOption::APPEND
+        );
+
+        os << "=========================" << endl;
+
+        InfoErr<< "open: " << os.name() << endl;
+        InfoErr<< "... sleep" << endl;
+
+        listFiles(baseDir);
+
+        sleep(2);
+
+        os << "+++++++++++++++++++++++++++++++++++" << endl;
+    }
+    {
+        OFstream os
+        (
+            baseDir/"Test4.txt",
+            IOstreamOption::ASCII,
+            IOstreamOption::COMPRESSED
+        );
+
+        os << "=========================" << endl;
+
+        InfoErr<< "open: " << os.name() << endl;
+        InfoErr<< "... sleep" << endl;
+
+        listFiles(baseDir);
+
+        sleep(2);
+
+        os << "+++++++++++++++++++++++++++++++++++" << endl;
+    }
+    {
+        OFstream os
+        (
+            IOstreamOption::ATOMIC,
+            baseDir/"Test5.txt"
+            // ASCII UNCOMPRESSED NON_APPEND
+        );
+
+        os << "=========================" << endl;
+
+        InfoErr<< "open: " << os.name() << endl;
+        InfoErr<< "... sleep" << endl;
+
+        listFiles(baseDir);
+
+        sleep(2);
+
+        os << "+++++++++++++++++++++++++++++++++++" << endl;
+    }
+
+    Info<< nl << "done:" << endl;
+
+    listFiles(baseDir);
+
+    if (args.found("keep"))
+    {
+        InfoErr<< "keep: " << baseDir << endl;
+    }
+    else
+    {
+        InfoErr<< "rmdir: " << baseDir << endl;
+        Foam::rmDir(baseDir);
+    }
+
+    Info<< "\nEnd\n" << endl;
+
+    return 0;
+}
+
+
+// ************************************************************************* //