| version 1.1007 | version 1.1008 |
|---|
| |
| | |
| class ProxyDataMsg; | class ProxyDataMsg; |
| class ProxyAtomsMsg; | class ProxyAtomsMsg; |
| class ProxyAllMsg; | //class ProxyAllMsg; |
| | |
| | #define PROXYMSGNOTBUFFERED 0 |
| | #define PROXYDATAMSGBUFFERED 1 |
| | #define PROXYALLMSGBUFFERED 2 |
| | |
| class ProxyPatch : public Patch | class ProxyPatch : public Patch |
| { | { |
| |
| | |
| void receiveAtoms(ProxyAtomsMsg*); | void receiveAtoms(ProxyAtomsMsg*); |
| void receiveData(ProxyDataMsg*); | void receiveData(ProxyDataMsg*); |
| void receiveAll(ProxyAllMsg*); | void receiveAll(ProxyDataMsg*); |
| | |
| void setSpanningTree(int, int*, int); | void setSpanningTree(int, int*, int); |
| int getSpanningTreeParent() { return parent; } | int getSpanningTreeParent() { return parent; } |
| |
| private: | private: |
| | |
| void sendResults(void); | void sendResults(void); |
| ProxyDataMsg* msgBuffer; | |
| ProxyAllMsg* msgAllBuffer; | //"proxyMsgBufferStatus" indicates whether there's a ProxyDataMsg buffered |
| | // and waiting to be processed, while "curProxyMsg" points to |
| | // the actual msg. This msg will be freed at the next step. --Chao Mei |
| | int proxyMsgBufferStatus; |
| | ProxyDataMsg* curProxyMsg; |
| | ProxyDataMsg* prevProxyMsg; |
| | |
| // for spanning tree | // for spanning tree |
| ProxyCombinedResultMsg *msgCBuffer; | ProxyCombinedResultMsg *msgCBuffer; |