7 #ifndef _DATAEXCHANGER_H
8 #define _DATAEXCHANGER_H
12 #include "DataExchanger.decl.h"
14 #define CPROXY_DE(x) ((CProxy_DataExchanger)(x))
20 char core[CmiMsgHeaderSizeBytes];
25 void setMessage(
const char *_data,
int _src,
int _srcPart,
int _size,
int _handler,
int _code) {
30 CmiSetHandler(
core,_handler);
36 char core[CmiMsgHeaderSizeBytes];
44 char core[CmiMsgHeaderSizeBytes];
55 char core[CmiMsgHeaderSizeBytes];
79 void packSend(
int dest,
int partition,
const char *data,
int size,
int handler,
int code=0);
89 void replica_send(
const char *sndbuf,
int sendcount,
int destPart,
int destPE);
void setMessage(const char *_data, int _src, int _srcPart, int _size, int _handler, int _code)
void recvReplicaDcdData(ReplicaDcdDataMsg *msg)
void sendReplicaDcdInit(int dstPart, ReplicaDcdInitMsg *msg, int msgsize)
void packSend(int dst, int dstPart, const char *data, int size, int handler, int code)
static void partition(int *order, const FullAtom *atoms, int begin, int end)
char core[CmiMsgHeaderSizeBytes]
void replica_send(const char *sndbuf, int sendcount, int destPart, int destPE)
void replica_eval(const char *cmdbuf, int targPart, int targPE, DataMessage **precvMsg)
void recvData(DataMessage *dmsg)
char core[CmiMsgHeaderSizeBytes]
int recv_eval_command_idx
void recvReplicaDcdAck(ReplicaDcdAckMsg *msg)
void replica_recv(DataMessage **precvMsg, int srcPart, int srcPE)
void replica_bcast(char *buf, int count, int root)
void sendReplicaDcdData(int dstPart, ReplicaDcdDataMsg *msg, int msgsize)
void recvReplicaDcdInit(ReplicaDcdInitMsg *msg)
char core[CmiMsgHeaderSizeBytes]
void replica_min_double(double *dat, int count)
void sendReplicaDcdAck(int dstPart, ReplicaDcdAckMsg *msg)
CpvExtern(int, breakScheduler)
char core[CmiMsgHeaderSizeBytes]
void replica_sendRecv(const char *sndbuf, int sendcount, int destPart, int destPE, DataMessage **precvMsg, int srcPart, int srcPE)
void recvAck(DataMessage *dmsg)