Node.C File Reference

#include <unistd.h>
#include "InfoStream.h"
#include "Node.decl.h"
#include "Node.h"
#include "ProcessorPrivate.h"
#include "Debug.h"
#include <stdio.h>
#include <converse.h>
#include "memusage.h"
#include "IMDOutput.h"
#include "Lattice.h"
#include "ComputeMsmMsa.h"
#include "ComputeMsm.h"
#include "main.decl.h"
#include "main.h"
#include "WorkDistrib.h"
#include "PatchMgr.h"
#include "Patch.h"
#include "Compute.h"
#include "ComputeMap.h"
#include "ComputeMgr.h"
#include "Molecule.h"
#include "HomePatchList.h"
#include "AtomMap.h"
#include "Sequencer.h"
#include "Controller.h"
#include "NamdState.h"
#include "Output.h"
#include "ProxyMgr.h"
#include "PatchMap.h"
#include "PatchMap.inl"
#include "Parameters.h"
#include "SimParameters.h"
#include "Communicate.h"
#include "LdbCoordinator.h"
#include "ScriptTcl.h"
#include "ComputeMgr.decl.h"
#include "ComputePmeMgr.decl.h"
#include "ComputeCUDAMgr.decl.h"
#include "ComputeCUDAMgr.h"
#include "ComputePmeCUDAMgr.decl.h"
#include "ComputePmeCUDAMgr.h"
#include "ComputeGridForceMgr.decl.h"
#include "Sync.h"
#include "BackEnd.h"
#include "PDB.h"
#include "packmsg.h"
#include "CollectionMgr.decl.h"
#include "ParallelIOMgr.decl.h"
#include "Vector.h"
#include "Random.h"
#include "PatchData.h"
#include "DeviceCUDA.h"
#include "Thread.h"
#include "GlobalGPUMgr.h"
#include "SynchronousCollectives.h"
#include "NamdEventsProfiling.h"
#include "DumpBench.h"
#include "CollectionMgr.h"
#include "CollectionMaster.h"
#include "CollectionMaster.decl.h"
#include "Node.def.h"

Go to the source code of this file.

Classes
class	CheckpointMsg

Macros
#define	MIN_DEBUG_LEVEL   3

Functions
void	recvCheckpointCReq_handler (envelope *)
void	recvCheckpointCAck_handler (envelope *)
void	registerUserEventsForAllComputeObjs (void)
void	initializeGPUResident ()

Variables
__thread DeviceCUDA *	deviceCUDA
int	eventEndOfTimeStep
double	startupTime
SimParameters *	node_simParameters
Parameters *	node_parameters
Molecule *	node_molecule
char *	gNAMDBinaryName

Macro Definition Documentation

MIN_DEBUG_LEVEL

#define MIN_DEBUG_LEVEL   3

Copyright (c) 1995, 1996, 1997, 1998, 1999, 2000 by The Board of Trustees of the University of Illinois. All rights reserved.

Definition at line 24 of file Node.C.

Function Documentation

initializeGPUResident()

void initializeGPUResident

(

)

Definition at line 447 of file Node.C.

References SynchronousCollectives::forceBarrierAll(), GlobalGPUMgr::getDeviceIndex(), GlobalGPUMgr::getDeviceIndexToPeMap(), GlobalGPUMgr::getIsMasterDevice(), GlobalGPUMgr::getIsMasterPe(), GlobalGPUMgr::getNumDevices(), GlobalGPUMgr::initialize(), GlobalGPUMgr::initializeBackends(), SynchronousCollectives::initMasterScope(), GlobalGPUMgr::Object(), and SynchronousCollectives::Object().

Referenced by Node::startup().

                             {
  SynchronousCollectives* syncColl = SynchronousCollectives::Object();
  GlobalGPUMgr* globalGPUMgr = GlobalGPUMgr::Object();
  syncColl->forceBarrierAll();
  globalGPUMgr->initialize();
  syncColl->initMasterScope(
    globalGPUMgr->getIsMasterPe(), globalGPUMgr->getIsMasterDevice(),
    globalGPUMgr->getNumDevices(), globalGPUMgr->getDeviceIndex(),
    globalGPUMgr->getDeviceIndexToPeMap()
  );
  globalGPUMgr->initializeBackends();
  CthFree(CthSelf());
}

recvCheckpointCAck_handler()

void recvCheckpointCAck_handler

(

envelope *

env

)

Definition at line 1416 of file Node.C.

References Node::Object(), and Node::recvCheckpointAck().

Referenced by Node::Node().

                                                 {
    Node::Object()->recvCheckpointAck(CheckpointMsg::unpack(EnvToUsr(env)));
  }

recvCheckpointCReq_handler()

void recvCheckpointCReq_handler

(

envelope *

env

)

Definition at line 1394 of file Node.C.

References Node::Object(), and Node::recvCheckpointReq().

