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 void handleStruct(StructJ[] data) {
188 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) {
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 tc.handleStruct(data);
229 public void handleEnum(EnumJ[] en) {
235 public int ___enumSize() {
237 Object[] paramObj = rmiObj.getMethodParams(new Class<?>[] { int.class },
238 new Class<?>[] { null });
239 return (int) paramObj[0];
243 public void ___handleEnum(int enumSize1) {
245 Class<?>[] paramCls = new Class<?>[enumSize1];
246 Class<?>[] paramClsVal = new Class<?>[enumSize1];
247 for(int i=0; i < enumSize1; i++) {
248 paramCls[i] = int.class;
249 paramClsVal[i] = null;
251 Object[] paramObj = rmiObj.getMethodParams(paramCls,
254 EnumJ[] enumJ = EnumJ.values();
255 EnumJ[] data = new EnumJ[enumSize1];
256 for (int i=0; i < enumSize1; i++) {
257 data[i] = enumJ[(int) paramObj[i]];
263 private void ___waitRequestInvokeMethod() throws IOException {
268 // Loop continuously waiting for incoming bytes
271 rmiObj.getMethodBytes();
272 int _objectId = rmiObj.getObjectId();
273 if (_objectId == objectId) {
274 // Multiplex based on object Id
275 int methodId = rmiObj.getMethodId();
278 case 0: ___setA(); break;
279 case 1: ___setB(); break;
280 case 2: ___setC(); break;
281 case 3: ___sumArray(); break;
282 case 4: ___setAndGetA(); break;
283 case 5: ___setACAndGetA(); break;
284 case 6: ___callBack(); break;
285 case 7: ___registerCallback(); break;
286 case 8: ____registerCallback(); break;
287 // Special option to register callback
288 case 9: ___regCB(); break;
289 // Struct handling (3 is the size of the struct)
290 case 10: ___handleStruct(structSize1); break;
291 case 11: structSize1 = ___structSize(); break;
292 case 12: ___handleEnum(enumSize1); break;
293 case 13: enumSize1 = ___enumSize(); break;
295 throw new Error("Method Id not recognized!");
302 public static void main(String[] args) throws Exception {
305 TestClass tc = new TestClass(3, 5f, "7911");
306 TestClass_Skeleton tcSkel = new TestClass_Skeleton(tc, port);
308 /* String[] methodSignatures = TestClass_CBSkeleton.getMethodSignatures();
309 IoTRMIObject rmiObj = new IoTRMIObject(port, methodSignatures);
310 Map<Integer,TestClassInterface> mapCBObject = new HashMap<Integer,TestClassInterface>();
312 // Can replace for-loop with while-loop if necessary
313 for (int i = 1; i < 3; i++) {
314 TestClassInterface tcSkel = new TestClass_CBSkeleton(tc, i);
315 mapCBObject.put(i, tcSkel);
318 Object retObj = null;
320 byte[] method = rmiObj.getMethodBytes();
321 int objId = IoTRMIObject.getObjectId(method);
322 TestClass_CBSkeleton tcSkel = (TestClass_CBSkeleton) mapCBObject.get(objId);
323 if (tcSkel != null) {
324 rmiObj.setMethodBytes(method);
325 retObj = tcSkel.invokeMethod(rmiObj);
327 if (retObj != null) {
328 rmiObj.sendReturnObj(retObj);
333 //System.out.println("Creating 0 object");
334 //TestClass_Skeleton tcSkel1 = new TestClass_Skeleton(tc, rmiObj, objectId);
335 //System.out.println("Creating 1 object");
337 //TestClass_Skeleton tcSkel2 = new TestClass_Skeleton(tc, rmiObj, objectId);
338 //System.out.println("Creating 2 object");
340 /*for (int i = 1; i < 3; i++) {
341 final int objectId = i;
342 Thread thread = new Thread() {
345 TestClass_Skeleton tcSkel = new TestClass_Skeleton(tc, rmiObj, objectId);
346 } catch (Exception ex){
347 ex.printStackTrace();
348 throw new Error("Error instantiating class CallBack_Skeleton!");