#include "caqueueingthread.h"
#endif
#if defined(__TIZEN__) || defined(__ANDROID__)
#include "caqueueingthread.h"
#endif
#if defined(__TIZEN__) || defined(__ANDROID__)
#include "caleserver.h"
#include "caleclient.h"
#endif
#include "caleserver.h"
#include "caleclient.h"
#endif
if (CA_STATUS_OK != result)
{
OIC_LOG(ERROR, CALEADAPTER_TAG, "CAInitBleServerSenderQueue failed");
if (CA_STATUS_OK != result)
{
OIC_LOG(ERROR, CALEADAPTER_TAG, "CAInitBleServerSenderQueue failed");
return CA_STATUS_FAILED;
}
return CA_STATUS_FAILED;
}
if (NULL == g_bleServerReceiveDataMutex)
{
if (NULL == g_bleServerReceiveDataMutex)
{
oc_mutex_free(g_bleIsServerMutex);
g_bleIsServerMutex = NULL;
oc_mutex_free(g_bleIsServerMutex);
g_bleIsServerMutex = NULL;
oc_mutex_free(g_bleLocalAddressMutex);
g_bleLocalAddressMutex = NULL;
oc_mutex_free(g_bleLocalAddressMutex);
g_bleLocalAddressMutex = NULL;
CAStopLEGattClient();
CAResult_t result = CAQueueingThreadStop(g_bleClientSendQueueHandle);
CAStopLEGattClient();
CAResult_t result = CAQueueingThreadStop(g_bleClientSendQueueHandle);
return result;
#else
CAStopLEGattClient();
return result;
#else
CAStopLEGattClient();
VERIFY_NON_NULL_RET(g_bleClientSendQueueHandle, CALEADAPTER_TAG,
"g_bleClientSendQueueHandle is NULL",
CA_STATUS_FAILED);
VERIFY_NON_NULL_RET(g_bleClientSendQueueHandle, CALEADAPTER_TAG,
"g_bleClientSendQueueHandle is NULL",
CA_STATUS_FAILED);
OIC_LOG_V(DEBUG, CALEADAPTER_TAG, "Data Sending to LE layer [%u]", dataLen);
CALEData_t *bleData = CACreateLEData(remoteEndpoint, data, dataLen, NULL);
OIC_LOG_V(DEBUG, CALEADAPTER_TAG, "Data Sending to LE layer [%u]", dataLen);
CALEData_t *bleData = CACreateLEData(remoteEndpoint, data, dataLen, NULL);
return CA_MEMORY_ALLOC_FAILED;
}
// Add message to send queue
return CA_MEMORY_ALLOC_FAILED;
}
// Add message to send queue
CAResult_t res = CAQueueingThreadAddData(g_bleClientSendQueueHandle, bleData,
sizeof(CALEData_t));
if (CA_STATUS_OK != res)
CAResult_t res = CAQueueingThreadAddData(g_bleClientSendQueueHandle, bleData,
sizeof(CALEData_t));
if (CA_STATUS_OK != res)
}
// Add message to send queue
}
// Add message to send queue
CAResult_t res = CAQueueingThreadAddData(g_bleServerSendQueueHandle,
bleData,
sizeof(CALEData_t));
CAResult_t res = CAQueueingThreadAddData(g_bleServerSendQueueHandle,
bleData,
sizeof(CALEData_t));
static void CASetLEAdapterThreadPoolHandle(ca_thread_pool_t handle)
{
g_bleAdapterThreadPool = handle;
static void CASetLEAdapterThreadPoolHandle(ca_thread_pool_t handle)
{
g_bleAdapterThreadPool = handle;
}
static void CASetLEReqRespAdapterCallback(CANetworkPacketReceivedCallback callback)
}
static void CASetLEReqRespAdapterCallback(CANetworkPacketReceivedCallback callback)
address);
if (CA_STATUS_OK != res)
{
address);
if (CA_STATUS_OK != res)
{
OIC_LOG(ERROR, CALEADAPTER_TAG, "Could not clear the send queue");
}
OIC_LOG(ERROR, CALEADAPTER_TAG, "Could not clear the send queue");
}
}
static void CALERemoveReceiveQueueData(u_arraylist_t *dataInfoList, const char* address)
}
static void CALERemoveReceiveQueueData(u_arraylist_t *dataInfoList, const char* address)
#include "caadapterutils.h"
#include "octhread.h"
#include "oic_malloc.h"
#include "caadapterutils.h"
#include "octhread.h"
#include "oic_malloc.h"
#ifdef __WITH_TLS__
#include "ca_adapter_net_ssl.h"
#ifdef __WITH_TLS__
#include "ca_adapter_net_ssl.h"
#include "cacommon.h"
#include "logger.h"
#include "caremotehandler.h"
#include "cacommon.h"
#include "logger.h"
#include "caremotehandler.h"
+#ifdef TCP_ADAPTER
+#include "catcpadapter.h"
+#endif
#define TAG "OIC_CA_COMMON_UTILS"
CAResult_t CARegisterNetworkMonitorHandler(CAAdapterStateChangedCB adapterStateCB, CAConnectionStateChangedCB connStateCB)
#define TAG "OIC_CA_COMMON_UTILS"
CAResult_t CARegisterNetworkMonitorHandler(CAAdapterStateChangedCB adapterStateCB, CAConnectionStateChangedCB connStateCB)
#include "cainterface.h"
#include "ocrandom.h"
#include "oic_malloc.h"
#include "cainterface.h"
#include "ocrandom.h"
#include "oic_malloc.h"
#include "logger.h"
#include "pbkdf2.h"
#include "base64.h"
#include "logger.h"
#include "pbkdf2.h"
#include "base64.h"
#include "credresource.h"
#include "cainterface.h"
#include "oic_string.h"
#include "credresource.h"
#include "cainterface.h"
#include "oic_string.h"
#define TAG "OIC_PIN_OXM_COMMON"
#define TAG "OIC_PIN_OXM_COMMON"
#define __STDC_LIMIT_MACROS
#endif
#define __STDC_LIMIT_MACROS
#endif
#include <inttypes.h>
#include "oic_malloc.h"
#include "ocpayload.h"
#include <inttypes.h>
#include "oic_malloc.h"
#include "ocpayload.h"
#include "cautilinterface.h"
#include "camessagehandler.h"
#include "oicgroup.h"
#include "cautilinterface.h"
#include "camessagehandler.h"
#include "oicgroup.h"
+#include "pstatresource.h"
#if defined (ROUTING_GATEWAY) || defined (ROUTING_EP)
#include "routingutility.h"
#if defined (ROUTING_GATEWAY) || defined (ROUTING_EP)
#include "routingutility.h"