Referenced by Node::Node().

                                                 {
    Node::Object()->recvCheckpointReq(CheckpointMsg::unpack(EnvToUsr(env)));
  }

registerUserEventsForAllComputeObjs()

void registerUserEventsForAllComputeObjs

(

void

)

Definition at line 853 of file ComputeMgr.C.

References computeAnglesType, computeAnisoType, computeBondsType, computeConsForceType, computeConsTorqueType, computeCrosstermsType, computeCylindricalBCType, computeDihedralsType, computeEFieldType, computeEwaldType, computeExclsType, computeExtType, computeFullDirectType, computeGlobalType, computeGridForceType, computeImpropersType, computeLCPOType, computeNonbondedPairType, computeNonbondedSelfType, computeOneFourNbTholeType, computePmeCUDAType, computePmeType, computeQMType, computeRestraintsType, computeSelfAnglesType, computeSelfAnisoType, computeSelfBondsType, computeSelfCrosstermsType, computeSelfDihedralsType, computeSelfExclsType, computeSelfImpropersType, computeSelfOneFourNbTholeType, computeSelfTholeType, computeSphericalBCType, computeStirType, computeTclBCType, computeTholeType, PatchMap::gridsize_a(), PatchMap::gridsize_b(), PatchMap::gridsize_c(), PatchMap::index_a(), PatchMap::index_b(), PatchMap::index_c(), NAMD_bug(), ComputeMap::numComputes(), PatchMap::Object(), ComputeMap::Object(), Lattice::offset_a(), Lattice::offset_b(), Lattice::offset_c(), ComputeMap::pid(), TRACE_COMPOBJ_IDOFFSET, ComputeMap::trans(), and ComputeMap::type().

