olb::ParBuf Class Reference

#include <parallelIO.h>

Inheritance diagram for olb::ParBuf:

Collaboration diagram for olb::ParBuf:

Public Types
enum	Modes { normal , serial }

Public Member Functions
	ParBuf (std::streambuf *_originalBuf)
Modes	getMode () const
void	setMode (Modes _mode)

Protected Member Functions
int_type	overflow (int_type c) override
std::streamsize	xsputn (const char *s, std::streamsize num) override
int_type	uflow () override
int_type	underflow () override
std::streamsize	xsgetn (char *s, std::streamsize num) override

Detailed Description

Definition at line 37 of file parallelIO.h.

Member Enumeration Documentation

Modes

enum olb::ParBuf::Modes

Enumerator
normal
serial

Definition at line 39 of file parallelIO.h.

{normal, serial} Modes;

Constructor & Destructor Documentation

ParBuf()

olb::ParBuf::ParBuf

(

std::streambuf *

_originalBuf

)

Definition at line 112 of file parallelIO.h.

  : originalBuf(_originalBuf), mode(normal)
{ }

Member Function Documentation

getMode()

ParBuf::Modes olb::ParBuf::getMode

(

)

const

Definition at line 136 of file parallelIO.h.

{
  return mode;
}

overflow()

std::streambuf::int_type olb::ParBuf::overflow ( int_type c )

overrideprotected

Definition at line 117 of file parallelIO.h.

{
  int_type returnVal = c;
  if (c != EOF) {
#ifdef PARALLEL_MODE_MPI
    if (singleton::mpi().isMainProcessor()) {
#endif
      returnVal = originalBuf->sputc((char)c);
#ifdef PARALLEL_MODE_MPI
    }
    if (mode==normal) {
      singleton::mpi().bCast(&returnVal, 1);
    }
#endif
  }
  return returnVal;
}

References olb::singleton::MpiManager::bCast(), olb::singleton::mpi(), and normal.

Here is the call graph for this function:

setMode()

void olb::ParBuf::setMode

(

ParBuf::Modes

_mode

)

Definition at line 142 of file parallelIO.h.

{
  mode = _mode;
}

uflow()

std::streambuf::int_type olb::ParBuf::uflow ( )

overrideprotected

Definition at line 163 of file parallelIO.h.

{
  int_type value;
#ifdef PARALLEL_MODE_MPI
  if (singleton::mpi().isMainProcessor()) {
#endif
    value = originalBuf->sbumpc();
#ifdef PARALLEL_MODE_MPI
  }
  if (mode==normal) {
    singleton::mpi().bCast(&value, 1);
  }
#endif
  return value;
}

References olb::singleton::MpiManager::bCast(), olb::singleton::mpi(), and normal.

Here is the call graph for this function:

underflow()

std::streambuf::int_type olb::ParBuf::underflow ( )

overrideprotected

Definition at line 180 of file parallelIO.h.

{
  int_type value;
#ifdef PARALLEL_MODE_MPI
  if (singleton::mpi().isMainProcessor()) {
#endif
    value = originalBuf->sgetc();
#ifdef PARALLEL_MODE_MPI
  }
  if (mode==normal) {
    singleton::mpi().bCast(&value, 1);
  }
#endif
  return value;
}

References olb::singleton::MpiManager::bCast(), olb::singleton::mpi(), and normal.

Here is the call graph for this function:

xsgetn()

std::streamsize olb::ParBuf::xsgetn ( char * s, std::streamsize num )

overrideprotected

Definition at line 197 of file parallelIO.h.

{
  std::streamsize sizeRead=0;
#ifdef PARALLEL_MODE_MPI
  if (singleton::mpi().isMainProcessor()) {
#endif
    sizeRead = originalBuf->sgetn(s, num);
#ifdef PARALLEL_MODE_MPI
  }
  if (mode==normal) {
    int intSizeRead = (int) sizeRead;
    singleton::mpi().bCast(&intSizeRead, 1);
    singleton::mpi().bCast(s, intSizeRead);
    sizeRead = (std::streamsize) intSizeRead;
  }
#endif
  return sizeRead;
}

References olb::singleton::MpiManager::bCast(), olb::singleton::mpi(), and normal.

Here is the call graph for this function:

xsputn()

std::streamsize olb::ParBuf::xsputn ( const char * s, std::streamsize num )

overrideprotected

Definition at line 148 of file parallelIO.h.

{
#ifdef PARALLEL_MODE_MPI
  if (singleton::mpi().isMainProcessor()) {
#endif
    return originalBuf->sputn(s,num);
#ifdef PARALLEL_MODE_MPI
  }
  else {
    return num;
  }
#endif
}

References olb::singleton::mpi().

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• src/io/parallelIO.h