src/IplPaws/PawsScalarDataSource.cpp

Go to the documentation of this file.

// -*- C++ -*-
/***************************************************************************
 *
 * The IPPL Framework
 * 
 * This program was prepared by PSI. 
 * All rights in the program are reserved by PSI.
 * Neither PSI nor the author(s)
 * makes any warranty, express or implied, or assumes any liability or
 * responsibility for the use of this software
 *
 * Visit http://www.acl.lanl.gov/POOMS for more details
 *
 ***************************************************************************/

// -*- C++ -*-
/***************************************************************************
 *
 * The IPPL Framework
 * 
 *
 * Visit http://people.web.psi.ch/adelmann/ for more details
 *
 ***************************************************************************/

// IPPL include fiels
#include "IpplPaws/PawsScalarDataSource.h"
#include "IpplPaws/PawsDataConnect.h"
#include "DataSource/ScalarDataSource.h"
#include "Utility/IpplInfo.h"
#include "Utility/Pstring.h"

// PAWS include files
#include "Paws/Paws.h"


// constructor: the name, the connection, the transfer method,
// the scalar to connect, and the parent node.
template<class T>
PawsScalarDataSource<T>::PawsScalarDataSource(const char *nm,
                                                    DataConnect *dc,
                                                    int tm,
                                                    ScalarDataSource<T>& S)
  : DataSourceObject(nm, &S, dc, tm),
    scalarDataSource(S), myScalar(S.scalarRef()), pawsdata(0), pdc(0)
{

  string filestring = "paws";
  if (string(dc->ID()) != filestring) {
    ERRORMSG("Illegal DataConnect object for Paws Data Object." << endl);
    Connection = 0;
  } else {
    // get the data connection pointer for a PAWS connection
    pdc = (PawsDataConnect *)dc;

    // create a PawsScalarData which contains the representation
    // (this stores the domain information, about how many blocks there
    // are and what their domains are) and
    // the descriptor (this manages the actual data storage)

    // figure out the transfer method
    if (TransferMethod == DataSource::DEFAULT)
      TransferMethod = dc->getDefaultTransferMethod();

    int mode = PAWS_OUT;

    if (TransferMethod == DataSource::INPUT)
      mode = PAWS_IN;
    else if (TransferMethod == DataSource::OUTPUT)
      mode = PAWS_OUT;
    else if (TransferMethod == DataSource::BOTH)
      mode = PAWS_INOUT;

    // create a PawsScalarData object, the main interface from the scalar
    // to the PAWS data transfer capabilities.  It contains a representation,
    // descriptor, and PawsData object.  The representation and descriptor
    // objects are used to get the domain and storage information, to calculate
    // send/receive schedules, and to pack and unpack data during transfers.
    pawsdata = new PawsScalarData<T>(
                 nm,                   // name
                 &myScalar,            // pointer to data 
                 mode,                 // transfer mode
                 PAWS_SYNC,            // sync mode
                 *(pdc->getPawsApp())); // pointer to PAWS

  }
}


// destructor
template<class T>
PawsScalarDataSource<T>::~PawsScalarDataSource() {
  if (pawsdata != 0)
    delete pawsdata; 
}


// Update the object, that is, make sure the receiver of the data has a
// current and consistent snapshot of the current state.  Return success.
template<class T>
bool PawsScalarDataSource<T>::update() {

  if (TransferMethod == DataSource::OUTPUT ||
      TransferMethod == DataSource::BOTH) {
    pawsdata->send();
  } else if (TransferMethod == DataSource::INPUT ||
             TransferMethod == DataSource::BOTH) {
    pawsdata->receive();
  }

  return true;
}


// Indicate to the receiver that we're allowing them time to manipulate the
// data (e.g., for a viz program, to rotate it, change representation, etc.)
// This should only return when the manipulation is done.
template<class T>
void PawsScalarDataSource<T>::interact(const char *) {
  pdc->poll();
}


/***************************************************************************
 * $RCSfile: PawsScalarDataSource.cpp,v $   $Author: adelmann $
 * $Revision: 1.1.1.1 $   $Date: 2003/01/23 07:40:32 $
 * IPPL_VERSION_ID: $Id: PawsScalarDataSource.cpp,v 1.1.1.1 2003/01/23 07:40:32 adelmann Exp $ 
 ***************************************************************************/

---