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 }, 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 }, 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 }, 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 }, 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 }, 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 }, 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 }, 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 }, 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 }, 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 }, new Class<?>[] { null });
196 return (int) paramObj[0];
200 public void ___handleStruct(int structsize1) {
202 Class<?>[] paramCls = new Class<?>[3*structsize1];
203 Class<?>[] paramClsTyp1 = new Class<?>[3*structsize1];
204 Class<?>[] paramClsTyp2 = new Class<?>[3*structsize1];
206 for(int i=0; i < structsize1; i++) {
207 paramCls[pos] = String.class;
208 paramClsTyp1[pos] = null;
209 paramClsTyp2[pos++] = null;
210 paramCls[pos] = float.class;
211 paramClsTyp1[pos] = null;
212 paramClsTyp2[pos++] = null;
213 paramCls[pos] = int.class;
214 paramClsTyp1[pos] = null;
215 paramClsTyp2[pos++] = null;
217 Object[] paramObj = rmiObj.getMethodParams(paramCls,
218 paramClsTyp1, paramClsTyp2);
219 StructJ[] data = new StructJ[structsize1];
220 for (int i=0; i < structsize1; i++) {
221 data[i] = new StructJ();
224 for(int i=0; i < structsize1; i++) {
225 data[i].name = (String) paramObj[pos++];
226 data[i].value = (float) paramObj[pos++];
227 data[i].year = (int) paramObj[pos++];
229 tc.handleStruct(data);
233 private void ___waitRequestInvokeMethod() throws IOException {
237 // Loop continuously waiting for incoming bytes
240 rmiObj.getMethodBytes();
241 int _objectId = rmiObj.getObjectId();
242 if (_objectId == objectId) {
243 // Multiplex based on object Id
244 int methodId = rmiObj.getMethodId();
247 case 0: ___setA(); break;
248 case 1: ___setB(); break;
249 case 2: ___setC(); break;
250 case 3: ___sumArray(); break;
251 case 4: ___setAndGetA(); break;
252 case 5: ___setACAndGetA(); break;
253 case 6: ___callBack(); break;
254 case 7: ___registerCallback(); break;
255 case 8: ____registerCallback(); break;
256 // Special option to register callback
257 case 9: ___regCB(); break;
258 // Struct handling (3 is the size of the struct)
259 case 10: ___handleStruct(structsize1); break;
260 case 11: structsize1 = ___structSize(); break;
262 throw new Error("Method Id not recognized!");
269 public static void main(String[] args) throws Exception {
272 TestClass tc = new TestClass(3, 5f, "7911");
273 TestClass_Skeleton tcSkel = new TestClass_Skeleton(tc, port);
275 /* String[] methodSignatures = TestClass_CBSkeleton.getMethodSignatures();
276 IoTRMIObject rmiObj = new IoTRMIObject(port, methodSignatures);
277 Map<Integer,TestClassInterface> mapCBObject = new HashMap<Integer,TestClassInterface>();
279 // Can replace for-loop with while-loop if necessary
280 for (int i = 1; i < 3; i++) {
281 TestClassInterface tcSkel = new TestClass_CBSkeleton(tc, i);
282 mapCBObject.put(i, tcSkel);
285 Object retObj = null;
287 byte[] method = rmiObj.getMethodBytes();
288 int objId = IoTRMIObject.getObjectId(method);
289 TestClass_CBSkeleton tcSkel = (TestClass_CBSkeleton) mapCBObject.get(objId);
290 if (tcSkel != null) {
291 rmiObj.setMethodBytes(method);
292 retObj = tcSkel.invokeMethod(rmiObj);
294 if (retObj != null) {
295 rmiObj.sendReturnObj(retObj);
300 //System.out.println("Creating 0 object");
301 //TestClass_Skeleton tcSkel1 = new TestClass_Skeleton(tc, rmiObj, objectId);
302 //System.out.println("Creating 1 object");
304 //TestClass_Skeleton tcSkel2 = new TestClass_Skeleton(tc, rmiObj, objectId);
305 //System.out.println("Creating 2 object");
307 /*for (int i = 1; i < 3; i++) {
308 final int objectId = i;
309 Thread thread = new Thread() {
312 TestClass_Skeleton tcSkel = new TestClass_Skeleton(tc, rmiObj, objectId);
313 } catch (Exception ex){
314 ex.printStackTrace();
315 throw new Error("Error instantiating class CallBack_Skeleton!");