#ifndef _GNU_SOURCE
#define _GNU_SOURCE
#endif
+#include <unistd.h>
#include <memory>
#include <algorithm>
#include <unordered_map>
#include "hs-helper.h"
#include "hs-clientmanager.h"
#include "hs-appinfo.h"
+#include "hs-config.h"
+#include "hs-apprecover.h"
+
const char _error[] = "error";
const char _reply_message[] = "reply_message";
const char _keyData[] = "data";
const char _keyId[] = "id";
-const char _keyHandshake[] = "handshake";
-const char _keyTimes[] = "times";
-const char _keySleep[] = "sleep";
-const char _hs_conf_json[] = "hs-conf.json";
-const char _lastmode_json[] = "lastmode.json";
-
-struct hs_config {
- struct json_object *hs_conf;
- struct json_object *lastmode;
+
+struct hs_handshake {
+ hs_handshake(int times, int sleep) : m_times(times), m_sleep(sleep) {}
+ int start(afb_api_t api) const;
+
+ enum HandshakeStatus {
+ Handshake_Idle = 0,
+ Handshake_Subscribing,
+ Handshake_Subscribe_Fail,
+ Handshake_WaitEvent,
+ Handshake_Over
+ };
+ static int hs_sts;
+
+private:
+ const std::string sub_event = "windowmanager/handshake";
+ const int m_times;
+ const int m_sleep;
};
-static struct hs_config g_hs_config;
-const char _wm_event[] = "windowmanager/screenUpdated";
-static void screenUpdateCb(void *closure, const char *event, struct json_object* obj, afb_api_t api)
+int hs_handshake::hs_sts = hs_handshake::Handshake_Idle;
+
+/**
+ * handshake callback function
+ *
+ * #### Parameters
+ * - obj : reply json object
+ * - error : api_call error
+ * - info : api_call information
+ *
+ * #### Return
+ * None
+ *
+ */
+void handshake_subscribe_callback(struct json_object *obj, const char *error, const char *info)
{
- AFB_WARNING("windowmanager/screenUpdated callback. obj=%s.", json_object_to_json_string(obj));
+ if(error == nullptr) {
+ hs_handshake::hs_sts = hs_handshake::Handshake_WaitEvent;
+ }
+ else {
+ hs_handshake::hs_sts = hs_handshake::Handshake_Subscribe_Fail;
+ }
}
-struct hs_instance {
- HS_ClientManager *client_manager; // the connection session manager
- HS_AppInfo *app_info; // application info
+/**
+ * handshake event function
+ *
+ * #### Parameters
+ * - api : the api
+ * - event : received event name
+ * - object : received json object
+ *
+ * #### Return
+ * 0 : event can transfer to others
+ * 1 : event not transfer to others
+ */
+int on_handshake_event(afb_api_t api, const char *event, struct json_object *object)
+{
+ hs_handshake::hs_sts = hs_handshake::Handshake_Over;
+ return 1;
+}
+
+/**
+ * start handshake function
+ *
+ * #### Parameters
+ * - api : the api
+ *
+ * #### Return
+ * None
+ * 0 : handshake success
+ * -1 : handshake fail
+ *
+ */
+int hs_handshake::start(afb_api_t api) const
+{
+ int ret = -1;
+ setEventHook(sub_event.c_str(), on_handshake_event);
+ int count = 0;
+ do {
+ // try to subscribe handshake event
+ if(hs_handshake::hs_sts == hs_handshake::Handshake_Idle
+ || hs_handshake::hs_sts == hs_handshake::Handshake_Subscribe_Fail) {
+ hs_handshake::hs_sts = Handshake_Subscribing;
+ HS_WmProxy wm_proxy;
+ wm_proxy.subscribe(api, HS_WmProxy::Event_Handshake, handshake_subscribe_callback);
+ }
- hs_instance() : client_manager(HS_ClientManager::instance()), app_info(HS_AppInfo::instance()) {}
- int init(afb_api_t api);
- void setEventHook(const char *event, const event_hook_func f);
- void onEvent(afb_api_t api, const char *event, struct json_object *object);
+ // wait handshake event
+ if(hs_handshake::hs_sts == hs_handshake::Handshake_Over) {
+ ret = 0;
+ break;
+ }
+
+ ++count;
+ usleep(m_sleep*1000);
+ } while(count < m_times);
+
+ return ret;
+}
+
+struct hs_instance {
+ HS_ClientManager *client_manager; // the connection session manager
+ HS_AppInfo *app_info; // application info
+ HS_AppRecover *app_recover;
+
+ hs_instance() : client_manager(HS_ClientManager::instance()), app_info(HS_AppInfo::instance()), app_recover(HS_AppRecover::instance()) {}
+ int init(afb_api_t api);
+ void setEventHook(const char *event, const event_hook_func f);
+ void onEvent(afb_api_t api, const char *event, struct json_object *object);
private:
- std::unordered_map<std::string, std::list<event_hook_func>> event_hook_list;
+ std::unordered_map<std::string, std::list<event_hook_func>> event_hook_list;
};
+static struct hs_instance *g_hs_instance;
+
/**
* init function
*
int hs_instance::init(afb_api_t api)
{
if(client_manager == nullptr) {
- AFB_ERROR("FATAL ERROR: client_manager is nullptr.");
+ AFB_ERROR("client_manager is nullptr.");
return -1;
}
client_manager->init();
if(app_info == nullptr) {
- AFB_ERROR("FATAL ERROR: app_info is nullptr.");
+ AFB_ERROR("app_info is nullptr.");
return -1;
}
app_info->init(api);
- struct json_object *handshake_obj;
- if(json_object_object_get_ex(g_hs_config.hs_conf, _keyHandshake, &handshake_obj) == 0) {
- AFB_ERROR("get handshake failed.");
+ HS_Config hs_config;
+ if(hs_config.readConfig() < 0) {
+ AFB_ERROR("read config file failed.");
return -1;
}
- else {
- struct json_object *times_obj, *sleep_obj;
- json_object_object_get_ex(handshake_obj, _keyTimes, ×_obj);
- json_object_object_get_ex(handshake_obj, _keySleep, &sleep_obj);
- AFB_WARNING("get handshake times=%d, sleep=%d", json_object_get_int(times_obj), json_object_get_int(sleep_obj));
+
+ const struct handshake_info *h = hs_config.getHandshakeInfo();
+ struct hs_handshake handshake(h->times, h->sleep);
+ if(handshake.start(api) < 0) {
+ AFB_ERROR("handshake with windowmanager failed.");
+ return -1;
+ }
+
+ if(app_recover == nullptr) {
+ AFB_ERROR("app_recover is nullptr.");
+ return -1;
}
+ app_recover->init(api);
+ app_recover->startRecovery(api, hs_config.getRecoverMap());
return 0;
}
}
}
-static struct hs_instance *g_hs_instance;
-
/**
* set event hook
*
if(ret == AFB_REQ_NOT_STARTED_APPLICATION) {
std::string id = g_hs_instance->app_info->getAppProperty(value, _keyId);
HS_AfmMainProxy afm_proxy;
- afm_proxy.start(request, id);
+ afm_proxy.start(request->api, id);
ret = 0;
}
}
if(ret == AFB_REQ_NOT_STARTED_APPLICATION) {
std::string id = g_hs_instance->app_info->getAppProperty(value, _keyId);
HS_AfmMainProxy afm_proxy;
- afm_proxy.start(request, id);
+ afm_proxy.start(request->api, id);
ret = 0;
}
}
static int preinit(afb_api_t api)
{
AFB_DEBUG("binding preinit (was register)");
- auto rootdir = std::string(getenv("AFM_APP_INSTALL_DIR"));
- auto path = rootdir + "/etc/" + _hs_conf_json;
- if(readJsonFile(path.c_str(), &g_hs_config.hs_conf) < 0) {
- AFB_ERROR("read %s failed.", _hs_conf_json);
- return -1;
- }
-
- path = rootdir + "/etc/" + _lastmode_json;
- if(readJsonFile(path.c_str(), &g_hs_config.lastmode) < 0) {
- AFB_ERROR("read %s failed.", _lastmode_json);
- return -1;
- }
return 0;
}
Code Review / apps / agl-service-homescreen.git / blobdiff