#include <Compute.h>

Inheritance diagram for Compute:

Public Member Functions
	Compute (ComputeID)

int	type ()

virtual	~Compute ()

void	setNumPatches (int n)

int	getNumPatches ()

virtual void	initialize ()

virtual void	atomUpdate ()

virtual void	patchReady (PatchID, int doneMigration, int seq)

virtual int	noWork ()

virtual void	doWork ()

virtual void	finishPatch (int)

int	sequence (void)

int	priority (void)

int	getGBISPhase (void)

virtual void	gbisP2PatchReady (PatchID, int seq)

virtual void	gbisP3PatchReady (PatchID, int seq)

Public Attributes
const ComputeID	cid

LDObjHandle	ldObjHandle

LocalWorkMsg *const	localWorkMsg

Protected Member Functions
void	enqueueWork ()

Protected Attributes
int	computeType

int	basePriority

int	gbisPhase

int	gbisPhasePriority [3]

Detailed Description

Definition at line 28 of file Compute.h.

Constructor & Destructor Documentation

◆ Compute()

Compute::Compute ( ComputeID c )

Definition at line 37 of file Compute.C.

References computeType, gbisPhasePriority, LdbIdField(), ldObjHandle, ComputeMap::Object(), and ComputeMap::type().

                             : gbisPhase(1),basePriority(0), cid(c),
         localWorkMsg(new (PRIORITY_SIZE) LocalWorkMsg) { 
   gbisPhasePriority[0] = 0;
   gbisPhasePriority[1] = 0;
   gbisPhasePriority[2] = 0;
   doAtomUpdate = false;
   computeType = ComputeMap::Object()->type(c);
   LdbIdField(ldObjHandle.id, 0) = 0;
 }

◆ ~Compute()

Compute::~Compute ( )

virtual

Definition at line 47 of file Compute.C.

References localWorkMsg.

                   {
   delete localWorkMsg;
 }

Member Function Documentation

◆ atomUpdate()

virtual void Compute::atomUpdate ( void )

inlinevirtual

Definition at line 59 of file Compute.h.

Referenced by ComputeHomePatches::atomUpdate(), and patchReady().

59 {};

◆ doWork()

void Compute::doWork ( void )

virtual

Definition at line 120 of file Compute.C.

References DebugM.

                      {
     DebugM(5,"Default Compute::doWork() called.\n");
 }

◆ enqueueWork()

void Compute::enqueueWork ( )

protected

Definition at line 51 of file Compute.C.

References DebugM, WorkDistrib::messageEnqueueWork(), and noWork().

Referenced by gbisP2PatchReady(), gbisP3PatchReady(), and patchReady().

                           {
   if (!this) { DebugM(4,"This Compute is NULL!!!\n"); }
   if ( ! noWork() ) {
     //gbisPhase = 1; //first phase - this should already be 1
     WorkDistrib::messageEnqueueWork(this);  // should be in ComputeMgr?
   } else {
     //don't enqueue work
   }
 }

◆ finishPatch()

void Compute::finishPatch ( int )

virtual

Definition at line 124 of file Compute.C.

References DebugM.

Referenced by WorkDistrib::finishCUDAPatch().

                              {
     DebugM(5,"Default Compute::finishPatch() called.\n");
 }

◆ gbisP2PatchReady()

void Compute::gbisP2PatchReady	(	PatchID	pid,
		int	seq
	)

virtual

Reimplemented in CudaComputeNonbonded.

Definition at line 96 of file Compute.C.

References enqueueWork().

Referenced by CudaComputeNonbonded::gbisP2PatchReady().

                                                    {
 
   if (! --patchReadyCounter) {
     patchReadyCounter = numPatches;
     //gbisPhase = 2;
     sequenceNumber = seq;
     enqueueWork();
   }
 }

◆ gbisP3PatchReady()

void Compute::gbisP3PatchReady	(	PatchID	pid,
		int	seq
	)

virtual

Reimplemented in CudaComputeNonbonded.

Definition at line 106 of file Compute.C.

References enqueueWork().

Referenced by CudaComputeNonbonded::gbisP3PatchReady().

                                                    {
   if (! --patchReadyCounter) {
     patchReadyCounter = numPatches;
     //gbisPhase = 3;
     sequenceNumber = seq;
     enqueueWork();
   }
 }

◆ getGBISPhase()

int Compute::getGBISPhase ( void )

inline

Definition at line 66 of file Compute.h.

References gbisPhase.

Referenced by WorkDistrib::messageEnqueueWork(), WorkDistrib::messageFinishCUDA(), and WorkDistrib::messageFinishMIC().

66 {return gbisPhase;}

Compute::gbisPhase

int gbisPhase

Definition: Compute.h:39

◆ getNumPatches()

int Compute::getNumPatches ( )

inline

Definition at line 53 of file Compute.h.

Referenced by CudaComputeNonbonded::assignPatches(), ComputeLCPO::ComputeLCPO(), ComputePmeCUDA::ComputePmeCUDA(), ComputeLCPO::doWork(), ComputePmeCUDA::initialize(), ComputePmeCUDA::noWork(), CudaComputeNonbonded::openBoxesOnPe(), CudaComputeNonbonded::skipPatchesOnPe(), ComputePmeCUDA::storePmeForceMsg(), ComputeLCPO::~ComputeLCPO(), and ComputePmeCUDA::~ComputePmeCUDA().

53 { return (numPatches); };

◆ initialize()

virtual void Compute::initialize ( void )

inlinevirtual

Definition at line 56 of file Compute.h.

Referenced by ComputePatch::initialize(), ComputePatchPair::initialize(), ComputeHomePatch::initialize(), and ComputeLCPO::initialize().

56 {};

◆ noWork()

int Compute::noWork ( )

virtual

Reimplemented in CudaComputeNonbonded, ComputeLCPO, ComputePme, ComputeNonbondedSelf, ComputeNonbondedPair, and ComputePmeCUDA.

Definition at line 116 of file Compute.C.

Referenced by enqueueWork().

                     {
   return 0;
 }

◆ patchReady()

void Compute::patchReady	(	PatchID	patchID,
		int	doneMigration,
		int	seq
	)

virtual

Reimplemented in CudaComputeNonbonded.

Definition at line 67 of file Compute.C.

References atomUpdate(), DebugM, enqueueWork(), Node::Object(), Node::simParameters, and simParams.

Referenced by CudaComputeNonbonded::patchReady().

                                                                    { 
   if (doneMigration) { // If any patch has done migration - we must remap
     doAtomUpdate = true; 
   }
 
   if (numPatches <= 0) {
       DebugM(5,"Compute::patchReady("<<patchID<<")-call not valid!\n");
   } else {
     if (! --patchReadyCounter) {
       patchReadyCounter = numPatches;
       //gbisPhase = 1;
       sequenceNumber = seq;  // breaks CUDA priority if done earlier
       //fprintf(stderr, "Sequence number %d\n", sequenceNumber);
       if (doAtomUpdate) {
         atomUpdate();
         doAtomUpdate = false;
       }
 #ifdef NODEGROUP_FORCE_REGISTER
       SimParameters *simParams = Node::Object()->simParameters;
       if(!simParams->CUDASOAintegrate){
          enqueueWork();
        }
 #else
       enqueueWork();
 #endif
     }
   }
 }