1 files changed, 122 insertions, 0 deletions
diff --git a/fluent-bit/lib/wasm-micro-runtime-WAMR-1.2.2/core/app-framework/sensor/app/sensor.c b/fluent-bit/lib/wasm-micro-runtime-WAMR-1.2.2/core/app-framework/sensor/app/sensor.c
new file mode 100644
index 000000000..d898a1d3a
--- /dev/null
+++ b/fluent-bit/lib/wasm-micro-runtime-WAMR-1.2.2/core/app-framework/sensor/app/sensor.c
@@ -0,0 +1,122 @@
+/*
+ * Copyright (C) 2019 Intel Corporation.  All rights reserved.
+ * SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
+ */
+
+#include "wa-inc/sensor.h"
+
+#include "sensor_api.h"
+
+typedef struct _sensor {
+    struct _sensor *next;
+    char *name;
+    uint32 handle;
+    void (*sensor_callback)(sensor_t, attr_container_t *, void *);
+    void *user_data;
+} sensor;
+
+static sensor_t g_sensors = NULL;
+
+sensor_t
+sensor_open(const char *name, int index,
+            sensor_event_handler_f sensor_event_handler, void *user_data)
+{
+    uint32 id = wasm_sensor_open(name, index);
+    if (id == -1)
+        return NULL;
+
+    // create local node for holding the user callback
+    sensor_t sensor = (sensor_t)malloc(sizeof(struct _sensor));
+    if (sensor == NULL)
+        return NULL;
+
+    memset(sensor, 0, sizeof(struct _sensor));
+    sensor->handle = id;
+    sensor->name = strdup(name);
+    sensor->user_data = user_data;
+    sensor->sensor_callback = sensor_event_handler;
+
+    if (!sensor->name) {
+        free(sensor);
+        return NULL;
+    }
+
+    if (g_sensors == NULL) {
+        g_sensors = sensor;
+    }
+    else {
+        sensor->next = g_sensors;
+        g_sensors = sensor;
+    }
+
+    return sensor;
+}
+
+bool
+sensor_config_with_attr_container(sensor_t sensor, attr_container_t *cfg)
+{
+    char *buffer = (char *)cfg;
+    int len = attr_container_get_serialize_length(cfg);
+
+    return wasm_sensor_config_with_attr_container(sensor->handle, buffer, len);
+}
+
+bool
+sensor_config(sensor_t sensor, int interval, int bit_cfg, int delay)
+{
+    bool ret = wasm_sensor_config(sensor->handle, interval, bit_cfg, delay);
+    return ret;
+}
+
+bool
+sensor_close(sensor_t sensor)
+{
+    wasm_sensor_close(sensor->handle);
+
+    // remove local node
+    sensor_t s = g_sensors;
+    sensor_t prev = NULL;
+    while (s) {
+        if (s == sensor) {
+            if (prev == NULL) {
+                g_sensors = s->next;
+            }
+            else {
+                prev->next = s->next;
+            }
+            free(s->name);
+            free(s);
+            return true;
+        }
+        else {
+            prev = s;
+            s = s->next;
+        }
+    }
+
+    return false;
+}
+
+/*
+ *
+ *  API for native layer to callback for sensor events
+ *
+ */
+
+void
+on_sensor_event(uint32 sensor_id, char *buffer, int len)
+{
+    attr_container_t *sensor_data = (attr_container_t *)buffer;
+
+    // lookup the sensor and call the handlers
+    sensor_t s = g_sensors;
+    sensor_t prev = NULL;
+    while (s) {
+        if (s->handle == sensor_id) {
+            s->sensor_callback(s, sensor_data, s->user_data);
+            break;
+        }
+
+        s = s->next;
+    }
+}