ReductionSet Class Reference

#include <ReductionMgr.h>

Public Member Functions
ReductionSetData *	getData (int seqNum)
ReductionSetData *	removeData (int seqNum)
	ReductionSet (int setID, int size, int numChildren)
	~ReductionSet ()

Public Attributes
int	reductionSetID
int	nextSequenceNumber
int	submitsRegistered
int	dataSize
ReductionSetData *	dataQueue
int	requireRegistered
int	threadIsWaiting
int	waitingForSequenceNumber
CthThread	waitingThread
int *	addToRemoteSequenceNumber

Detailed Description

Definition at line 214 of file ReductionMgr.h.

Constructor & Destructor Documentation

ReductionSet()

ReductionSet::ReductionSet	(	int	setID,
		int	size,
		int	numChildren
	)

Definition at line 58 of file ReductionMgr.C.

References addToRemoteSequenceNumber, dataQueue, dataSize, NAMD_bug(), nextSequenceNumber, REDUCTION_MAX_RESERVED, REDUCTIONS_AMD, REDUCTIONS_BASIC, reductionSetID, requireRegistered, submitsRegistered, and threadIsWaiting.

                                                               {
  if ( setID == REDUCTIONS_BASIC || setID == REDUCTIONS_AMD ) {
    if ( size != -1 ) {
      NAMD_bug("ReductionSet size specified for REDUCTIONS_BASIC or REDUCTIONS_AMD.");
    }
    size = REDUCTION_MAX_RESERVED;
  }
  if ( size == -1 ) NAMD_bug("ReductionSet size not specified.");
  dataSize = size;
  reductionSetID = setID;
  nextSequenceNumber = 0;
  submitsRegistered = 0;
  dataQueue = 0;
  requireRegistered = 0;
  threadIsWaiting = 0;
  addToRemoteSequenceNumber = new int[numChildren];
}

~ReductionSet()

ReductionSet::~ReductionSet

(

)

Definition at line 76 of file ReductionMgr.C.

References addToRemoteSequenceNumber, dataQueue, next(), and ReductionSetData::next.

                            {

  ReductionSetData *current = dataQueue;

  while ( current ) {
    ReductionSetData *next = current->next;
    delete current;
    current = next;
  }
  delete [] addToRemoteSequenceNumber;
}

Member Function Documentation

getData()

ReductionSetData * ReductionSet::getData

(

int

seqNum

)

Definition at line 89 of file ReductionMgr.C.

References dataQueue, and dataSize.

                                                  {

  ReductionSetData **current = &dataQueue;

  while ( *current ) {
    if ( (*current)->sequenceNumber == seqNum ) return *current;
    current = &((*current)->next);
  }

//iout << "seq " << seqNum << " created on " << CkMyPe() << "\n" << endi;
  *current = new ReductionSetData(seqNum, dataSize);
  return *current;
}

removeData()

ReductionSetData * ReductionSet::removeData

(

int

seqNum

)

Definition at line 104 of file ReductionMgr.C.

References dataQueue, NAMD_die(), and ReductionSetData::next.

                                                     {

  ReductionSetData **current = &dataQueue;

  while ( *current ) {
    if ( (*current)->sequenceNumber == seqNum ) break;
    current = &((*current)->next);
  }

  if ( ! *current ) { NAMD_die("ReductionSet::removeData on missing seqNum"); }

  ReductionSetData *toremove = *current;
  *current = (*current)->next;
  return toremove;
}

Member Data Documentation

addToRemoteSequenceNumber

int* ReductionSet::addToRemoteSequenceNumber

Definition at line 229 of file ReductionMgr.h.

Referenced by ReductionSet(), and ~ReductionSet().

dataQueue

ReductionSetData* ReductionSet::dataQueue

Definition at line 220 of file ReductionMgr.h.

Referenced by getData(), ReductionSet(), removeData(), and ~ReductionSet().

dataSize

int ReductionSet::dataSize

Definition at line 219 of file ReductionMgr.h.

Referenced by getData(), and ReductionSet().

nextSequenceNumber

int ReductionSet::nextSequenceNumber

Definition at line 217 of file ReductionMgr.h.

Referenced by ReductionSet().

reductionSetID

int ReductionSet::reductionSetID

Definition at line 216 of file ReductionMgr.h.

Referenced by ReductionSet().

requireRegistered

int ReductionSet::requireRegistered

Definition at line 223 of file ReductionMgr.h.

Referenced by ReductionSet().

submitsRegistered

int ReductionSet::submitsRegistered

Definition at line 218 of file ReductionMgr.h.

Referenced by ReductionSet().

threadIsWaiting

int ReductionSet::threadIsWaiting

Definition at line 224 of file ReductionMgr.h.

Referenced by ReductionSet().

waitingForSequenceNumber

int ReductionSet::waitingForSequenceNumber

Definition at line 225 of file ReductionMgr.h.

waitingThread

CthThread ReductionSet::waitingThread

Definition at line 226 of file ReductionMgr.h.

---

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

• ReductionMgr.h
• ReductionMgr.C