Updating stubs and skeletons for the second benchmark and drivers; tested the second...

[iot2.git] / benchmarks / drivers / Java / IHome / SpeakerSmartCallback_Stub.java

diff --git a/benchmarks/drivers/Java/IHome/SpeakerSmartCallback_Stub.java b/benchmarks/drivers/Java/IHome/SpeakerSmartCallback_Stub.java
new file mode 100644 (file)
index 0000000..3a4a01d
--- /dev/null
+++ b/benchmarks/drivers/Java/IHome/SpeakerSmartCallback_Stub.java
@@ -0,0 +1,47 @@
+package iotcode.IHome;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.concurrent.atomic.AtomicBoolean;
+import iotrmi.Java.IoTRMIComm;
+import iotrmi.Java.IoTRMICommClient;
+import iotrmi.Java.IoTRMICommServer;
+import iotrmi.Java.IoTRMIUtil;
+
+import iotcode.interfaces.*;
+
+public class SpeakerSmartCallback_Stub implements SpeakerSmartCallback {
+
+       private int objectId = 2;
+       private IoTRMIComm rmiComm;
+       // Synchronization variables
+       
+
+       public SpeakerSmartCallback_Stub(int _localPortSend, int _localPortRecv, int _portSend, int _portRecv, String _skeletonAddress, int _rev) throws Exception {
+               if (_localPortSend != 0 && _localPortRecv != 0) {
+                       rmiComm = new IoTRMICommClient(_localPortSend, _localPortRecv, _portSend, _portRecv, _skeletonAddress, _rev);
+               } else
+               {
+                       rmiComm = new IoTRMICommClient(_portSend, _portRecv, _skeletonAddress, _rev);
+               }
+               IoTRMIUtil.mapStub.put(objectId, this);
+       }
+
+       public SpeakerSmartCallback_Stub(IoTRMIComm _rmiComm, int _objectId) throws Exception {
+               rmiComm = _rmiComm;
+               objectId = _objectId;
+       }
+
+       public void speakerDone() {
+               int methodId = 0;
+               Class<?> retType = void.class;
+               Class<?>[] paramCls = new Class<?>[] {  };
+               Object[] paramObj = new Object[] {  };
+               rmiComm.remoteCall(objectId, methodId, paramCls, paramObj);
+       }
+
+}