1 package iotrmi.Java.sample;
3 import java.io.IOException;
4 import java.util.Arrays;
7 import java.util.HashMap;
9 import iotrmi.Java.IoTRMIObject;
10 import iotrmi.Java.IoTRMICall;
12 public class TestClass_Skeleton implements TestClassInterface {
17 private int objectId = 0; // Default value is 0
18 private static int objIdCnt = 0; // Counter for callback object Ids
19 private TestClassInterface tc;
21 private IoTRMIObject rmiObj;
22 private IoTRMICall rmiCall;
23 private CallBackInterface cbstub;
29 public TestClass_Skeleton(TestClass _tc, int _port) throws
30 ClassNotFoundException, InstantiationException,
31 IllegalAccessException, IOException {
35 rmiObj = new IoTRMIObject(_port);
36 ___waitRequestInvokeMethod();
40 public void setA(int _int) {
46 public void ___setA() {
48 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { int.class },
49 new Class<?>[] { null });
50 setA((int) paramObj[0]);
54 public void setB(float _float) {
60 public void ___setB() {
62 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { float.class },
63 new Class<?>[] { null });
64 setB((float) paramObj[0]);
68 public void setC(String _string) {
74 public void ___setC() {
76 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { String.class },
77 new Class<?>[] { null });
78 setC((String) paramObj[0]);
82 public String sumArray(String[] newA) {
84 return tc.sumArray(newA);
88 public void ___sumArray() throws IOException {
90 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { String[].class },
91 new Class<?>[] { null });
92 Object retObj = sumArray((String[]) paramObj[0]);
93 rmiObj.sendReturnObj(retObj);
97 public int setAndGetA(int newA) {
99 return tc.setAndGetA(newA);
103 public void ___setAndGetA() throws IOException {
105 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { int.class },
106 new Class<?>[] { null });
107 Object retObj = setAndGetA((int) paramObj[0]);
108 rmiObj.sendReturnObj(retObj);
112 public int setACAndGetA(String newC, int newA) {
114 return tc.setACAndGetA(newC, newA);
118 public void ___setACAndGetA() throws IOException {
120 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { String.class, int.class },
121 new Class<?>[] { null, null });
122 Object retObj = setACAndGetA((String) paramObj[0], (int) paramObj[1]);
123 rmiObj.sendReturnObj(retObj);
127 public void registerCallback(CallBackInterface _cb) {
129 tc.registerCallback(_cb);
133 public void ___registerCallback() throws IOException {
135 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { int.class, String.class, int.class },
136 new Class<?>[] { null, null, null });
137 CallBackInterface cbstub = new CallBack_Stub((int) paramObj[0], (String) paramObj[1], (int) paramObj[2]);
138 registerCallback((CallBackInterface) cbstub);
142 public void registerCallback(CallBackInterface[] _cb) {
144 tc.registerCallback(_cb);
148 // Use 4 underscores because this is a second instance of registerCallback
149 public void ____registerCallback() throws IOException {
151 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { int.class },
152 new Class<?>[] { null });
153 int numStubs = (int) paramObj[0];
154 CallBackInterface[] stub = new CallBackInterface[numStubs];
155 for (int objId = 0; objId < numStubs; objId++) {
156 stub[objId] = new CallBack_CBStub(rmiCall, objIdCnt);
159 registerCallback(stub);
163 public void ___regCB() throws IOException {
165 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { int.class, String.class, int.class },
166 new Class<?>[] { null, null, null });
167 //String[] methodSignatures = CallBack_CBStub.getMethodSignatures();
168 rmiCall = new IoTRMICall((int) paramObj[0], (String) paramObj[1], (int) paramObj[2]);
169 System.out.println("Creating a new IoTRMICall object");
173 public int callBack() {
175 return tc.callBack();
179 public void ___callBack() throws IOException {
181 Object retObj = callBack();
182 rmiObj.sendReturnObj(retObj);
186 public StructJ[] handleStruct(StructJ[] data) {
188 return tc.handleStruct(data);
192 public int ___structSize() {
194 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { int.class },
195 new Class<?>[] { null });
196 return (int) paramObj[0];
200 public void ___handleStruct(int structsize1) throws IOException {
202 Class<?>[] paramCls = new Class<?>[3*structsize1];
203 Class<?>[] paramClsVal = new Class<?>[3*structsize1];
205 for(int i=0; i < structsize1; i++) {
206 paramCls[pos] = String.class;
207 paramClsVal[pos++] = null;
208 paramCls[pos] = float.class;
209 paramClsVal[pos++] = null;
210 paramCls[pos] = int.class;
211 paramClsVal[pos++] = null;
213 Object[] paramObj = rmiObj.getMethodParams(paramCls,
215 StructJ[] data = new StructJ[structsize1];
216 for (int i=0; i < structsize1; i++) {
217 data[i] = new StructJ();
220 for(int i=0; i < structsize1; i++) {
221 data[i].name = (String) paramObj[pos++];
222 data[i].value = (float) paramObj[pos++];
223 data[i].year = (int) paramObj[pos++];
225 // Just the following if there is no returned value
226 //tc.handleStruct(data);
227 StructJ[] retStruct = tc.handleStruct(data);
228 // Return length first
229 int structsize2 = retStruct.length;
230 Object retObj = structsize2;
231 rmiObj.sendReturnObj(retObj);
232 // Send the actual struct members
233 // Calculate the size of the array
234 Class<?>[] retCls = new Class<?>[3*structsize2];
235 Object[] retObj2 = new Object[3*structsize2];
236 // Handle with for loop
238 for(int i = 0; i < structsize2; i++) {
239 retCls[pos] = String.class;
240 retObj2[pos++] = data[i].name;
241 retCls[pos] = float.class;
242 retObj2[pos++] = data[i].value;
243 retCls[pos] = int.class;
244 retObj2[pos++] = data[i].year;
246 rmiObj.sendReturnObj(retCls, retObj2);
250 public EnumJ[] handleEnum(EnumJ[] en) {
252 return tc.handleEnum(en);
256 public void ___handleEnum() throws IOException {
258 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { int[].class },
259 new Class<?>[] { null });
261 int paramInt[] = (int[]) paramObj[0];
262 int enumSize1 = paramInt.length;
263 EnumJ[] enumJ = EnumJ.values();
264 EnumJ[] data = new EnumJ[enumSize1];
265 for (int i=0; i < enumSize1; i++) {
266 data[i] = enumJ[paramInt[i]];
268 // if void, just "handleEnum(data)"
269 // this is when we have return value EnumJ[]
270 EnumJ[] retEnum = handleEnum(data);
272 int enumSize2 = retEnum.length;
273 // Now send the array of integers
274 int[] retEnumInt = new int[enumSize2];
275 for (int i=0; i < enumSize2; i++) {
276 retEnumInt[i] = retEnum[i].ordinal();
278 Object retObj = retEnumInt;
279 rmiObj.sendReturnObj(retObj);
283 private void ___waitRequestInvokeMethod() throws IOException {
288 // Loop continuously waiting for incoming bytes
291 rmiObj.getMethodBytes();
292 int _objectId = rmiObj.getObjectId();
293 if (_objectId == objectId) {
294 // Multiplex based on object Id
295 int methodId = rmiObj.getMethodId();
298 case 0: ___setA(); break;
299 case 1: ___setB(); break;
300 case 2: ___setC(); break;
301 case 3: ___sumArray(); break;
302 case 4: ___setAndGetA(); break;
303 case 5: ___setACAndGetA(); break;
304 case 6: ___callBack(); break;
305 case 7: ___registerCallback(); break;
306 case 8: ____registerCallback(); break;
307 // Special option to register callback
308 case 9: ___regCB(); break;
309 // Struct handling (3 is the size of the struct)
310 case 10: ___handleStruct(structSize1); break;
311 case 11: structSize1 = ___structSize(); break;
312 case 12: ___handleEnum(); break;
314 throw new Error("Method Id not recognized!");
321 public static void main(String[] args) throws Exception {
324 TestClass tc = new TestClass(3, 5f, "7911");
325 TestClass_Skeleton tcSkel = new TestClass_Skeleton(tc, port);