src/IplPaws/PawsFieldDataSource.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
 *
 ***************************************************************************/

#include <iostream.h>
#include "IpplPaws/PawsFieldDataSource.h"
#include "IpplPaws/PawsFieldData.h"
#include "IpplPaws/PawsDataConnect.h"
#include "Message/Communicate.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 field to connect, and the parent node.
template<class T, unsigned Dim, class M, class C>
PawsFieldDataSource<T,Dim,M,C>::PawsFieldDataSource(const char *nm,
                                                    DataConnect *dc,
                                                    int tm,
                                                    Field_t &F)
  : DataSourceObject(nm, &F, dc, tm), myField(F) {
 
  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;

    // 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 PawsFieldData object, the main interface from the IPPL Field
    // to the PAWS data transfer capabilities.  It creates/uses the DLRep and DLDesc
    // objects to get the domain and storage information, to calculate
    // send/receive schedules, and to pack and unpack data during transfers.
    // NOTE: it can communicate using PAWS STANDARD
    pawsdata = new PawsFieldData_t(nm, &F, mode,
                              PAWS_SYNC, PAWS_COLUMN,
                              *(pdc->getPawsApp())); 
  }
}


// destructor
template<class T, unsigned Dim, class M, class C>
PawsFieldDataSource<T,Dim,M,C>::~PawsFieldDataSource() {
  //Inform dbgmsg("PawsFieldDataSource::~PawsFieldDataSource",
  //              INFORM_ALL_NODES);

  //dbgmsg << "Deleting the PawsFieldData object ..." << endl;
  if (pawsdata != 0 && pdc != 0) {
    //dbgmsg << "Waiting at barrier before deleting PawsFieldData ..." << endl;
    //Ippl::Comm->barrier();
    pdc->barrier();
    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, unsigned Dim, class M, class C>
bool PawsFieldDataSource<T,Dim,M,C>::update() {

  pdc->barrier();

  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, unsigned Dim, class M, class C>
void PawsFieldDataSource<T,Dim,M,C>::interact(const char *) {
  pdc->poll();
}


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

---