NamdCentLB.C File Reference

#include <unistd.h>
#include <fcntl.h>
#include "InfoStream.h"
#include "NamdCentLB.h"
#include "NamdCentLB.def.h"
#include "Node.h"
#include "PatchMap.h"
#include "ComputeMap.h"
#include "LdbCoordinator.h"

Go to the source code of this file.

Macros
#define	IF_NEW_NODE

Functions
void	CreateNamdCentLB ()
NamdCentLB *	AllocateNamdCentLB ()
int	isPmeProcessor (int)

Variables
double *	cpuloads = NULL

Macro Definition Documentation

IF_NEW_NODE

#define IF_NEW_NODE

Value:

int j; \
    for ( j=0; j<nProxyNodes && neighborNodes[j] != proxyNode; ++j ); \
    if ( j == nProxyNodes )

Function Documentation

AllocateNamdCentLB()

NamdCentLB* AllocateNamdCentLB

(

)

Definition at line 38 of file NamdCentLB.C.

Referenced by NamdHybridLB::NamdHybridLB().

                                 {
  return new NamdCentLB((CkMigrateMessage*)NULL);
}

CreateNamdCentLB()

void CreateNamdCentLB

(

)

Definition at line 26 of file NamdCentLB.C.

References cpuloads.

Referenced by LdbCoordinator::createLoadBalancer().

                        {
  // CkPrintf("[%d] creating NamdCentLB %d\n",CkMyPe(),loadbalancer);
  int seqno = LdbInfra::Object()->getLoadbalancerTicket();
  loadbalancer = CProxy_NamdCentLB::ckNew(CkLBOptions(seqno));
  // CkPrintf("[%d] created NamdCentLB %d\n",CkMyPe(),loadbalancer);
  if (CkMyRank() == 0 && cpuloads == NULL) {    
    cpuloads = new double[CkNumPes()];
    CmiAssert(cpuloads != NULL);
    for (int i=0; i<CkNumPes(); i++) cpuloads[i] = 0.0;
  }
}

isPmeProcessor()

int isPmeProcessor

(

int

)

Definition at line 624 of file ComputePme.C.

                         { 
  SimParameters *simParams = Node::Object()->simParameters;
  if (simParams->usePMECUDA) {
    return 0;
  } else {
    return pencilPMEProcessors[p];
  }
}

Variable Documentation

cpuloads

double* cpuloads = NULL

Definition at line 24 of file NamdCentLB.C.

Referenced by compLoad(), CreateNamdCentLB(), CreateNamdHybridLB(), processCpuLoad(), NamdCentLB::Strategy(), and NamdHybridLB::UpdateLocalLBInfo().