3 import java.io.IOException;
4 import java.nio.ByteBuffer;
5 import java.util.Arrays;
6 import java.util.ArrayList;
7 import java.util.HashMap;
11 import java.lang.reflect.*;
13 import java.util.concurrent.*;
14 import java.util.concurrent.atomic.AtomicBoolean;
17 /** Class IoTRMICommClient is a class that extends IoTRMIComm
19 * This is a version of IoTRMIComm that sits on the main stub.
21 * @author Rahmadi Trimananda <rtrimana @ uci.edu>
25 public class IoTRMICommClient extends IoTRMIComm {
30 private IoTSocketClient rmiClientSend;
31 private IoTSocketClient rmiClientRecv;
32 private int objectIdCounter = Integer.MAX_VALUE;
36 * Constructor (for stub) - send and recv from the perspective of RMI socket servers
38 public IoTRMICommClient(int _localPortSend, int _localPortRecv, int _portSend, int _portRecv, String _address, int _rev) throws
39 ClassNotFoundException, InstantiationException,
40 IllegalAccessException, IOException {
43 rmiClientRecv = new IoTSocketClient(_localPortSend, _portSend, _address, _rev);
44 rmiClientSend = new IoTSocketClient(_localPortRecv, _portRecv, _address, _rev);
45 waitForPacketsOnClient();
50 * waitForPacketsOnClient() starts a thread that waits for packet bytes on client side
52 public void waitForPacketsOnClient() {
54 Thread thread = new Thread() {
56 byte[] packetBytes = null;
59 packetBytes = rmiClientRecv.receiveBytes(packetBytes);
60 if (packetBytes != null) {
61 int packetType = IoTRMIComm.getPacketType(packetBytes);
62 if (packetType == IoTRMIUtil.METHOD_TYPE) {
63 System.out.println("Method packet: " + Arrays.toString(packetBytes));
64 methodQueue.offer(packetBytes);
65 } else if (packetType == IoTRMIUtil.RET_VAL_TYPE) {
66 System.out.println("Return value packet: " + Arrays.toString(packetBytes));
67 returnQueue.offer(packetBytes);
69 throw new Error("IoTRMIComm: Packet type is unknown: " + packetType);
73 } catch (Exception ex) {
75 throw new Error("IoTRMIComm: Error receiving return value bytes on client!");
85 * sendReturnObj() for non-struct objects (client side)
87 public synchronized void sendReturnObj(Object retObj, byte[] methodBytes) {
89 // Send back return value
90 byte[] retObjBytes = IoTRMIUtil.getObjectBytes(retObj);
91 // Send return value together with OBJECT_ID and METHOD_ID for arbitration
92 int objMethIdLen = IoTRMIUtil.OBJECT_ID_LEN + IoTRMIUtil.METHOD_ID_LEN;
93 int headerLen = objMethIdLen + IoTRMIUtil.PACKET_TYPE_LEN;
94 byte[] retAllBytes = new byte[headerLen + retObjBytes.length];
95 // Copy OBJECT_ID and METHOD_ID
96 System.arraycopy(methodBytes, 0, retAllBytes, 0, objMethIdLen);
97 int packetType = IoTRMIUtil.RET_VAL_TYPE; // This is a return value
98 byte[] packetTypeBytes = IoTRMIUtil.intToByteArray(packetType);
99 System.arraycopy(packetTypeBytes, 0, retAllBytes, objMethIdLen, IoTRMIUtil.PACKET_TYPE_LEN);
100 // Copy array of bytes (return object)
101 System.arraycopy(retObjBytes, 0, retAllBytes, headerLen, retObjBytes.length);
103 rmiClientSend.sendBytes(retAllBytes);
104 } catch (IOException ex) {
105 ex.printStackTrace();
106 throw new Error("IoTRMICommClient: Error sending bytes in sendReturnObj()!");
112 * sendReturnObj() overloaded to send multiple return objects for structs (client side)
114 public synchronized void sendReturnObj(Class<?>[] retCls, Object[] retObj, byte[] methodBytes) {
116 // Send back return value
117 byte[] retObjBytes = returnToBytes(retCls, retObj);
118 // Send return value together with OBJECT_ID and METHOD_ID for arbitration
119 int objMethIdLen = IoTRMIUtil.OBJECT_ID_LEN + IoTRMIUtil.METHOD_ID_LEN;
120 int headerLen = objMethIdLen + IoTRMIUtil.PACKET_TYPE_LEN;
121 byte[] retAllBytes = new byte[headerLen + retObjBytes.length];
122 // Copy OBJECT_ID and METHOD_ID
123 System.arraycopy(methodBytes, 0, retAllBytes, 0, objMethIdLen);
124 int packetType = IoTRMIUtil.RET_VAL_TYPE; // This is a return value
125 byte[] packetTypeBytes = IoTRMIUtil.intToByteArray(packetType);
126 System.arraycopy(packetTypeBytes, 0, retAllBytes, objMethIdLen, IoTRMIUtil.PACKET_TYPE_LEN);
127 // Copy array of bytes (return object)
129 rmiClientSend.sendBytes(retAllBytes);
130 } catch (IOException ex) {
131 ex.printStackTrace();
132 throw new Error("IoTRMICommClient: Error sending bytes in sendReturnObj()!");
138 * remoteCall() calls a method remotely by passing in parameters (client side)
140 public synchronized void remoteCall(int objectId, int methodId, Class<?>[] paramCls, Object[] paramObj) {
143 byte[] methodBytes = methodToBytes(objectId, methodId, paramCls, paramObj);
145 rmiClientSend.sendBytes(methodBytes);
146 } catch (IOException ex) {
147 ex.printStackTrace();
148 throw new Error("IoTRMICommClient: Error when sending bytes in remoteCall()!");