ParallelBuffer.h

 
// Description: A simple I/O stream class that intercepts output from an
//              ostream and redirects the output as necessary for parallel
//              I/O.
 
#ifndef included_ParallelBuffer_h
#define included_ParallelBuffer_h
 
#include "CAROM_config.h"
 
#include <iostream>
#include <string>
 
namespace CAROM {
 
class ParallelBuffer : public std::streambuf
{
public:
    ParallelBuffer();
 
    ~ParallelBuffer();
 
    void
    outputString(
        const std::string& text)
    {
        outputString(text, static_cast<int>(text.length()));
    }
 
    void
    outputString(
        const std::string& text,
        int length);
 
    int
    sync();
 
#if !defined(__INTEL_COMPILER) && (defined(__GNUG__))
    std::streamsize
    xsputn(
        const std::string& text,
        std::streamsize n);
#endif
 
    int
    overflow(
        int ch);
 
#ifdef _MSC_VER
    int
    underflow()
    {
        return EOF;
    }
#endif
 
private:
    void
    copyToBuffer(
        const std::string& text,
        int length);
 
    void
    outputBuffer();
 
    std::string d_prefix;
 
    std::ostream* d_ostream;
 
    char* d_buffer;
 
    int d_buffer_size;
 
    int d_buffer_ptr;
 
    static const int DEFAULT_BUFFER_SIZE;
};
 
}
 
#endif