Referenced by Node::startup().

                                           {
#ifdef TRACE_COMPUTE_OBJECTS
    ComputeMap *map = ComputeMap::Object();
    PatchMap *pmap = PatchMap::Object();     
    char user_des[50];
    int p1, p2;
    int adim, bdim, cdim;
    int t1, t2;
    int x1, y1, z1, x2, y2, z2;
    int dx, dy, dz;
    for (int i=0; i<map->numComputes(); i++)
    {
        memset(user_des, 0, 50);
        switch ( map->type(i) )
        {
        case computeNonbondedSelfType:
            sprintf(user_des, "computeNonBondedSelfType_%d_pid_%d", i, map->pid(i,0));
            break;
        case computeLCPOType:
            sprintf(user_des, "computeLCPOType_%d_pid_%d", i, map->pid(i,0));
            break;
        case computeNonbondedPairType:
            adim = pmap->gridsize_a();
            bdim = pmap->gridsize_b();
            cdim = pmap->gridsize_c();
            p1 = map->pid(i, 0);
            t1 = map->trans(i, 0);
            x1 = pmap->index_a(p1) + adim * Lattice::offset_a(t1);
            y1 = pmap->index_b(p1) + bdim * Lattice::offset_b(t1);
            z1 = pmap->index_c(p1) + cdim * Lattice::offset_c(t1);
            p2 = map->pid(i, 1);
            t2 = map->trans(i, 1);
            x2 = pmap->index_a(p2) + adim * Lattice::offset_a(t2);
            y2 = pmap->index_b(p2) + bdim * Lattice::offset_b(t2);
            z2 = pmap->index_c(p2) + cdim * Lattice::offset_c(t2);
            dx = abs(x1-x2);
            dy = abs(y1-y2);
            dz = abs(z1-z2);
            sprintf(user_des, "computeNonBondedPairType_%d(%d,%d,%d)", i, dx,dy,dz);
            break;
#if defined(NAMD_CUDA) || defined(NAMD_HIP)
#ifdef BONDED_CUDA
        case computeBondedCUDAType:
            sprintf(user_des, "computeBondedCUDAType_%d", i);
            break;
#endif
#endif
        case computeExclsType:
            sprintf(user_des, "computeExclsType_%d", i);
            break;
        case computeBondsType:
            sprintf(user_des, "computeBondsType_%d", i);
            break;
        case computeAnglesType:
            sprintf(user_des, "computeAnglesType_%d", i);
            break;
        case computeDihedralsType:
            sprintf(user_des, "computeDihedralsType_%d", i);
            break;
        case computeImpropersType:
            sprintf(user_des, "computeImpropersType_%d", i);
            break;
        case computeTholeType:
            sprintf(user_des, "computeTholeType_%d", i);
            break;
        case computeAnisoType:
            sprintf(user_des, "computeAnisoType_%d", i);
            break;
        case computeCrosstermsType:
            sprintf(user_des, "computeCrosstermsType_%d", i);
            break;
        case computeOneFourNbTholeType:
            sprintf(user_des, "computeOneFourNbTholeType_%d", i);
            break;
        case computeSelfExclsType:
            sprintf(user_des, "computeSelfExclsType_%d", i);
            break;
        case computeSelfBondsType:
            sprintf(user_des, "computeSelfBondsType_%d", i);
            break;
        case computeSelfAnglesType:
            sprintf(user_des, "computeSelfAnglesType_%d", i);
            break;
        case computeSelfDihedralsType:
            sprintf(user_des, "computeSelfDihedralsType_%d", i);
            break;
        case computeSelfImpropersType:
            sprintf(user_des, "computeSelfImpropersType_%d", i);
            break;
        case computeSelfTholeType:
            sprintf(user_des, "computeSelfTholeType_%d", i);
            break;
        case computeSelfAnisoType:
            sprintf(user_des, "computeSelfAnisoType_%d", i);
            break;
        case computeSelfCrosstermsType:
            sprintf(user_des, "computeSelfCrosstermsType_%d", i);
            break;
        case computeSelfOneFourNbTholeType:
            sprintf(user_des, "computeSelfOneFourNbTholeType_%d", i);
            break;
#ifdef DPMTA
        case computeDPMTAType:
            sprintf(user_des, "computeDPMTAType_%d", i);
            break;
#endif
#ifdef DPME
        case computeDPMEType:
            sprintf(user_des, "computeDPMEType_%d", i);
            break;
#endif
        case computePmeType:
            sprintf(user_des, "computePMEType_%d", i);
            break;
#if defined(NAMD_CUDA) || defined(NAMD_HIP)
        case computePmeCUDAType:
            sprintf(user_des, "computePMECUDAType_%d", i);
            break;
#endif
        case computeEwaldType:
            sprintf(user_des, "computeEwaldType_%d", i);
            break;
        case computeFullDirectType:
            sprintf(user_des, "computeFullDirectType_%d", i);
            break;
        case computeGlobalType:
            sprintf(user_des, "computeGlobalType_%d", i);
            break;
        case computeStirType:
            sprintf(user_des, "computeStirType_%d", i);
            break;
        case computeExtType:
            sprintf(user_des, "computeExtType_%d", i);
            break;
        case computeQMType:
            sprintf(user_des, "computeQMType_%d", i);
            break;
        case computeEFieldType:
            sprintf(user_des, "computeEFieldType_%d", i);
            break;
            /* BEGIN gf */
        case computeGridForceType:
            sprintf(user_des, "computeGridForceType_%d", i);
            break;
            /* END gf */
        case computeSphericalBCType:
            sprintf(user_des, "computeSphericalBCType_%d", i);
            break;
        case computeCylindricalBCType:
            sprintf(user_des, "computeCylindricalBCType_%d", i);
            break;
        case computeTclBCType:
            sprintf(user_des, "computeTclBCType_%d", i);
            break;
        case computeRestraintsType:
            sprintf(user_des, "computeRestraintsType_%d", i);
            break;
        case computeConsForceType:
            sprintf(user_des, "computeConsForceType_%d", i);
            break;
        case computeConsTorqueType:
            sprintf(user_des, "computeConsTorqueType_%d", i);
            break;
        default:
            NAMD_bug("Unknown compute type in ComputeMgr::registerUserEventForAllComputeObjs().");
            break;
        }
        int user_des_len = strlen(user_des);
        char *user_des_cst = new char[user_des_len+1];
        memcpy(user_des_cst, user_des, user_des_len);
        user_des_cst[user_des_len] = 0;
        //Since the argument in traceRegisterUserEvent is supposed
        //to be a const string which will not be copied inside the
        //function when a new user event is created, user_des_cst 
        //has to be allocated in heap.
        int reEvenId = traceRegisterUserEvent(user_des_cst, TRACE_COMPOBJ_IDOFFSET+i);
        //printf("Register user event (%s) with id (%d)\n", user_des, reEvenId);
    }
#else
    return;
#endif
}

Variable Documentation

deviceCUDA

__thread DeviceCUDA* deviceCUDA

Definition at line 23 of file DeviceCUDA.C.

eventEndOfTimeStep

int eventEndOfTimeStep

Definition at line 296 of file Node.C.

Referenced by Controller::integrate(), Sequencer::integrate(), and Node::Node().

gNAMDBinaryName

char* gNAMDBinaryName

Definition at line 247 of file BackEnd.C.

Referenced by BackEnd::init(), and Node::outputPatchComputeMaps().

node_molecule

Molecule* node_molecule

Definition at line 436 of file Node.C.

Referenced by Node::resendMolecule(), Node::resendMolecule2(), and Node::startup().

node_parameters

Parameters* node_parameters

Definition at line 435 of file Node.C.

Referenced by Node::resendMolecule(), Node::resendMolecule2(), and Node::startup().

node_simParameters

SimParameters* node_simParameters

Definition at line 434 of file Node.C.

Referenced by Node::startup().

startupTime

double startupTime

Definition at line 297 of file Node.C.

Referenced by Node::run(), and Node::startup().