typedef struct _icd_resource_handle {
OCResourceHandle handle;
- unsigned int number;
+ unsigned int signal_number;
} icd_resource_handle_s;
if (rsrc_handle->handle == handle) {
DBG("resource handle(%u, %u) removed from handle list", handle,
- rsrc_handle->number);
+ rsrc_handle->signal_number);
client->hdlist = g_list_delete_link(client->hdlist, cur_hd);
free(rsrc_handle);
g_mutex_unlock(&icd_dbus_client_list_mutex);
return;
}
-int icd_dbus_client_list_get_info(OCResourceHandle handle, unsigned int *sig_num,
- gchar **bus_name)
+int icd_dbus_client_list_get_info(OCResourceHandle handle,
+ unsigned int *signal_number, gchar **bus_name)
{
FN_CALL;
icd_dbus_client_s *client;
GList *cur_client, *cur_hd;
icd_resource_handle_s *rsrc_handle;
- RETV_IF(NULL == sig_num, IOTCON_ERROR_INVALID_PARAMETER);
+ RETV_IF(NULL == signal_number, IOTCON_ERROR_INVALID_PARAMETER);
RETV_IF(NULL == bus_name, IOTCON_ERROR_INVALID_PARAMETER);
g_mutex_lock(&icd_dbus_client_list_mutex);
if (rsrc_handle->handle == handle) {
DBG("signal_number(%u) for resource handle(%u) found",
- rsrc_handle->number, handle);
- *sig_num = rsrc_handle->number;
+ rsrc_handle->signal_number, handle);
+ *signal_number = rsrc_handle->signal_number;
*bus_name = ic_utils_strdup(client->bus_name);
g_mutex_unlock(&icd_dbus_client_list_mutex);
return IOTCON_ERROR_NONE;
RET_IF(NULL == rsrc_handle);
RET_IF(NULL == rsrc_handle->handle);
- DBG("handle(%u, %u) deregistering", rsrc_handle->handle, rsrc_handle->number);
+ DBG("handle(%u, %u) deregistering", rsrc_handle->handle, rsrc_handle->signal_number);
ret = icd_ioty_unregister_resource(rsrc_handle->handle);
if (IOTCON_ERROR_NONE != ret)
if (rsrc_handle->handle == handle) {
ERR("resource handle(%u, %u) already exist", rsrc_handle->handle,
- rsrc_handle->number);
+ rsrc_handle->signal_number);
g_mutex_unlock(&icd_dbus_client_list_mutex);
return IOTCON_ERROR_ALREADY;
}
}
rsrc_handle->handle = handle;
- rsrc_handle->number = signal_number;
+ rsrc_handle->signal_number = signal_number;
DBG("handle(%u) added in the client(%s, %u)", handle, bus_name, signal_number);
{
int ret;
- ret = icd_ioty_bind_resource(ICD_INT64_TO_POINTER(parent), ICD_INT64_TO_POINTER(child));
+ ret = icd_ioty_bind_resource(ICD_INT64_TO_POINTER(parent),
+ ICD_INT64_TO_POINTER(child));
if (IOTCON_ERROR_NONE != ret)
ERR("icd_ioty_bind_resource() Fail(%d)", ret);
#define ICD_POINTER_TO_INT64(p) ((int64_t)(intptr_t)(p))
icDbus* icd_dbus_get_object();
-int icd_dbus_client_list_get_info(void *handle, unsigned int *sig_num, gchar **bus_name);
-int icd_dbus_emit_signal(const char *dest, const char *sig_name, GVariant *value);
+int icd_dbus_client_list_get_info(void *handle, unsigned int *signal_number,
+ gchar **bus_name);
+int icd_dbus_emit_signal(const char *dest, const char *signal_name,
+ GVariant *value);
unsigned int icd_dbus_init();
void icd_dbus_deinit(unsigned int id);
struct icd_req_context {
- unsigned int signum;
+ unsigned int signal_number;
char *bus_name;
int types;
int observer_id;
struct icd_find_context {
- unsigned int signum;
+ unsigned int signal_number;
char *bus_name;
int conn_type;
GVariant **payload;
struct icd_info_context {
- unsigned int signum;
+ unsigned int signal_number;
int info_type;
char *bus_name;
GVariant *payload;
struct icd_observe_context {
- unsigned int signum;
+ unsigned int signal_number;
int res;
int seqnum;
char *bus_name;
struct icd_presence_context {
- unsigned int signum;
+ unsigned int signal_number;
char *bus_name;
int result;
unsigned int nonce;
}
-static int _ocprocess_response_signal(const char *dest, const char *signal,
- unsigned int signum, GVariant *value)
+static int _ocprocess_response_signal(const char *dest, const char *signal_prefix,
+ unsigned int signal_number, GVariant *value)
{
int ret;
- char sig_name[IC_DBUS_SIGNAL_LENGTH] = {0};
+ char signal_name[IC_DBUS_SIGNAL_LENGTH] = {0};
- ret = snprintf(sig_name, sizeof(sig_name), "%s_%u", signal, signum);
- if (ret <= 0 || sizeof(sig_name) <= ret) {
+ ret = snprintf(signal_name, sizeof(signal_name), "%s_%u", signal_prefix, signal_number);
+ if (ret <= 0 || sizeof(signal_name) <= ret) {
ERR("snprintf() Fail(%d)", ret);
return IOTCON_ERROR_IO_ERROR;
}
- ret = icd_dbus_emit_signal(dest, sig_name, value);
+ ret = icd_dbus_emit_signal(dest, signal_name, value);
if (IOTCON_ERROR_NONE != ret) {
ERR("icd_dbus_emit_signal() Fail(%d)", ret);
return ret;
ICD_POINTER_TO_INT64(ctx->resource_h));
ret = _ocprocess_response_signal(ctx->bus_name, IC_DBUS_SIGNAL_REQUEST_HANDLER,
- ctx->signum, value);
+ ctx->signal_number, value);
if (IOTCON_ERROR_NONE != ret)
ERR("_ocprocess_response_signal() Fail(%d)", ret);
}
/* signal number & bus_name */
- req_ctx->signum = signal_number;
+ req_ctx->signal_number = signal_number;
req_ctx->bus_name = bus_name;
dev_addr = calloc(1, sizeof(OCDevAddr));
* To reduce the number of emit_signal, let's send signal only one time for one device.
* for ex, client list. */
ret = _ocprocess_response_signal(ctx->bus_name, IC_DBUS_SIGNAL_FOUND_RESOURCE,
- ctx->signum, value);
+ ctx->signal_number, value);
if (IOTCON_ERROR_NONE != ret) {
ERR("_ocprocess_response_signal() Fail(%d)", ret);
g_variant_unref(value);
return OC_STACK_KEEP_TRANSACTION;
}
- find_ctx->signum = sig_context->signum;
+ find_ctx->signal_number = sig_context->signal_number;
find_ctx->bus_name = ic_utils_strdup(sig_context->bus_name);
find_ctx->payload = icd_payload_res_to_gvariant(resp->payload, &resp->devAddr);
find_ctx->conn_type = icd_ioty_transport_flag_to_conn_type(resp->devAddr.adapter,
static int _worker_info_cb(void *context)
{
int ret;
- const char *sig_name = NULL;
+ const char *signal_prefix = NULL;
struct icd_info_context *ctx = context;
RETV_IF(NULL == ctx, IOTCON_ERROR_INVALID_PARAMETER);
if (ICD_DEVICE_INFO == ctx->info_type)
- sig_name = IC_DBUS_SIGNAL_DEVICE;
+ signal_prefix = IC_DBUS_SIGNAL_DEVICE;
else if (ICD_PLATFORM_INFO == ctx->info_type)
- sig_name = IC_DBUS_SIGNAL_PLATFORM;
+ signal_prefix = IC_DBUS_SIGNAL_PLATFORM;
- ret = _ocprocess_response_signal(ctx->bus_name, sig_name, ctx->signum, ctx->payload);
+ ret = _ocprocess_response_signal(ctx->bus_name, signal_prefix, ctx->signal_number,
+ ctx->payload);
if (IOTCON_ERROR_NONE != ret)
ERR("_ocprocess_response_signal() Fail(%d)", ret);
value = g_variant_new("(a(qs)vii)", ctx->options, ctx->payload, ctx->res,
ctx->seqnum);
- ret = _ocprocess_response_signal(ctx->bus_name, IC_DBUS_SIGNAL_OBSERVE, ctx->signum,
- value);
+ ret = _ocprocess_response_signal(ctx->bus_name, IC_DBUS_SIGNAL_OBSERVE,
+ ctx->signal_number, value);
if (IOTCON_ERROR_NONE != ret)
ERR("_ocprocess_response_signal() Fail(%d)", ret);
}
-static void _observe_cb_response_error(const char *dest, unsigned int signum, int ret_val)
+static void _observe_cb_response_error(const char *dest,
+ unsigned int signal_number, int ret_val)
{
int ret;
GVariant *value;
value = g_variant_new("(a(qs)vii)", &options, payload, ret_val, 0);
- ret = _ocprocess_response_signal(dest, IC_DBUS_SIGNAL_OBSERVE, signum, value);
+ ret = _ocprocess_response_signal(dest, IC_DBUS_SIGNAL_OBSERVE, signal_number, value);
if (IOTCON_ERROR_NONE != ret)
ERR("_ocprocess_response_signal() Fail(%d)", ret);
}
-OCStackApplicationResult icd_ioty_ocprocess_observe_cb(void *ctx, OCDoHandle handle,
- OCClientResponse *resp)
+OCStackApplicationResult icd_ioty_ocprocess_observe_cb(void *ctx,
+ OCDoHandle handle, OCClientResponse *resp)
{
int ret, res;
GVariantBuilder *options;
if (NULL == resp->payload) {
ERR("payload is empty");
- _observe_cb_response_error(sig_context->bus_name, sig_context->signum,
+ _observe_cb_response_error(sig_context->bus_name, sig_context->signal_number,
IOTCON_ERROR_IOTIVITY);
return OC_STACK_KEEP_TRANSACTION;
}
observe_ctx = calloc(1, sizeof(struct icd_observe_context));
if (NULL == observe_ctx) {
ERR("calloc() Fail(%d)", errno);
- _observe_cb_response_error(sig_context->bus_name, sig_context->signum,
+ _observe_cb_response_error(sig_context->bus_name, sig_context->signal_number,
IOTCON_ERROR_OUT_OF_MEMORY);
return OC_STACK_KEEP_TRANSACTION;
}
resp->numRcvdVendorSpecificHeaderOptions);
observe_ctx->payload = icd_payload_to_gvariant(resp->payload);
- observe_ctx->signum = sig_context->signum;
+ observe_ctx->signal_number = sig_context->signal_number;
observe_ctx->res = res;
observe_ctx->bus_name = ic_utils_strdup(sig_context->bus_name);
observe_ctx->options = options;
ret = _ocprocess_worker_start(_worker_observe_cb, observe_ctx);
if (IOTCON_ERROR_NONE != ret) {
ERR("_ocprocess_worker_start() Fail(%d)", ret);
- _observe_cb_response_error(sig_context->bus_name, sig_context->signum, ret);
+ _observe_cb_response_error(sig_context->bus_name, sig_context->signal_number, ret);
free(observe_ctx->bus_name);
if (observe_ctx->payload)
g_variant_unref(observe_ctx->payload);
value = g_variant_new("(iusiis)", ctx->result, ctx->nonce, addr, conn_type,
ctx->trigger, ic_utils_dbus_encode_str(ctx->resource_type));
- ret = _ocprocess_response_signal(ctx->bus_name, IC_DBUS_SIGNAL_PRESENCE, ctx->signum,
- value);
+ ret = _ocprocess_response_signal(ctx->bus_name, IC_DBUS_SIGNAL_PRESENCE,
+ ctx->signal_number, value);
if (IOTCON_ERROR_NONE != ret)
ERR("_ocprocess_response_signal() Fail(%d)", ret);
}
-static void _presence_cb_response_error(const char *dest, unsigned int signum,
+static void _presence_cb_response_error(const char *dest, unsigned int signal_number,
int ret_val)
{
FN_CALL;
value = g_variant_new("(iusiis)", ret_val, 0, IC_STR_NULL, IOTCON_CONNECTIVITY_ALL,
IOTCON_PRESENCE_TRIGGER_RESOURCE_CREATED, IC_STR_NULL);
- ret = _ocprocess_response_signal(dest, IC_DBUS_SIGNAL_PRESENCE, signum, value);
+ ret = _ocprocess_response_signal(dest, IC_DBUS_SIGNAL_PRESENCE, signal_number, value);
if (IOTCON_ERROR_NONE != ret)
ERR("_ocprocess_response_signal() Fail(%d)", ret);
}
presence_ctx = calloc(1, sizeof(struct icd_presence_context));
if (NULL == presence_ctx) {
ERR("calloc() Fail(%d)", errno);
- _presence_cb_response_error(sig_context->bus_name, sig_context->signum,
+ _presence_cb_response_error(sig_context->bus_name, sig_context->signal_number,
IOTCON_ERROR_OUT_OF_MEMORY);
return OC_STACK_KEEP_TRANSACTION;
}
dev_addr = calloc(1, sizeof(OCDevAddr));
if (NULL == dev_addr) {
ERR("calloc() Fail(%d)", errno);
- _presence_cb_response_error(sig_context->bus_name, sig_context->signum,
+ _presence_cb_response_error(sig_context->bus_name, sig_context->signal_number,
IOTCON_ERROR_OUT_OF_MEMORY);
free(presence_ctx);
return OC_STACK_KEEP_TRANSACTION;
ret = _presence_trigger_to_ioty_trigger(payload->trigger, &presence_ctx->trigger);
if (IOTCON_ERROR_NONE != ret) {
ERR("_presence_trigger_to_ioty_trigger() Fail(%d)", ret);
- _presence_cb_response_error(sig_context->bus_name, sig_context->signum, ret);
+ _presence_cb_response_error(sig_context->bus_name, sig_context->signal_number,
+ ret);
free(presence_ctx);
return OC_STACK_KEEP_TRANSACTION;
}
presence_ctx->result = IOTCON_ERROR_IOTIVITY;
}
- presence_ctx->signum = sig_context->signum;
+ presence_ctx->signal_number = sig_context->signal_number;
presence_ctx->bus_name = ic_utils_strdup(sig_context->bus_name);
presence_ctx->nonce = resp->sequenceNumber;
presence_ctx->dev_addr = dev_addr;
ret = _ocprocess_worker_start(_worker_presence_cb, presence_ctx);
if (IOTCON_ERROR_NONE != ret) {
ERR("_ocprocess_worker_start() Fail(%d)", ret);
- _presence_cb_response_error(sig_context->bus_name, sig_context->signum, ret);
+ _presence_cb_response_error(sig_context->bus_name, sig_context->signal_number, ret);
free(presence_ctx->resource_type);
free(presence_ctx->bus_name);
free(presence_ctx->dev_addr);
info_ctx->info_type = info_type;
info_ctx->payload = icd_payload_to_gvariant(resp->payload);
- info_ctx->signum = sig_context->signum;
+ info_ctx->signal_number = sig_context->signal_number;
info_ctx->bus_name = ic_utils_strdup(sig_context->bus_name);
ret = _ocprocess_worker_start(_worker_info_cb, info_ctx);
int icd_ioty_find_resource(const char *host_address, int conn_type,
- const char *resource_type, unsigned int signum, const char *bus_name)
+ const char *resource_type, unsigned int signal_number, const char *bus_name)
{
int len;
OCStackResult result;
}
context->bus_name = ic_utils_strdup(bus_name);
- context->signum = signum;
+ context->signal_number = signal_number;
cbdata.context = context;
cbdata.cb = icd_ioty_ocprocess_find_cb;
}
-static gboolean _icd_ioty_crud(int type, icDbus *object, GDBusMethodInvocation *invocation,
- GVariant *resource, GVariant *query, GVariant *repr)
+static gboolean _icd_ioty_crud(int type,
+ icDbus *object,
+ GDBusMethodInvocation *invocation,
+ GVariant *resource,
+ GVariant *query,
+ GVariant *repr)
{
bool is_secure;
OCMethod rest_type;
}
-OCDoHandle icd_ioty_observer_start(GVariant *resource, int observe_type, GVariant *query,
- unsigned int signal_number, const char *bus_name)
+OCDoHandle icd_ioty_observer_start(GVariant *resource, int observe_type,
+ GVariant *query, unsigned int signal_number, const char *bus_name)
{
bool is_secure;
OCMethod method;
return NULL;
}
context->bus_name = ic_utils_strdup(bus_name);
- context->signum = signal_number;
+ context->signal_number = signal_number;
cbdata.context = context;
cbdata.cb = icd_ioty_ocprocess_observe_cb;
return IOTCON_ERROR_OUT_OF_MEMORY;
}
context->bus_name = ic_utils_strdup(bus_name);
- context->signum = signal_number;
+ context->signal_number = signal_number;
cbdata.context = context;
cbdata.cb = icd_ioty_ocprocess_info_cb;
return NULL;
}
context->bus_name = ic_utils_strdup(bus_name);
- context->signum = signal_number;
+ context->signal_number = signal_number;
cbdata.context = context;
cbdata.cb = icd_ioty_ocprocess_presence_cb;
#define ICD_IOTY_TIZEN_INFO_TIZEN_DEVICE_ID "tizen_device_id"
typedef struct {
- unsigned int signum;
+ unsigned int signal_number;
char *bus_name;
} icd_sig_ctx_s;
gboolean icd_ioty_delete(icDbus *object, GDBusMethodInvocation *invocation,
GVariant *resource);
-OCDoHandle icd_ioty_observer_start(GVariant *resource, int observe_type, GVariant *query,
- unsigned int signal_number, const char *bus_name);
+OCDoHandle icd_ioty_observer_start(GVariant *resource, int observe_type,
+ GVariant *query, unsigned int signal_number, const char *bus_name);
int icd_ioty_observer_stop(OCDoHandle handle, GVariant *options);
}
-unsigned int icl_dbus_subscribe_signal(char *sig_name, void *cb_container, void *cb_free,
- GDBusSignalCallback sig_handler)
+unsigned int icl_dbus_subscribe_signal(char *signal_name, void *cb_container,
+ void *cb_free, GDBusSignalCallback sig_handler)
{
unsigned int id;
GDBusConnection *conn = g_dbus_proxy_get_connection(G_DBUS_PROXY(icl_dbus_object));
id = g_dbus_connection_signal_subscribe(conn,
NULL,
IOTCON_DBUS_INTERFACE,
- sig_name,
+ signal_name,
IOTCON_DBUS_OBJPATH,
NULL,
G_DBUS_SIGNAL_FLAGS_NONE,
icDbus* icl_dbus_get_object();
unsigned int icl_dbus_generate_signal_number();
-unsigned int icl_dbus_subscribe_signal(char *sig_name, void *cb_container, void *cb_free,
- GDBusSignalCallback sig_handler);
+unsigned int icl_dbus_subscribe_signal(char *signal_name, void *cb_container,
+ void *cb_free, GDBusSignalCallback sig_handler);
void icl_dbus_unsubscribe_signal(unsigned int id);
-int icl_dbus_add_connection_changed_cb(iotcon_connection_changed_cb cb, void *user_data);
+int icl_dbus_add_connection_changed_cb(iotcon_connection_changed_cb cb,
+ void *user_data);
int icl_dbus_remove_connection_changed_cb(iotcon_connection_changed_cb cb,
void *user_data);
iotcon_device_info_cb cb,
void *user_data)
{
+ int ret;
GError *error = NULL;
- unsigned int sub_id;
- int ret, signal_number;
- char signal_name[IC_DBUS_SIGNAL_LENGTH] = {0};
icl_device_info_s *cb_container;
+ unsigned int sub_id, signal_number;
+ char signal_name[IC_DBUS_SIGNAL_LENGTH] = {0};
RETV_IF(NULL == icl_dbus_get_object(), IOTCON_ERROR_DBUS);
RETV_IF(NULL == host_address, IOTCON_ERROR_INVALID_PARAMETER);
iotcon_platform_info_cb cb,
void *user_data)
{
+ int ret;
GError *error = NULL;
- unsigned int sub_id;
- int ret, signal_number;
- char signal_name[IC_DBUS_SIGNAL_LENGTH] = {0};
icl_platform_info_s *cb_container;
+ unsigned int sub_id, signal_number;
+ char signal_name[IC_DBUS_SIGNAL_LENGTH] = {0};
RETV_IF(NULL == icl_dbus_get_object(), IOTCON_ERROR_DBUS);
RETV_IF(NULL == host_address, IOTCON_ERROR_INVALID_PARAMETER);
iotcon_state_h state,
iotcon_lite_resource_h *resource_handle)
{
- unsigned int sub_id;
+ int ret, iface;
const gchar **types;
GError *error = NULL;
- int ret, iface, signal_number;
iotcon_lite_resource_h resource;
- char sig_name[IC_DBUS_SIGNAL_LENGTH];
+ unsigned int sub_id, signal_number;
+ char signal_name[IC_DBUS_SIGNAL_LENGTH];
RETV_IF(NULL == icl_dbus_get_object(), IOTCON_ERROR_DBUS);
RETV_IF(NULL == uri_path, IOTCON_ERROR_INVALID_PARAMETER);
return ret;
}
- snprintf(sig_name, sizeof(sig_name), "%s_%u", IC_DBUS_SIGNAL_REQUEST_HANDLER,
+ snprintf(signal_name, sizeof(signal_name), "%s_%u", IC_DBUS_SIGNAL_REQUEST_HANDLER,
signal_number);
- sub_id = icl_dbus_subscribe_signal(sig_name, resource,
+ sub_id = icl_dbus_subscribe_signal(signal_name, resource,
_icl_lite_resource_conn_cleanup, _icl_lite_resource_request_handler);
if (0 == sub_id) {
ERR("icl_dbus_subscribe_signal() Fail");
iotcon_presence_h *presence_handle)
{
FN_CALL;
+ int ret;
GError *error = NULL;
- unsigned int sub_id;
- int signal_number, ret;
- char signal_name[IC_DBUS_SIGNAL_LENGTH] = {0};
icl_presence_s *presence;
+ unsigned int sub_id, signal_number;
+ char signal_name[IC_DBUS_SIGNAL_LENGTH] = {0};
RETV_IF(NULL == icl_dbus_get_object(), IOTCON_ERROR_INVALID_PARAMETER);
RETV_IF(NULL == host_address, IOTCON_ERROR_INVALID_PARAMETER);
unsigned int *sub_id,
int64_t *observe_handle)
{
+ int ret;
GError *error = NULL;
- int ret, signal_number;
+ unsigned int signal_number;
GVariant *arg_query, *arg_remote_resource;
char signal_name[IC_DBUS_SIGNAL_LENGTH] = {0};
iotcon_found_resource_cb cb,
void *user_data)
{
- unsigned int sub_id;
+ int ret;
GError *error = NULL;
- int ret, signal_number;
icl_found_resource_s *cb_container;
+ unsigned int sub_id, signal_number;
char signal_name[IC_DBUS_SIGNAL_LENGTH] = {0};
RETV_IF(NULL == icl_dbus_get_object(), IOTCON_ERROR_DBUS);
void *user_data,
iotcon_resource_h *resource_handle)
{
- unsigned int sub_id;
- GError *error = NULL;
+ int ret;
const gchar **types;
+ GError *error = NULL;
iotcon_resource_h resource;
- int signal_number, ret;
- char sig_name[IC_DBUS_SIGNAL_LENGTH];
+ unsigned int sub_id, signal_number;
+ char signal_name[IC_DBUS_SIGNAL_LENGTH];
RETV_IF(NULL == icl_dbus_get_object(), IOTCON_ERROR_DBUS);
RETV_IF(NULL == uri_path, IOTCON_ERROR_INVALID_PARAMETER);
resource->ifaces = ifaces;
resource->properties = properties;
- snprintf(sig_name, sizeof(sig_name), "%s_%u", IC_DBUS_SIGNAL_REQUEST_HANDLER,
+ snprintf(signal_name, sizeof(signal_name), "%s_%u", IC_DBUS_SIGNAL_REQUEST_HANDLER,
signal_number);
- sub_id = icl_dbus_subscribe_signal(sig_name, resource, _icl_resource_conn_cleanup,
+ sub_id = icl_dbus_subscribe_signal(signal_name, resource, _icl_resource_conn_cleanup,
_icl_request_handler);
if (0 == sub_id) {
ERR("icl_dbus_subscribe_signal() Fail");