private static volatile boolean sIsPlatformInitialized = false;
private static QualityOfService sPlatformQualityOfService = QualityOfService.NA;
+ private static volatile boolean sIsStopPlatform = false;
+
private OcPlatform() {
}
* @param platformConfig platform configuration
*/
public synchronized static void Configure(PlatformConfig platformConfig) {
+ if (sIsStopPlatform)
+ {
+ OcPlatform.start();
+ sIsStopPlatform = false;
+ }
+
if (!sIsPlatformInitialized) {
CaInterface.initialize(platformConfig.getActivity(), platformConfig.getContext());
platformConfig.getIpAddress(),
platformConfig.getPort(),
platformConfig.getQualityOfService().getValue(),
- platformConfig.getSvrDbPath()
+ platformConfig.getSvrDbPath(),
+ platformConfig.getDBDefaultPath(),
+ platformConfig.getDBRescuePath(),
+ platformConfig.getKeySize(),
+ platformConfig.getKey(),
+ platformConfig.getAvailableTransportType()
);
sIsPlatformInitialized = true;
String ipAddress,
int port,
int qualityOfService,
- String dbPath);
+ String dbPath,
+ String dbPathDefault,
+ String dbRescuePath,
+ int keySize,
+ byte[] key,
+ int transport);
+
+ /**
+ * API for stop all process of the OcPlatform.
+ * All of threads and memory will be terminated by this API.
+ * Iotivity Core can be started again through Configure(PlatformConfig platformConfig) API.
+ * Both Configure and Shutdown API is filtering for duplicated calling even while processing.
+ * <p>
+ * Note: This API is for both server and client side.
+ * </p>
+ */
+ public synchronized static void Shutdown() {
+ if (!sIsStopPlatform)
+ {
+ OcPlatform.stop();
+ sIsStopPlatform = true;
+ sIsPlatformInitialized = false;
+ }
+ }
+
+ private static native void stop();
+ private static native void start();
/**
* API for notifying base that resource's attributes have changed.
) throws OcException;
/**
+ * Set param Info
+ *
+ * @param ocDeviceInfo object containing all the device specific information
+ * @throws OcException if failure
+ */
+ public static void setPropertyValue(
+ int path, String propName, String propValue) throws OcException {
+ OcPlatform.initCheck();
+ OcPlatform.setPropertyValue1(path, propName, propValue);
+ }
+
+ public static void setPropertyValue(
+ int path, String propName, List<String> propValue) throws OcException {
+ OcPlatform.initCheck();
+ OcPlatform.setPropertyValue0(path, propName, propValue.toArray(new String[propValue.size()]));
+ }
+
+ public static void getPropertyValue(
+ int path, String propName, String propValue) throws OcException {
+ OcPlatform.initCheck();
+ OcPlatform.getPropertyValue0(path, propName, propValue);
+ }
+
+ private static native void setPropertyValue1(
+ int path,
+ String propName,
+ String propValue
+ ) throws OcException;
+
+
+ private static native void setPropertyValue0(
+ int path,
+ String propName,
+ String[] propValue
+ ) throws OcException;
+
+ private static native void getPropertyValue0(
+ int path,
+ String propName,
+ String propValue
+ ) throws OcException;
+
+ /**
* Register Platform Info
*
* @param ocPlatformInfo object containing all the platform specific information
throws OcException;
/**
- * API to publish resource to remote resource-directory.
- *
- * @param host Host Address of a service to publish resource.
- * @param connectivityTypeSet Set of types of connectivity. Example: IP
- * @param onPublishResourceListener Handles events, success states and failure states.
- * @throws OcException if failure
- */
- public static void publishResourceToRD(
- String host,
- EnumSet<OcConnectivityType> connectivityTypeSet,
- OnPublishResourceListener onPublishResourceListener) throws OcException {
- OcPlatform.initCheck();
-
- int connTypeInt = 0;
-
- for (OcConnectivityType connType : OcConnectivityType.values()) {
- if (connectivityTypeSet.contains(connType)) {
- connTypeInt |= connType.getValue();
- }
- }
-
- OcPlatform.publishResourceToRD0(
- host,
- connTypeInt,
- onPublishResourceListener,
- sPlatformQualityOfService.getValue()
- );
- }
-
- /**
- * API to publish resource to remote resource-directory.
- *
- * @param host Host Address of a service to publish resource.
- * @param connectivityTypeSet Set of types of connectivity. Example: IP
- * @param onPublishResourceListener Handles events, success states and failure states.
- * @param qualityOfService the quality of communication.
- * @throws OcException if failure
- */
- public static void publishResourceToRD(
- String host,
- EnumSet<OcConnectivityType> connectivityTypeSet,
- OnPublishResourceListener onPublishResourceListener,
- QualityOfService qualityOfService) throws OcException {
- OcPlatform.initCheck();
-
- int connTypeInt = 0;
-
- for (OcConnectivityType connType : OcConnectivityType.values()) {
- if (connectivityTypeSet.contains(connType)) {
- connTypeInt |= connType.getValue();
- }
- }
-
- OcPlatform.publishResourceToRD0(
- host,
- connTypeInt,
- onPublishResourceListener,
- qualityOfService.getValue()
- );
- }
-
- private static native void publishResourceToRD0(
- String host,
- int connectivityType,
- OnPublishResourceListener onPublishResourceListener,
- int qualityOfService) throws OcException;
-
- /**
- * API to publish resource to remote resource-directory.
- *
- * @param host Host Address of a service to publish resource.
- * @param connectivityTypeSet Set of types of connectivity. Example: IP
- * @param ocResourceHandleList reference to list of resource handles to be published.
- * @param onPublishResourceListener Handles events, success states and failure states.
- * @throws OcException if failure
- */
- public static void publishResourceToRD(
- String host,
- EnumSet<OcConnectivityType> connectivityTypeSet,
- List<OcResourceHandle> ocResourceHandleList,
- OnPublishResourceListener onPublishResourceListener) throws OcException {
- OcPlatform.initCheck();
-
- int connTypeInt = 0;
-
- for (OcConnectivityType connType : OcConnectivityType.values()) {
- if (connectivityTypeSet.contains(connType)) {
- connTypeInt |= connType.getValue();
- }
- }
-
- OcPlatform.publishResourceToRD1(
- host,
- connTypeInt,
- ocResourceHandleList.toArray(
- new OcResourceHandle[ocResourceHandleList.size()]),
- onPublishResourceListener,
- sPlatformQualityOfService.getValue()
- );
- }
-
- /**
- * API to publish resource to remote resource-directory.
- *
- * @param host Host IP Address of a service to publish resource.
- * @param connectivityTypeSet Set of types of connectivity. Example: IP
- * @param ocResourceHandleList reference to list of resource handles to be published.
- * @param onPublishResourceListener Handles events, success states and failure states.
- * @param qualityOfService the quality of communication
- * @throws OcException if failure
- */
- public static void publishResourceToRD(
- String host,
- EnumSet<OcConnectivityType> connectivityTypeSet,
- List<OcResourceHandle> ocResourceHandleList,
- OnPublishResourceListener onPublishResourceListener,
- QualityOfService qualityOfService) throws OcException {
- OcPlatform.initCheck();
-
- int connTypeInt = 0;
-
- for (OcConnectivityType connType : OcConnectivityType.values()) {
- if (connectivityTypeSet.contains(connType)) {
- connTypeInt |= connType.getValue();
- }
- }
-
- OcPlatform.publishResourceToRD1(
- host,
- connTypeInt,
- ocResourceHandleList.toArray(
- new OcResourceHandle[ocResourceHandleList.size()]),
- onPublishResourceListener,
- qualityOfService.getValue()
- );
- }
-
- private static native void publishResourceToRD1(
- String host,
- int connectivityType,
- OcResourceHandle[] ocResourceHandleArray,
- OnPublishResourceListener onPublishResourceListener,
- int qualityOfService) throws OcException;
-
- /**
- * API to delete resource from remote resource-directory.
- *
- * @param host Host Address of a service to publish resource.
- * @param connectivityTypeSet Set of types of connectivity. Example: IP
- * @param onDeleteResourceListener Handles events, success states and failure states.
- * @throws OcException if failure
- */
- public static void deleteResourceFromRD(
- String host,
- EnumSet<OcConnectivityType> connectivityTypeSet,
- OnDeleteResourceListener onDeleteResourceListener) throws OcException {
- OcPlatform.initCheck();
-
- int connTypeInt = 0;
-
- for (OcConnectivityType connType : OcConnectivityType.values()) {
- if (connectivityTypeSet.contains(connType)) {
- connTypeInt |= connType.getValue();
- }
- }
-
- OcPlatform.deleteResourceFromRD0(
- host,
- connTypeInt,
- onDeleteResourceListener,
- sPlatformQualityOfService.getValue()
- );
- }
-
- /**
- * API to delete resource from remote resource-directory.
- *
- * @param host Host Address of a service to publish resource.
- * @param connectivityTypeSet Set of types of connectivity. Example: IP
- * @param onDeleteResourceListener Handles events, success states and failure states.
- * @param qualityOfService the quality of communication.
- * @throws OcException if failure
- */
- public static void deleteResourceFromRD(
- String host,
- EnumSet<OcConnectivityType> connectivityTypeSet,
- OnDeleteResourceListener onDeleteResourceListener,
- QualityOfService qualityOfService) throws OcException {
- OcPlatform.initCheck();
-
- int connTypeInt = 0;
-
- for (OcConnectivityType connType : OcConnectivityType.values()) {
- if (connectivityTypeSet.contains(connType)) {
- connTypeInt |= connType.getValue();
- }
- }
-
- OcPlatform.deleteResourceFromRD0(
- host,
- connTypeInt,
- onDeleteResourceListener,
- qualityOfService.getValue()
- );
- }
-
- private static native void deleteResourceFromRD0(
- String host,
- int connectivityType,
- OnDeleteResourceListener onDeleteResourceListener,
- int qualityOfService) throws OcException;
-
- /**
- * API to delete resource from remote resource-directory.
- *
- * @param host Host Address of a service to publish resource.
- * @param connectivityTypeSet Set of types of connectivity. Example: IP
- * @param ocResourceHandleList reference to list of resource handles to be published.
- * @param onDeleteResourceListener Handles events, success states and failure states.
- * @throws OcException if failure
- */
- public static void deleteResourceFromRD(
- String host,
- EnumSet<OcConnectivityType> connectivityTypeSet,
- List<OcResourceHandle> ocResourceHandleList,
- OnDeleteResourceListener onDeleteResourceListener) throws OcException {
- OcPlatform.initCheck();
-
- int connTypeInt = 0;
-
- for (OcConnectivityType connType : OcConnectivityType.values()) {
- if (connectivityTypeSet.contains(connType)) {
- connTypeInt |= connType.getValue();
- }
- }
-
- OcPlatform.deleteResourceFromRD1(
- host,
- connTypeInt,
- ocResourceHandleList.toArray(
- new OcResourceHandle[ocResourceHandleList.size()]),
- onDeleteResourceListener,
- sPlatformQualityOfService.getValue()
- );
- }
-
- /**
- * API to delete resource from remote resource-directory.
- *
- * @param host Host IP Address of a service to publish resource.
- * @param connectivityTypeSet Set of types of connectivity. Example: IP
- * @param ocResourceHandleList reference to list of resource handles to be published.
- * @param onDeleteResourceListener Handles events, success states and failure states.
- * @param qualityOfService the quality of communication
- * @throws OcException if failure
- */
- public static void deleteResourceFromRD(
- String host,
- EnumSet<OcConnectivityType> connectivityTypeSet,
- List<OcResourceHandle> ocResourceHandleList,
- OnDeleteResourceListener onDeleteResourceListener,
- QualityOfService qualityOfService) throws OcException {
- OcPlatform.initCheck();
-
- int connTypeInt = 0;
-
- for (OcConnectivityType connType : OcConnectivityType.values()) {
- if (connectivityTypeSet.contains(connType)) {
- connTypeInt |= connType.getValue();
- }
- }
-
- OcPlatform.deleteResourceFromRD1(
- host,
- connTypeInt,
- ocResourceHandleList.toArray(
- new OcResourceHandle[ocResourceHandleList.size()]),
- onDeleteResourceListener,
- qualityOfService.getValue()
- );
- }
-
- private static native void deleteResourceFromRD1(
- String host,
- int connectivityType,
- OcResourceHandle[] ocResourceHandleArray,
- OnDeleteResourceListener onDeleteResourceListener,
- int qualityOfService) throws OcException;
-
- /**
- * An OnPublishResourceListener can be registered via the OcPlatform.publishResourceToRD call.
- * Event listeners are notified asynchronously
- */
- public interface OnPublishResourceListener {
- public void onPublishResourceCompleted(OcRepresentation ocRepresentation);
- public void onPublishResourceFailed(Throwable ex);
- }
-
- /**
- * An OnDeleteResourceListener can be registered via the OcPlatform.deleteResourceFromRD call.
- * Event listeners are notified asynchronously
- */
- public interface OnDeleteResourceListener {
- public void onDeleteResourceCompleted(int result);
- }
-
- /**
* An FindDirectPairingListener can be registered via the OcPlatform.findDirectPairingDevices call.
* Event listeners are notified asynchronously
*/
public EntityHandlerResult handleEntity(OcResourceRequest ocResourceRequest);
}
+ /**
+ * Listner to get result of findKeepAliveResource and sendKeepAliveRequest.
+ * An PingListener can be registered via the OcPlatform.KeepAliveListener and
+ * OcPlatform.sendKeepAliveRequest call.
+ * Event listeners are notified asynchronously
+ */
+ public interface KeepAliveListener {
+ public void onKeepAliveListener(OcRepresentation ocRepresentation, int result);
+ }
+
private static void initCheck() {
if (!sIsPlatformInitialized) {
throw new IllegalStateException("OcPlatform must be configured by making a call to " +
/**
* Method to set DeviceId.
*/
- public static native void setDeviceId(byte[] deviceId);
+ public static native void setDeviceId(byte[] deviceId) throws OcException;
+
+ /**
+ * gets OCRepresentation of KeepAlive resource from given host.
+ *
+ * @param host Host IP Address of pingResource
+ * @param onKeepAliveFoundListener Function to callback with result code and OCRepresentation.
+ * @throws OcException if failure
+ */
+ public static void findKeepAliveResource(String host,
+ KeepAliveListener onKeepAliveFoundListener)
+ throws OcException {
+ OcPlatform.initCheck();
+ OcPlatform.findKeepAliveResourceImpl(host, onKeepAliveFoundListener);
+ }
+
+ private static native void findKeepAliveResourceImpl(String host,
+ KeepAliveListener onKeepAliveFoundListener)
+ throws OcException;
+
+ /**
+ * send KeepAlive request to given host.
+ *
+ * @param interval interval time of expected pong response
+ * @param keepAliveResponseListener handles callback
+ * @throws OcException if failure
+ *
+ */
+ public static void sendKeepAliveRequest(String host, OcRepresentation ocRepresentation,
+ KeepAliveListener keepAliveResponseListener)
+ throws OcException {
+ OcPlatform.initCheck();
+ OcPlatform.sendKeepAliveRequestImpl(host, ocRepresentation, keepAliveResponseListener);
+ }
+
+ private static native void sendKeepAliveRequestImpl(String host,
+ OcRepresentation ocRepresentation,
+ KeepAliveListener keepAliveResponseListener)
+ throws OcException;
}
projects / platform / upstream / iotivity.git / blobdiff