1 /*---------------------------------------------------------------------------*\
3 \\ / F ield | OpenFOAM: The Open Source CFD Toolbox
5 \\ / A nd | Copyright (C) 1991-2008 OpenCFD Ltd.
7 -------------------------------------------------------------------------------
9 This file is part of OpenFOAM.
11 OpenFOAM is free software; you can redistribute it and/or modify it
12 under the terms of the GNU General Public License as published by the
13 Free Software Foundation; either version 2 of the License, or (at your
14 option) any later version.
16 OpenFOAM is distributed in the hope that it will be useful, but WITHOUT
17 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
18 FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
21 You should have received a copy of the GNU General Public License
22 along with OpenFOAM; if not, write to the Free Software Foundation,
23 Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
26 Read token and binary block from IPstream using pvm.
28 \*---------------------------------------------------------------------------*/
36 // * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * //
41 // * * * * * * * * * * * * * * * * Constructor * * * * * * * * * * * * * * * //
52 Istream(format, version),
53 fromProcNo_(fromProcNo),
61 // If the buffer size is not specified then probe the incomming message
65 // Probe read buffer until message arrives.
66 while (!(bufid = pvm_probe(procID(fromProcNo_), msgType())));
68 // When the message arrives find its size
69 pvm_bufinfo(bufid, &messageSize_, &tag, &tid);
71 // Resize buffer to message size
72 buf_.setSize(messageSize_);
76 // Read message into buffer
87 &tid, &tag, &messageSize_
91 FatalErrorIn("IPstream::IPstream(const int fromProcNo)")
92 << "pvm_precv cannot receive incomming message"
97 // Check size of message read
99 if (messageSize_ > buf_.size())
101 FatalErrorIn("IPstream::IPstream(const int fromProcNo)")
102 << "buffer (" << buf_.size()
103 << ") not large enough for incomming message ("
104 << messageSize_ << ')'
110 // * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * //
112 } // End namespace Foam
114 // ************************************************************************* //