typedef int (*_ocprocess_cb)(void *user_data);
typedef void (*_free_context)(void *context);
-struct icd_ioty_worker
-{
+struct icd_ioty_worker {
void *ctx;
_ocprocess_cb cb;
_free_context free_ctx;
RETV_IF(NULL == ctx, OC_STACK_KEEP_TRANSACTION);
RETV_IF(NULL == resp, OC_STACK_KEEP_TRANSACTION);
- cb_result = (OC_OBSERVE_DEREGISTER == resp->sequenceNumber)?
- OC_STACK_DELETE_TRANSACTION:OC_STACK_KEEP_TRANSACTION;
+ cb_result = (OC_OBSERVE_DEREGISTER == resp->sequenceNumber) ?
+ OC_STACK_DELETE_TRANSACTION : OC_STACK_KEEP_TRANSACTION;
if (NULL == resp->payload) {
ERR("payload is empty");
prop |= OC_EXPLICIT_DISCOVERABLE;
/* TODO: Secure option is not supported yet. */
- properties = (properties & OC_SECURE)? (properties ^ OC_SECURE):properties;
+ properties = (properties & OC_SECURE) ? (properties ^ OC_SECURE) : properties;
return prop;
}
OCResourceHandle icd_ioty_register_resource(const char *uri_path,
- const char* const* res_types, int ifaces, int properties)
+ const char * const *res_types, int ifaces, int properties)
{
FN_CALL;
int i;
icd_ioty_csdk_lock();
/* TODO : QoS is come from lib. */
- if (msg_length) {
+ if (msg_length)
ret = OCNotifyListOfObservers(handle, obs_ids, obs_length, payload, OC_LOW_QOS);
- } else {
+ else
ret = OCNotifyAllObservers(handle, OC_LOW_QOS);
- }
+
icd_ioty_csdk_unlock();
if (OC_STACK_NO_OBSERVERS == ret) {
response.numSendVendorSpecificHeaderOptions = options_size;
if (0 != options_size) {
- int ret= _ioty_get_header_options(options,
+ int ret = _ioty_get_header_options(options,
response.numSendVendorSpecificHeaderOptions,
response.sendVendorSpecificHeaderOptions,
sizeof(response.sendVendorSpecificHeaderOptions)
OCCallbackData cbdata = {0};
OCConnectivityType oic_conn_type;
- coap_str = is_secure? ICD_IOTY_COAPS:ICD_IOTY_COAP;
+ coap_str = is_secure ? ICD_IOTY_COAPS : ICD_IOTY_COAP;
if (IC_STR_EQUAL == strcmp(IC_STR_NULL, host_address)) {
len = snprintf(uri, sizeof(uri), "%s", OC_RSRVD_WELL_KNOWN_URI);
void icd_ioty_complete(int type, GDBusMethodInvocation *invocation, GVariant *value)
{
- switch(type) {
+ switch (type) {
case ICD_CRUD_GET:
ic_dbus_complete_get(icd_dbus_get_object(), invocation, value);
break;
properties = icd_ioty_oic_properties_to_properties(resource->bitmap);
/* port */
- port = (resource->port)? resource->port:dev_addr->port;
+ port = (resource->port) ? resource->port : dev_addr->port;
/* TODO
* Check "resource->secure" and "resource->bitmap" */
else
OCRepPayloadSetPropString(repr, key, str_value);
- } else if (g_variant_is_of_type(var, G_VARIANT_TYPE ("a{sv}"))) {
+ } else if (g_variant_is_of_type(var, G_VARIANT_TYPE("a{sv}"))) {
GVariantIter state_iter;
repr_value = OCRepPayloadCreate();
g_variant_iter_init(&state_iter, var);
ret = IC_EQUAL;
break;
case OCREP_PROP_INT:
- ret = (value1->i == value2->i)? IC_EQUAL : 1;
+ ret = (value1->i == value2->i) ? IC_EQUAL : 1;
break;
case OCREP_PROP_DOUBLE:
- ret = (value1->d == value2->d)? IC_EQUAL : 1;
+ ret = (value1->d == value2->d) ? IC_EQUAL : 1;
break;
case OCREP_PROP_BOOL:
- ret = (value1->b == value2->b)? IC_EQUAL : 1;
+ ret = (value1->b == value2->b) ? IC_EQUAL : 1;
break;
case OCREP_PROP_STRING:
- ret = (IC_STR_EQUAL == g_strcmp0(value1->str, value2->str))? IC_EQUAL : 1;
+ ret = (IC_STR_EQUAL == g_strcmp0(value1->str, value2->str)) ? IC_EQUAL : 1;
break;
case OCREP_PROP_OBJECT:
ret = icd_payload_representation_compare(value1->obj, value2->obj);
GThread *thread;
GMainLoop *loop;
-#if !GLIB_CHECK_VERSION(2,35,0)
+#if !GLIB_CHECK_VERSION(2, 35, 0)
g_type_init();
#endif
GVariant *var = NULL;
iotcon_state_h state;
GVariantBuilder *builder;
-// GVariantBuilder *state_builder;
struct icl_value_s *state_value = NULL;
if (NULL == hash)
case IOTCON_TYPE_STATE:
state = ((icl_val_state_s*)state_value)->state;
var = _icl_state_value_to_gvariant(state->hash_table);
-// var = g_variant_new("a{sv}", state_builder);
break;
case IOTCON_TYPE_NONE:
default:
{
int iface = GPOINTER_TO_INT(user_data);
- switch(iface) {
+ switch (iface) {
case IOTCON_INTERFACE_BATCH:
child->visibility = ICL_VISIBILITY_REPR;
break;
DBG("interface type of response : %d", resp->iface);
- switch(resp->iface) {
+ switch (resp->iface) {
case IOTCON_INTERFACE_NONE:
case IOTCON_INTERFACE_DEFAULT:
case IOTCON_INTERFACE_GROUP:
{
int ret;
-#if !GLIB_CHECK_VERSION(2,35,0)
+#if !GLIB_CHECK_VERSION(2, 35, 0)
g_type_init();
#endif