Reverting back the first benchmark (now works with less threads); synchronization...
[iot2.git] / benchmarks / Java / SmartLightsController / CameraCallback_Skeleton.java
index 0e4b30d2245dd47195e6ed40cf734989c7cbd7bf..74103684ee37dbf06fca49e33f43a5510207ab06 100644 (file)
@@ -66,33 +66,15 @@ public class CameraCallback_Skeleton implements CameraCallback {
                return didAlreadyInitWaitInvoke.get();
        }
 
-       public void newCameraFrameAvailable(CameraSmart _camera) {
-               mainObj.newCameraFrameAvailable(_camera);
+       public void newCameraFrameAvailable(byte latestFrame[], long timeStamp) {
+               mainObj.newCameraFrameAvailable(latestFrame, timeStamp);
        }
 
        public void ___newCameraFrameAvailable() {
                byte[] localMethodBytes = methodBytes;
                rmiComm.setGetMethodBytes();
-               Object[] paramObj = rmiComm.getMethodParams(new Class<?>[] { int[].class }, new Class<?>[] { null }, localMethodBytes);
-               try {
-                       int[] stubIdArray0 = (int[]) paramObj[0];
-                       int objIdRecv0 = stubIdArray0[0];
-                       CameraSmart newStub0 = null;
-                       if(!IoTRMIUtil.mapStub.containsKey(objIdRecv0)) {
-                               newStub0 = new CameraSmart_Stub(rmiComm, objIdRecv0);
-                               IoTRMIUtil.mapStub.put(objIdRecv0, newStub0);
-                               rmiComm.setObjectIdCounter(objIdRecv0);
-                               rmiComm.decrementObjectIdCounter();
-                       }
-                       else {
-                               newStub0 = (CameraSmart_Stub) IoTRMIUtil.mapStub.get(objIdRecv0);
-                       }
-                       CameraSmart stub0 = newStub0;
-                       newCameraFrameAvailable(stub0);
-               } catch(Exception ex) {
-                       ex.printStackTrace();
-                       throw new Error("Exception from callback object instantiation!");
-               }
+               Object[] paramObj = rmiComm.getMethodParams(new Class<?>[] { byte[].class, long.class }, new Class<?>[] { null, null }, localMethodBytes);
+               newCameraFrameAvailable((byte[]) paramObj[0], (long) paramObj[1]);
        }
 
        public void ___waitRequestInvokeMethod() throws IOException {
@@ -123,7 +105,6 @@ public class CameraCallback_Skeleton implements CameraCallback {
                                                catch (Exception ex) {
                                                        ex.printStackTrace();
                                                }
-                                               //System.out.println("Thread done!");
                                        }
                                }.start();
                                break;