Sync Class Reference

#include <Sync.h>

Inheritance diagram for Sync:

Public Member Functions
	Sync (void)
	~Sync (void)
void	openSync ()
int	holdComputes (PatchID pid, Compute **cbegin, Compute **cend, int doneMigration, int seq)
void	PatchReady (void)

Static Public Member Functions
static Sync *	Object ()

Detailed Description

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 Sync.h.

Constructor & Destructor Documentation

Sync()

Sync::Sync

(

void

)

Definition at line 42 of file Sync.C.

References eventHoldComputes, eventReleaseComputes, and NAMD_bug().

          : INCREASE(600), step(0), counter(0), homeReady(0)
{
    if (CkpvAccess(Sync_instance) == NULL) {
        CkpvAccess(Sync_instance) = this;
    } else {
        NAMD_bug("Sync instanced twice on same processor!");
    }
    capacity = INCREASE;
    clist = new _clist[capacity];
    cnum = 0;
    nPatcheReady = 0;
    numPatches = -1;
    eventHoldComputes = traceRegisterUserEvent("Sync::holdComputes", 133);
    eventReleaseComputes = traceRegisterUserEvent("Sync::releaseComputes", 134);
}

~Sync()

Sync::~Sync

(

void

)

Definition at line 58 of file Sync.C.

{
  delete [] clist;
}

Member Function Documentation

holdComputes()

int Sync::holdComputes	(	PatchID	pid,
		Compute **	cbegin,
		Compute **	cend,
		int	doneMigration,
		int	seq
	)

Definition at line 103 of file Sync.C.

References eventHoldComputes, and PatchMap::Object().

{
  if (!useSync) return 0;
  if (step < 0) step = seq;
  if (!useProxySync) {
    // only hold when homepatches are not ready
    PatchMap *patchMap = PatchMap::Object();
    if (homeReady && seq == step) {
      nPatcheReady++;
      triggerCompute();
      return 0;
    }
  }
  traceUserEvent(eventHoldComputes);

  int slot = 0;
  for (; slot < cnum; slot++)
     if (clist[slot].pid == -1) break;
  if (slot == cnum) {
    cnum++;
    // table is full, expand the list
    if (cnum == capacity) {
      capacity += INCREASE;
      struct _clist *tmp = new _clist[capacity];
      memcpy(tmp, clist, cnum*sizeof(_clist));
      delete [] clist;
      clist = tmp;
      //CmiPrintf("[%d] Info:: Sync buffer overflow and expanded!\n", CkMyPe());
    }
  }

  clist[slot].cbegin = cbegin;
  clist[slot].cend = cend;
  clist[slot].pid = pid;
  clist[slot].doneMigration  = doneMigration;
  clist[slot].step = seq;

//  CkPrintf("REG[%d]: patch:%d step:%d-%d slot:%d\n", CkMyPe(), pid, patchMap->patch(pid)->flags.sequence, step, slot);

  if (clist[slot].step == step) {
      nPatcheReady++;
      triggerCompute();
  }
  return 1;
}

Object()

static Sync* Sync::Object ( void  )

inlinestatic

Definition at line 52 of file Sync.h.

Referenced by Patch::positionsReady(), HomePatch::positionsReady(), HomePatch::positionsReady_SOA(), LdbCoordinator::resume(), and Node::startup().

{ return CkpvAccess(Sync_instance); }

openSync()

void Sync::openSync

(

void

)

Definition at line 63 of file Sync.C.

References endi(), iINFO(), iout, PatchMap::Object(), ProxyMgr::Object(), proxyRecvSpanning, and proxySendSpanning.

Referenced by LdbCoordinator::resume(), and Node::startup().

{
  int reportPe = 1;
  while ( 2 * reportPe < CkNumPes() ) reportPe *= 2;
  step = -1;
  useSync = 1;
  if ( PatchMap::Object()->numPatches() >= 4 * CkNumPes() ) useSync = 0;
  if ( CmiNumNodes() < 2 ) useSync = 0;
  if ( CmiNumPhysicalNodes() < 2 ) useSync = 0;
#if defined(NAMD_CUDA) || defined(NAMD_HIP) || defined(NAMD_MIC)
  useSync = 0;
#endif
  useProxySync = 0;
  if (useSync) {
    // if use proxy spanning tree, proxy sync is forced
    if (!useProxySync && (proxySendSpanning || proxyRecvSpanning)
        && PatchMap::Object()->numPatches() < 4 * CkNumPes() ) {
      // If on BG/P, useProxySync should not be turned on for better performance
      #if ! (CMK_BLUEGENEQ || CMK_BLUEGENEP)
      // CmiPrintf("[%d] useProxySync is turned on. \n", CkMyPe());
      useProxySync = 1;
      #endif
    }
#if defined(NODEAWARE_PROXY_SPANNINGTREE) && defined(USE_NODEPATCHMGR)
    // immediate messages can be processed by any PE
    if (CkMyNodeSize() > 2) useProxySync = 0;
#endif
    // no proxies on this node, no need to use proxy sync.
    if (useProxySync && ProxyMgr::Object()->numProxies() == 0) {
      // CmiPrintf("[%d] useProxySync is turned off because no proxy. \n", CkMyPe());
      useProxySync = 0;
    }
    // if no proxy sync and no home patch, then disable home patch sync as well
    if (!useProxySync && PatchMap::Object()->numHomePatches() == 0) useSync = 0;
  }
  if(CkMyPe() == reportPe)
    iout << iINFO << "useSync: " << useSync << " useProxySync: " << useProxySync << "\n" << endi;
}    

PatchReady()

void Sync::PatchReady

(

void

)

Definition at line 150 of file Sync.C.

Referenced by HomePatch::positionsReady(), and HomePatch::positionsReady_SOA().

{
 if ( useSync ) {
  counter ++;
  triggerCompute();
 }
}

---

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

• Sync.h
• Sync.C