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 ( int  ,
recv_replica_dcd_ack_idx   
)

CkpvDeclare ( int  ,
recv_replica_dcd_data_idx   
)

CkpvDeclare ( int  ,
recv_replica_dcd_init_idx   
)

CkpvDeclare ( int  ,
recv_eval_result_idx   
)

CkpvDeclare ( int  ,
recv_eval_command_idx   
)

CkpvDeclare ( int  ,
recv_red_idx   
)

CkpvDeclare ( int  ,
recv_bcast_idx   
)

CkpvDeclare ( int  ,
recv_ack_idx   
)

CkpvDeclare ( int  ,
recv_data_idx   
)

CkpvDeclare ( infostream  ,
iout_obj   
)

CkpvDeclare ( Sync ,
Sync_instance   
)

CkpvDeclare ( Communicate ,
comm   
)

CkpvDeclare ( BOCgroup  ,
BOCclass_group   
)

CkpvDeclare ( PatchMgr ,
PatchMap_patchMgr   
)

CkpvDeclare ( ReductionMgr ,
ReductionMgr_instance   
)

CkpvDeclare ( ProxyMgr ,
ProxyMgr_instance   
)

CkpvDeclare ( PatchMgr ,
PatchMgr_instance   
)

CkpvDeclare ( PatchMap ,
PatchMap_instance   
)

CkpvDeclare ( Node ,
Node_instance   
)

CkpvDeclare ( LdbCoordinator ,
LdbCoordinator_instance   
)

CkpvDeclare ( CollectionMgr ,
CollectionMgr_instance   
)

CkpvDeclare ( CollectionMaster ,
CollectionMaster_instance   
)

CkpvDeclare ( BroadcastMgr ,
BroadcastMgr_instance   
)

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.

void initializeReplicaConverseHandlers (  ) 

Definition at line 248 of file DataExchanger.C.

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

Referenced by ProcessorPrivateInit().

00248                                          {
00249   CkpvInitialize(int, recv_data_idx);
00250   CkpvInitialize(int, recv_ack_idx);
00251   CkpvInitialize(int, recv_bcast_idx);
00252   CkpvInitialize(int, recv_red_idx);
00253   CkpvInitialize(int, recv_eval_command_idx);
00254   CkpvInitialize(int, recv_eval_result_idx);
00255   CkpvInitialize(int, recv_replica_dcd_init_idx);
00256   CkpvInitialize(int, recv_replica_dcd_data_idx);
00257   CkpvInitialize(int, recv_replica_dcd_ack_idx);
00258 
00259   CkpvAccess(recv_data_idx) = CmiRegisterHandler((CmiHandler)recvData);                   
00260   CkpvAccess(recv_ack_idx) = CmiRegisterHandler((CmiHandler)recvAck);                     
00261   CkpvAccess(recv_red_idx) = CmiRegisterHandler((CmiHandler)recvRed);                     
00262   CkpvAccess(recv_bcast_idx) = CmiRegisterHandler((CmiHandler)recvBcast);                 
00263   CkpvAccess(recv_eval_command_idx) = CmiRegisterHandler((CmiHandler)recvEvalCommand);    
00264   CkpvAccess(recv_eval_result_idx) = CmiRegisterHandler((CmiHandler)recvEvalResult);      
00265   CkpvAccess(recv_replica_dcd_init_idx) = CmiRegisterHandler((CmiHandler)recvReplicaDcdInit);
00266   CkpvAccess(recv_replica_dcd_data_idx) = CmiRegisterHandler((CmiHandler)recvReplicaDcdData);
00267   CkpvAccess(recv_replica_dcd_ack_idx) = CmiRegisterHandler((CmiHandler)recvReplicaDcdAck);
00268 
00269 #if CMK_IMMEDIATE_MSG && CMK_SMP && ! ( CMK_MULTICORE || CMK_SMP_NO_COMMTHD )
00270   int sleep_commthd_idx = CmiRegisterHandler((CmiHandler)recvSleepCommthdMsg);
00271   if ( CkMyPe() == 0 && CkNumNodes() == 1 ) {
00272     CkPrintf("Charm++ communication thread will sleep due to single-process run.\n");
00273     SleepCommthdMsg *msg = (SleepCommthdMsg *)malloc(sizeof(SleepCommthdMsg));
00274     CmiSetHandler(msg, sleep_commthd_idx);
00275     CmiBecomeImmediate(msg);
00276     CmiPushImmediateMsg(msg);
00277   }
00278 #endif
00279 }

void ProcessorPrivateInit ( void   ) 

Definition at line 57 of file ProcessorPrivate.C.

References initializeReplicaConverseHandlers().

Referenced by all_init().

00058 {
00059   CkpvInitialize(AtomMap*, AtomMap_instance);
00060   CkpvAccess(AtomMap_instance) = 0;
00061   CkpvInitialize(BroadcastMgr*, BroadcastMgr_instance);
00062   CkpvAccess(BroadcastMgr_instance) = 0;
00063   CkpvInitialize(CollectionMaster*, CollectionMaster_instance);
00064   CkpvAccess(CollectionMaster_instance) = 0;
00065   CkpvInitialize(CollectionMgr*, CollectionMgr_instance);
00066   CkpvAccess(CollectionMgr_instance) = 0;
00067   CkpvInitialize(LdbCoordinator*, LdbCoordinator_instance);
00068   CkpvAccess(LdbCoordinator_instance) = 0;
00069   CkpvInitialize(Node*, Node_instance);
00070   CkpvAccess(Node_instance) = 0;
00071 
00072   CkpvInitialize(PatchMap*, PatchMap_instance);
00073   CkpvAccess(PatchMap_instance) = 0;
00074   CkpvInitialize(PatchMgr*, PatchMgr_instance);
00075   CkpvAccess(PatchMgr_instance) = 0;
00076   CkpvInitialize(ProxyMgr*, ProxyMgr_instance);
00077   CkpvAccess(ProxyMgr_instance) = 0;
00078   CkpvInitialize(ReductionMgr*, ReductionMgr_instance);
00079   CkpvAccess(ReductionMgr_instance) = 0;
00080   CkpvInitialize(PatchMgr*, PatchMap_patchMgr);
00081   CkpvAccess(PatchMap_patchMgr) = 0;
00082   CkpvInitialize(BOCgroup, BOCclass_group);
00083   CkpvAccess(BOCclass_group).dataExchanger.setZero();
00084   CkpvInitialize(Communicate*, comm);
00085   CkpvAccess(comm) = 0;
00086   CkpvInitialize(Sync*, Sync_instance);
00087   CkpvAccess(Sync_instance) = 0;
00088   CkpvInitialize(infostream, iout_obj);
00089 
00090   initializeReplicaConverseHandlers();
00091 
00092 #ifdef PROCTRACE_DEBUG
00093   CkpvInitialize(DebugFileTrace*, DebugFileTrace_instance);
00094   CkpvAccess(DebugFileTrace_instance) = 0;
00095 #endif
00096 
00097 }


Generated on Mon Nov 20 01:17:16 2017 for NAMD by  doxygen 1.4.7