NAMD
Functions
ProcessorPrivate.C File Reference
#include "ProcessorPrivate.h"
#include "Debug.h"
#include "InfoStream.h"

Go to the source code of this file.

Functions

 CkpvDeclare (AtomMap *, AtomMap_instance)
 
 CkpvDeclare (BroadcastMgr *, BroadcastMgr_instance)
 
 CkpvDeclare (CollectionMaster *, CollectionMaster_instance)
 
 CkpvDeclare (CollectionMgr *, CollectionMgr_instance)
 
 CkpvDeclare (LdbCoordinator *, LdbCoordinator_instance)
 
 CkpvDeclare (Node *, Node_instance)
 
 CkpvDeclare (PatchMap *, PatchMap_instance)
 
 CkpvDeclare (PatchMgr *, PatchMgr_instance)
 
 CkpvDeclare (ProxyMgr *, ProxyMgr_instance)
 
 CkpvDeclare (ReductionMgr *, ReductionMgr_instance)
 
 CkpvDeclare (PatchMgr *, PatchMap_patchMgr)
 
 CkpvDeclare (BOCgroup, BOCclass_group)
 
 CkpvDeclare (Communicate *, comm)
 
 CkpvDeclare (Sync *, Sync_instance)
 
 CkpvDeclare (infostream, iout_obj)
 
 CkpvDeclare (int, recv_data_idx)
 
 CkpvDeclare (int, recv_ack_idx)
 
 CkpvDeclare (int, recv_bcast_idx)
 
 CkpvDeclare (int, recv_red_idx)
 
 CkpvDeclare (int, recv_eval_command_idx)
 
 CkpvDeclare (int, recv_eval_result_idx)
 
 CkpvDeclare (int, recv_replica_dcd_init_idx)
 
 CkpvDeclare (int, recv_replica_dcd_data_idx)
 
 CkpvDeclare (int, recv_replica_dcd_ack_idx)
 
void initializeReplicaConverseHandlers ()
 
void ProcessorPrivateInit (void)
 

Function Documentation

CkpvDeclare ( AtomMap ,
AtomMap_instance   
)

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

CkpvDeclare ( BroadcastMgr ,
BroadcastMgr_instance   
)
CkpvDeclare ( CollectionMaster ,
CollectionMaster_instance   
)
CkpvDeclare ( CollectionMgr ,
CollectionMgr_instance   
)
CkpvDeclare ( LdbCoordinator ,
LdbCoordinator_instance   
)
CkpvDeclare ( Node ,
Node_instance   
)
CkpvDeclare ( PatchMap ,
PatchMap_instance   
)
CkpvDeclare ( PatchMgr ,
PatchMgr_instance   
)
CkpvDeclare ( ProxyMgr ,
ProxyMgr_instance   
)
CkpvDeclare ( ReductionMgr ,
ReductionMgr_instance   
)
CkpvDeclare ( PatchMgr ,
PatchMap_patchMgr   
)
CkpvDeclare ( BOCgroup  ,
BOCclass_group   
)
CkpvDeclare ( Communicate ,
comm   
)
CkpvDeclare ( Sync ,
Sync_instance   
)
CkpvDeclare ( infostream  ,
iout_obj   
)
CkpvDeclare ( int  ,
recv_data_idx   
)
CkpvDeclare ( int  ,
recv_ack_idx   
)
CkpvDeclare ( int  ,
recv_bcast_idx   
)
CkpvDeclare ( int  ,
recv_red_idx   
)
CkpvDeclare ( int  ,
recv_eval_command_idx   
)
CkpvDeclare ( int  ,
recv_eval_result_idx   
)
CkpvDeclare ( int  ,
recv_replica_dcd_init_idx   
)
CkpvDeclare ( int  ,
recv_replica_dcd_data_idx   
)
CkpvDeclare ( int  ,
recv_replica_dcd_ack_idx   
)
void initializeReplicaConverseHandlers ( )

Definition at line 252 of file DataExchanger.C.

References recvAck(), recvBcast(), recvData(), recvEvalCommand(), recvEvalResult(), recvRed(), recvReplicaDcdAck(), recvReplicaDcdData(), and recvReplicaDcdInit().

Referenced by ProcessorPrivateInit().

