static CAErrorHandleCallback g_errorHandleCallback = NULL;
-static struct CANetworkCallback_t * g_networkChangeCallbackList = NULL;
+static struct CANetworkCallback_t *g_networkChangeCallbackList = NULL;
/**
* network callback structure is handling
* for adapter state changed and connection state changed event.
*/
-typedef struct CANetworkCallback_t {
+typedef struct CANetworkCallback_t
+{
/** Linked list; for multiple callback list.*/
- struct CANetworkCallback_t * next;
+ struct CANetworkCallback_t *next;
/** Adapter state changed event callback. */
CAAdapterStateChangedCB adapter;
} CANetworkCallback_t;
-static size_t CAGetAdapterIndex(CATransportAdapter_t cType)
+static CAResult_t CAGetAdapterIndex(CATransportAdapter_t cType, size_t *adapterIndex)
{
for (size_t index = 0 ; index < g_numberOfAdapters ; index++)
{
if (cType == g_adapterHandler[index].cType )
- {
- return index;
- }
+ {
+ *adapterIndex = index;
+ return CA_STATUS_OK;
+ }
}
- return -1;
+ return CA_STATUS_FAILED;
}
static void CARegisterCallback(CAConnectivityHandler_t handler)
}
size_t numberofAdapters = g_numberOfAdapters + 1;
CAConnectivityHandler_t *adapterHandler = OICRealloc(g_adapterHandler,
- (numberofAdapters) * sizeof(*adapterHandler));
+ (numberofAdapters) * sizeof(*adapterHandler));
if (NULL == adapterHandler)
{
OIC_LOG(ERROR, TAG, "Memory allocation failed during registration");
}
g_adapterHandler = adapterHandler;
g_numberOfAdapters = numberofAdapters;
- g_adapterHandler[g_numberOfAdapters-1] = handler;
+ g_adapterHandler[g_numberOfAdapters - 1] = handler;
OIC_LOG_V(DEBUG, TAG, "%d type adapter, register complete!", handler.cType);
}
* CAResult_t
*/
static CAResult_t AddNetworkStateChangedCallback(CAAdapterStateChangedCB adapterCB,
- CAConnectionStateChangedCB connCB)
+ CAConnectionStateChangedCB connCB)
{
OIC_LOG(DEBUG, TAG, "Add NetworkStateChanged Callback");
}
#endif
- CANetworkCallback_t* callback = NULL;
+ CANetworkCallback_t *callback = NULL;
LL_FOREACH(g_networkChangeCallbackList, callback)
{
if (callback && adapterCB == callback->adapter && connCB == callback->conn)
* CAResult_t
*/
static CAResult_t RemoveNetworkStateChangedCallback(CAAdapterStateChangedCB adapterCB,
- CAConnectionStateChangedCB connCB)
+ CAConnectionStateChangedCB connCB)
{
OIC_LOG(DEBUG, TAG, "Remove NetworkStateChanged Callback");
- CANetworkCallback_t* callback = NULL;
+ CANetworkCallback_t *callback = NULL;
LL_FOREACH(g_networkChangeCallbackList, callback)
{
if (callback && adapterCB == callback->adapter && connCB == callback->conn)
{
OIC_LOG(DEBUG, TAG, "Remove All NetworkStateChanged Callback");
- CANetworkCallback_t* callback = NULL;
+ CANetworkCallback_t *callback = NULL;
LL_FOREACH(g_networkChangeCallbackList, callback)
{
OIC_LOG(DEBUG, TAG, "remove all callbacks");
static void CAAdapterChangedCallback(CATransportAdapter_t adapter, CANetworkStatus_t status)
{
// Call the callback.
- CANetworkCallback_t* callback = NULL;
+ CANetworkCallback_t *callback = NULL;
LL_FOREACH(g_networkChangeCallbackList, callback)
{
if (callback && callback->adapter)
static void CAConnectionChangedCallback(const CAEndpoint_t *info, bool isConnected)
{
// Call the callback.
- CANetworkCallback_t* callback = NULL;
+ CANetworkCallback_t *callback = NULL;
LL_FOREACH(g_networkChangeCallbackList, callback)
{
if (callback && callback->conn)
#endif
static void CAAdapterErrorHandleCallback(const CAEndpoint_t *endpoint,
- const void *data, size_t dataLen,
- CAResult_t result)
+ const void *data, size_t dataLen,
+ CAResult_t result)
{
OIC_LOG(DEBUG, TAG, "received error from adapter in interfacecontroller");
// Initialize adapters and register callback.
#ifdef IP_ADAPTER
if ((transportType & CA_ADAPTER_IP) || (CA_DEFAULT_ADAPTER == transportType)
- || (transportType & CA_ALL_ADAPTERS))
+ || (transportType & CA_ALL_ADAPTERS))
{
CAInitializeIP(CARegisterCallback, CAReceivedPacketCallback, CAAdapterChangedCallback,
CAAdapterErrorHandleCallback, handle);
#ifdef EDR_ADAPTER
if ((transportType & CA_ADAPTER_RFCOMM_BTEDR) || (CA_DEFAULT_ADAPTER == transportType)
- || (transportType == CA_ALL_ADAPTERS))
+ || (transportType == CA_ALL_ADAPTERS))
{
CAInitializeEDR(CARegisterCallback, CAReceivedPacketCallback, CAAdapterChangedCallback,
CAConnectionChangedCallback, CAAdapterErrorHandleCallback, handle);
#ifdef LE_ADAPTER
if ((transportType & CA_ADAPTER_GATT_BTLE) || (CA_DEFAULT_ADAPTER == transportType)
- || (transportType == CA_ALL_ADAPTERS))
+ || (transportType == CA_ALL_ADAPTERS))
{
CAInitializeLE(CARegisterCallback, CAReceivedPacketCallback, CAAdapterChangedCallback,
CAConnectionChangedCallback, CAAdapterErrorHandleCallback, handle);
#ifdef RA_ADAPTER
if ((transportType & CA_ADAPTER_REMOTE_ACCESS) || (CA_DEFAULT_ADAPTER == transportType)
- || (transportType == CA_ALL_ADAPTERS))
+ || (transportType == CA_ALL_ADAPTERS))
{
CAInitializeRA(CARegisterCallback, CAReceivedPacketCallback, CAAdapterChangedCallback,
handle);
#ifdef TCP_ADAPTER
if ((transportType & CA_ADAPTER_TCP) || (CA_DEFAULT_ADAPTER == transportType)
- || (transportType == CA_ALL_ADAPTERS))
+ || (transportType == CA_ALL_ADAPTERS))
{
CAInitializeTCP(CARegisterCallback, CAReceivedPacketCallback, CAAdapterChangedCallback,
CAConnectionChangedCallback, CAAdapterErrorHandleCallback, handle);
#ifdef NFC_ADAPTER
if ((transportType & CA_ADAPTER_NFC) || (CA_DEFAULT_ADAPTER == transportType)
- || (transportType == CA_ALL_ADAPTERS))
+ || (transportType == CA_ALL_ADAPTERS))
{
CAInitializeNFC(CARegisterCallback, CAReceivedPacketCallback, CAAdapterChangedCallback,
CAAdapterErrorHandleCallback, handle);
}
CAResult_t CAUnsetNetworkMonitorCallbacks(CAAdapterStateChangedCB adapterCB,
- CAConnectionStateChangedCB connCB)
+ CAConnectionStateChangedCB connCB)
{
OIC_LOG(DEBUG, TAG, "Unset network monitoring callback");
CAResult_t res = RemoveNetworkStateChangedCallback(adapterCB, connCB);
CAResult_t CAStartAdapter(CATransportAdapter_t transportType)
{
+ size_t index = 0;
+ CAResult_t res = CA_STATUS_FAILED;
+
OIC_LOG_V(DEBUG, TAG, "Start the adapter of CAConnectivityType[%d]", transportType);
- size_t index = CAGetAdapterIndex(transportType);
- if (0 > index)
+ res = CAGetAdapterIndex(transportType, &index);
+ if (CA_STATUS_OK != res)
{
OIC_LOG(ERROR, TAG, "unknown connectivity type!");
return CA_STATUS_FAILED;
}
- CAResult_t res = CA_STATUS_FAILED;
if (g_adapterHandler[index].startAdapter != NULL)
{
res = g_adapterHandler[index].startAdapter();
void CAStopAdapter(CATransportAdapter_t transportType)
{
+ size_t index = 0;
+ CAResult_t res = CA_STATUS_FAILED;
+
OIC_LOG_V(DEBUG, TAG, "Stop the adapter of CATransportType[%d]", transportType);
- size_t index = CAGetAdapterIndex(transportType);
- if (0 > index)
+ res = CAGetAdapterIndex(transportType, &index);
+ if (CA_STATUS_OK != res)
{
OIC_LOG(ERROR, TAG, "unknown transport type!");
return;
VERIFY_NON_NULL(info, TAG, "info is null");
VERIFY_NON_NULL(size, TAG, "size is null");
- CAEndpoint_t **tempInfo = (CAEndpoint_t**) OICCalloc(g_numberOfAdapters, sizeof(*tempInfo));
+ CAEndpoint_t **tempInfo = (CAEndpoint_t **) OICCalloc(g_numberOfAdapters, sizeof(*tempInfo));
if (!tempInfo)
{
OIC_LOG(ERROR, TAG, "Out of memory!");
return CA_MEMORY_ALLOC_FAILED;
}
- size_t *tempSize = (size_t*)OICCalloc(g_numberOfAdapters, sizeof(*tempSize));
+ size_t *tempSize = (size_t *)OICCalloc(g_numberOfAdapters, sizeof(*tempSize));
if (!tempSize)
{
OIC_LOG(ERROR, TAG, "Out of memory!");
{
// #1. get information for each adapter
res = g_adapterHandler[index].GetnetInfo(&tempInfo[index],
- &tempSize[index]);
+ &tempSize[index]);
// #2. total size
if (res == CA_STATUS_OK)
CAResult_t CASendUnicastData(const CAEndpoint_t *endpoint, const void *data, uint32_t length,
CADataType_t dataType)
{
+ size_t index = 0;
+ CAResult_t res = CA_STATUS_FAILED;
+
VERIFY_NON_NULL(endpoint, TAG, "endpoint is null");
u_arraylist_t *list = CAGetSelectedNetworkList();
for (size_t i = 0; i < u_arraylist_length(list); i++)
{
- void* ptrType = u_arraylist_get(list, i);
+ void *ptrType = u_arraylist_get(list, i);
if (NULL == ptrType)
{
continue;
}
- size_t index = CAGetAdapterIndex(connType);
-
- if (-1 == index)
+ res = CAGetAdapterIndex(connType, &index);
+ if (CA_STATUS_OK != res)
{
OIC_LOG(ERROR, TAG, "unknown transport type!");
return CA_STATUS_INVALID_PARAM;
CAResult_t CASendMulticastData(const CAEndpoint_t *endpoint, const void *data, uint32_t length,
CADataType_t dataType)
{
+ size_t index = 0;
+ CAResult_t res = CA_STATUS_FAILED;
+
VERIFY_NON_NULL(endpoint, TAG, "endpoint is null");
u_arraylist_t *list = CAGetSelectedNetworkList();
size_t selectedLength = u_arraylist_length(list);
for (size_t i = 0; i < selectedLength; i++)
{
- void* ptrType = u_arraylist_get(list, i);
+ void *ptrType = u_arraylist_get(list, i);
if (NULL == ptrType)
{
continue;
}
- size_t index = CAGetAdapterIndex(connType);
- if (0 > index)
+ res = CAGetAdapterIndex(connType, &index);
+ if (CA_STATUS_OK != res)
{
OIC_LOG(ERROR, TAG, "unknown connectivity type!");
continue;
CAResult_t CAStartListeningServerAdapters()
{
+ size_t index = 0;
CAResult_t result = CA_STATUS_FAILED;
u_arraylist_t *list = CAGetSelectedNetworkList();
size_t length = u_arraylist_length(list);
for (size_t i = 0; i < length; i++)
{
- void* ptrType = u_arraylist_get(list, i);
+ void *ptrType = u_arraylist_get(list, i);
- if(ptrType == NULL)
+ if (ptrType == NULL)
{
continue;
}
CATransportAdapter_t connType = *(CATransportAdapter_t *)ptrType;
- size_t index = CAGetAdapterIndex(connType);
- if (0 > index)
+ if (CA_STATUS_OK != CAGetAdapterIndex(connType, &index))
{
OIC_LOG(ERROR, TAG, "unknown connectivity type!");
continue;
CAResult_t CAStopListeningServerAdapters()
{
+ size_t index = 0;
+ CAResult_t res = CA_STATUS_FAILED;
u_arraylist_t *list = CAGetSelectedNetworkList();
if (!list)
{
size_t length = u_arraylist_length(list);
for (size_t i = 0; i < length; i++)
{
- void* ptrType = u_arraylist_get(list, i);
- if(ptrType == NULL)
+ void *ptrType = u_arraylist_get(list, i);
+ if (ptrType == NULL)
{
continue;
}
CATransportAdapter_t connType = *(CATransportAdapter_t *)ptrType;
- size_t index = CAGetAdapterIndex(connType);
- if (0 > index)
+ res = CAGetAdapterIndex(connType, &index);
+ if (CA_STATUS_OK != res)
{
OIC_LOG(ERROR, TAG, "unknown connectivity type!");
continue;
CAResult_t CAStartDiscoveryServerAdapters()
{
+ size_t index = 0;
CAResult_t result = CA_STATUS_FAILED;
u_arraylist_t *list = CAGetSelectedNetworkList();
size_t length = u_arraylist_length(list);
for (size_t i = 0; i < length; i++)
{
- void* ptrType = u_arraylist_get(list, i);
+ void *ptrType = u_arraylist_get(list, i);
- if(ptrType == NULL)
+ if (ptrType == NULL)
{
continue;
}
CATransportAdapter_t connType = *(CATransportAdapter_t *)ptrType;
- size_t index = CAGetAdapterIndex(connType);
- if (0 > index)
+ if (CA_STATUS_OK != CAGetAdapterIndex(connType, &index))
{
OIC_LOG(DEBUG, TAG, "unknown connectivity type!");
continue;
#ifdef SINGLE_THREAD
CAResult_t CAReadData()
{
+ size_t index = 0;
+ CAResult_t res = CA_STATUS_FAILED;
u_arraylist_t *list = CAGetSelectedNetworkList();
if (!list)
CATransportAdapter_t connType = *(CATransportAdapter_t *) ptrType;
- size_t index = CAGetAdapterIndex(connType);
- if (0 > index)
+ res = CAGetAdapterIndex(connType, &index);
+ if (CA_STATUS_OK != res)
{
OIC_LOG(DEBUG, TAG, "unknown connectivity type!");
continue;