+#ifndef LOCALCOMM_H
+#define LOCALCOMM_H
+#include "common.h"
class LocalComm {
- private Table t1;
- private Table t2;
+private:
+ Table *t1;
+ Table *t2;
- public LocalComm(Table _t1, Table _t2) {
- t1 = _t1;
- t2 = _t2;
+public:
+ LocalComm(Table *_t1, Table *_t2) :
+ t1(_t1),
+ t2(_t2) {
}
- public Array<char> *sendDataToLocalDevice(Long deviceId, Array<char> *data) throws InterruptedException {
- System.out.println("Passing Locally");
-
- if (deviceId == t1.getMachineId()) {
- // return t1.localCommInput(data);
- } else if (deviceId == t2.getMachineId()) {
- // return t2.localCommInput(data);
- } else {
- throw new Error("Cannot send to " + deviceId + " using this local comm");
- }
-
- return new char[0];
- }
-}
+ public Array<char> *sendDataToLocalDevice(int64_t deviceId, Array<char> *data);
+};
+#endif