252  {
253  CkpvInitialize(int, recv_data_idx);
254  CkpvInitialize(int, recv_ack_idx);
255  CkpvInitialize(int, recv_bcast_idx);
256  CkpvInitialize(int, recv_red_idx);
257  CkpvInitialize(int, recv_eval_command_idx);
258  CkpvInitialize(int, recv_eval_result_idx);
259  CkpvInitialize(int, recv_replica_dcd_init_idx);
260  CkpvInitialize(int, recv_replica_dcd_data_idx);
261  CkpvInitialize(int, recv_replica_dcd_ack_idx);
262 
263  CkpvAccess(recv_data_idx) = CmiRegisterHandler((CmiHandler)recvData);
264  CkpvAccess(recv_ack_idx) = CmiRegisterHandler((CmiHandler)recvAck);
265  CkpvAccess(recv_red_idx) = CmiRegisterHandler((CmiHandler)recvRed);
266  CkpvAccess(recv_bcast_idx) = CmiRegisterHandler((CmiHandler)recvBcast);
267  CkpvAccess(recv_eval_command_idx) = CmiRegisterHandler((CmiHandler)recvEvalCommand);
268  CkpvAccess(recv_eval_result_idx) = CmiRegisterHandler((CmiHandler)recvEvalResult);
269  CkpvAccess(recv_replica_dcd_init_idx) = CmiRegisterHandler((CmiHandler)recvReplicaDcdInit);
270  CkpvAccess(recv_replica_dcd_data_idx) = CmiRegisterHandler((CmiHandler)recvReplicaDcdData);
271  CkpvAccess(recv_replica_dcd_ack_idx) = CmiRegisterHandler((CmiHandler)recvReplicaDcdAck);
272 
273 #if CMK_IMMEDIATE_MSG && CMK_SMP && ! ( CMK_MULTICORE || CMK_SMP_NO_COMMTHD )
274  int sleep_commthd_idx = CmiRegisterHandler((CmiHandler)recvSleepCommthdMsg);
275  if ( CkMyPe() == 0 && CkNumNodes() == 1 ) {
276  CkPrintf("Charm++ communication thread will sleep due to single-process run.\n");
277  SleepCommthdMsg *msg = (SleepCommthdMsg *)malloc(sizeof(SleepCommthdMsg));
278  CmiSetHandler(msg, sleep_commthd_idx);
279  CmiBecomeImmediate(msg);
280  CmiPushImmediateMsg(msg);
281  }
282 #endif
283 }
void recvRed(DataMessage *dmsg)
void recvReplicaDcdData(ReplicaDcdDataMsg *msg)
Definition: DataExchanger.C:82
void recvEvalResult(DataMessage *dmsg)
void recvBcast(DataMessage *dmsg)
void recvEvalCommand(DataMessage *dmsg)
void recvData(DataMessage *dmsg)
Definition: DataExchanger.C:93
void recvReplicaDcdAck(ReplicaDcdAckMsg *msg)
Definition: DataExchanger.C:87
void recvReplicaDcdInit(ReplicaDcdInitMsg *msg)
Definition: DataExchanger.C:77
void recvAck(DataMessage *dmsg)
Definition: DataExchanger.C:99
void ProcessorPrivateInit ( void  )

Definition at line 57 of file ProcessorPrivate.C.

References initializeReplicaConverseHandlers().

Referenced by all_init().

58 {
59  CkpvInitialize(AtomMap*, AtomMap_instance);
60  CkpvAccess(AtomMap_instance) = 0;
61  CkpvInitialize(BroadcastMgr*, BroadcastMgr_instance);
62  CkpvAccess(BroadcastMgr_instance) = 0;
63  CkpvInitialize(CollectionMaster*, CollectionMaster_instance);
64  CkpvAccess(CollectionMaster_instance) = 0;
65  CkpvInitialize(CollectionMgr*, CollectionMgr_instance);
66  CkpvAccess(CollectionMgr_instance) = 0;
67  CkpvInitialize(LdbCoordinator*, LdbCoordinator_instance);
68  CkpvAccess(LdbCoordinator_instance) = 0;
69  CkpvInitialize(Node*, Node_instance);
70  CkpvAccess(Node_instance) = 0;
71 
72  CkpvInitialize(PatchMap*, PatchMap_instance);
73  CkpvAccess(PatchMap_instance) = 0;
74  CkpvInitialize(PatchMgr*, PatchMgr_instance);
75  CkpvAccess(PatchMgr_instance) = 0;
76  CkpvInitialize(ProxyMgr*, ProxyMgr_instance);
77  CkpvAccess(ProxyMgr_instance) = 0;
78  CkpvInitialize(ReductionMgr*, ReductionMgr_instance);
79  CkpvAccess(ReductionMgr_instance) = 0;
80  CkpvInitialize(PatchMgr*, PatchMap_patchMgr);
81  CkpvAccess(PatchMap_patchMgr) = 0;
82  CkpvInitialize(BOCgroup, BOCclass_group);
83  CkpvAccess(BOCclass_group).dataExchanger.setZero();
84  CkpvInitialize(Communicate*, comm);
85  CkpvAccess(comm) = 0;
86  CkpvInitialize(Sync*, Sync_instance);
87  CkpvAccess(Sync_instance) = 0;
88  CkpvInitialize(infostream, iout_obj);
89 
91 
92 #ifdef PROCTRACE_DEBUG
93  CkpvInitialize(DebugFileTrace*, DebugFileTrace_instance);
94  CkpvAccess(DebugFileTrace_instance) = 0;
95 #endif
96 
97 }
Definition: Node.h:78
Definition: Sync.h:22
void initializeReplicaConverseHandlers()