class LocalComm {
- Table t1;
- Table t2;
+ Table t1;
+ Table t2;
- LocalComm(Table _t1, Table _t2) {
- t1 = _t1;
- t2 = _t2;
- }
+ LocalComm(Table _t1, Table _t2) {
+ t1 = _t1;
+ t2 = _t2;
+ }
- char[] sendDataToLocalDevice(Long deviceId, char[] data) throws InterruptedException{
- System.out.println("Passing Locally");
+ char[] sendDataToLocalDevice(Long deviceId, 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");
- }
+ 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];
- }
+ return new char[0];
+ }
}