GHashTable * address_map;
/// Mutex used to synchronize access to context fields.
- ca_mutex lock;
+ oc_mutex lock;
} CAGattClientContext;
char const * const object_path =
g_dbus_proxy_get_object_path(characteristic);
- ca_mutex_lock(g_context.lock);
+ oc_mutex_lock(g_context.lock);
char * const address =
g_hash_table_lookup(g_context.address_map, object_path);
}
}
- ca_mutex_unlock(g_context.lock);
+ oc_mutex_unlock(g_context.lock);
}
// ---------------------------------------------------------------------
{
CALEContext * const context = user_data;
- ca_mutex_lock(g_context.lock);
+ oc_mutex_lock(g_context.lock);
CAGattClientSetupService(device,
g_context.characteristic_map,
services_prop,
context);
- ca_mutex_unlock(g_context.lock);
+ oc_mutex_unlock(g_context.lock);
g_variant_unref(services_prop);
}
CAResult_t CAGattClientInitialize(CALEContext * context)
{
- g_context.lock = ca_mutex_new();
+ g_context.lock = oc_mutex_new();
/*
Map Bluetooth MAC address to OIC Transport Profile
OICFree,
OICFree);
- ca_mutex_lock(context->lock);
+ oc_mutex_lock(context->lock);
for (GList * l = context->devices; l != NULL; l = l->next)
{
context);
}
- ca_mutex_unlock(context->lock);
+ oc_mutex_unlock(context->lock);
- ca_mutex_lock(g_context.lock);
+ oc_mutex_lock(g_context.lock);
g_context.characteristic_map = characteristic_map;
g_context.address_map = address_map;
- ca_mutex_unlock(g_context.lock);
+ oc_mutex_unlock(g_context.lock);
return CA_STATUS_OK;
}
return; // Initialization did not complete.
}
- ca_mutex_lock(g_context.lock);
+ oc_mutex_lock(g_context.lock);
if (g_context.characteristic_map != NULL)
{
g_context.address_map = NULL;
}
- ca_mutex_unlock(g_context.lock);
+ oc_mutex_unlock(g_context.lock);
- ca_mutex_free(g_context.lock);
+ oc_mutex_free(g_context.lock);
g_context.lock = NULL;
/*
g_error_free(error);
- ca_mutex_lock(context->lock);
+ oc_mutex_lock(context->lock);
if (context->on_client_error != NULL)
{
CA_STATUS_FAILED);
}
- ca_mutex_unlock(context->lock);
+ oc_mutex_unlock(context->lock);
return CA_STATUS_FAILED;
}
CAResult_t result = CA_STATUS_FAILED;
- ca_mutex_lock(g_context.lock);
+ oc_mutex_lock(g_context.lock);
GDBusProxy * const characteristic =
G_DBUS_PROXY(
length,
context);
- ca_mutex_unlock(g_context.lock);
+ oc_mutex_unlock(g_context.lock);
return result;
}
CAResult_t result = CA_STATUS_FAILED;
- ca_mutex_lock(g_context.lock);
+ oc_mutex_lock(g_context.lock);
if (g_context.characteristic_map == NULL)
{
// Remote OIC GATT service was not found prior to getting here.
- ca_mutex_unlock(g_context.lock);
+ oc_mutex_unlock(g_context.lock);
return result;
}
}
}
- ca_mutex_unlock(g_context.lock);
+ oc_mutex_unlock(g_context.lock);
return result;
}