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;
35 * Constructor (for stub) - send and recv from the perspective of RMI socket servers
37 public IoTRMICommClient(int _localPortSend, int _localPortRecv, int _portSend, int _portRecv, String _address, int _rev) throws
38 ClassNotFoundException, InstantiationException,
39 IllegalAccessException, IOException {
42 rmiClientRecv = new IoTSocketClient(_localPortSend, _portSend, _address, _rev);
43 rmiClientSend = new IoTSocketClient(_localPortRecv, _portRecv, _address, _rev);
44 waitForPacketsOnClient();
49 * waitForPacketsOnClient() starts a thread that waits for packet bytes on client side
51 public void waitForPacketsOnClient() {
53 Thread thread = new Thread() {
55 byte[] packetBytes = null;
58 packetBytes = rmiClientRecv.receiveBytes(packetBytes);
59 if (packetBytes != null) {
60 int packetType = IoTRMIComm.getPacketType(packetBytes);
61 if (packetType == IoTRMIUtil.METHOD_TYPE) {
62 System.out.println("Method packet: " + Arrays.toString(packetBytes));
63 methodQueue.offer(packetBytes);
64 } else if (packetType == IoTRMIUtil.RET_VAL_TYPE) {
65 System.out.println("Return value packet: " + Arrays.toString(packetBytes));
66 returnQueue.offer(packetBytes);
68 throw new Error("IoTRMICommClient: Packet type is unknown: " + packetType);
72 } catch (Exception ex) {
74 throw new Error("IoTRMICommClient: Error receiving return value bytes on client!");
84 * sendReturnObj() for non-struct objects (client side)
86 public synchronized void sendReturnObj(Object retObj, byte[] methodBytes) {
88 // Send back return value
89 byte[] retObjBytes = IoTRMIUtil.getObjectBytes(retObj);
90 // Send return value together with OBJECT_ID and METHOD_ID for arbitration
91 int objMethIdLen = IoTRMIUtil.OBJECT_ID_LEN + IoTRMIUtil.METHOD_ID_LEN;
92 int headerLen = objMethIdLen + IoTRMIUtil.PACKET_TYPE_LEN;
93 byte[] retAllBytes = new byte[headerLen + retObjBytes.length];
94 // Copy OBJECT_ID and METHOD_ID
95 System.arraycopy(methodBytes, 0, retAllBytes, 0, objMethIdLen);
96 int packetType = IoTRMIUtil.RET_VAL_TYPE; // This is a return value
97 byte[] packetTypeBytes = IoTRMIUtil.intToByteArray(packetType);
98 System.arraycopy(packetTypeBytes, 0, retAllBytes, objMethIdLen, IoTRMIUtil.PACKET_TYPE_LEN);
99 // Copy array of bytes (return object)
100 System.arraycopy(retObjBytes, 0, retAllBytes, headerLen, retObjBytes.length);
102 rmiClientSend.sendBytes(retAllBytes);
103 } catch (IOException ex) {
104 ex.printStackTrace();
105 throw new Error("IoTRMICommClient: Error sending bytes in sendReturnObj()!");
111 * sendReturnObj() overloaded to send multiple return objects for structs (client side)
113 public synchronized void sendReturnObj(Class<?>[] retCls, Object[] retObj, byte[] methodBytes) {
115 // Send back return value
116 byte[] retObjBytes = returnToBytes(retCls, retObj);
117 // Send return value together with OBJECT_ID and METHOD_ID for arbitration
118 int objMethIdLen = IoTRMIUtil.OBJECT_ID_LEN + IoTRMIUtil.METHOD_ID_LEN;
119 int headerLen = objMethIdLen + IoTRMIUtil.PACKET_TYPE_LEN;
120 byte[] retAllBytes = new byte[headerLen + retObjBytes.length];
121 // Copy OBJECT_ID and METHOD_ID
122 System.arraycopy(methodBytes, 0, retAllBytes, 0, objMethIdLen);
123 int packetType = IoTRMIUtil.RET_VAL_TYPE; // This is a return value
124 byte[] packetTypeBytes = IoTRMIUtil.intToByteArray(packetType);
125 System.arraycopy(packetTypeBytes, 0, retAllBytes, objMethIdLen, IoTRMIUtil.PACKET_TYPE_LEN);
126 // Copy array of bytes (return object)
128 rmiClientSend.sendBytes(retAllBytes);
129 } catch (IOException ex) {
130 ex.printStackTrace();
131 throw new Error("IoTRMICommClient: Error sending bytes in sendReturnObj()!");
137 * remoteCall() calls a method remotely by passing in parameters (client side)
139 public synchronized void remoteCall(int objectId, int methodId, Class<?>[] paramCls, Object[] paramObj) {
142 byte[] methodBytes = methodToBytes(objectId, methodId, paramCls, paramObj);
144 rmiClientSend.sendBytes(methodBytes);
145 } catch (IOException ex) {
146 ex.printStackTrace();
147 throw new Error("IoTRMICommClient: Error when sending bytes in remoteCall()!");