static ssize_t sendData(const CAEndpoint_t *endpoint, const void *data,
size_t dlen, const char *fam)
{
+ OIC_LOG_V(DEBUG, TAG, "%s", __func__);
// #1. get TCP Server object from list
size_t index = 0;
CATCPSessionInfo_t *svritem = CAGetTCPSessionInfoFromEndpoint(endpoint, &index);
ssize_t CATCPSendData(CAEndpoint_t *endpoint, const void *data, size_t datalen)
{
+ OIC_LOG_V(DEBUG, TAG, "%s", __func__);
VERIFY_NON_NULL_RET(endpoint, TAG, "endpoint is NULL", -1);
VERIFY_NON_NULL_RET(data, TAG, "data is NULL", -1);
CATCPSessionInfo_t *CAConnectTCPSession(const CAEndpoint_t *endpoint)
{
+ OIC_LOG_V(DEBUG, TAG, "%s", __func__);
VERIFY_NON_NULL_RET(endpoint, TAG, "endpoint is NULL", NULL);
// #1. create TCP server object
CAResult_t CADisconnectTCPSession(CATCPSessionInfo_t *svritem, size_t index)
{
+ OIC_LOG_V(DEBUG, TAG, "%s", __func__);
VERIFY_NON_NULL(svritem, TAG, "svritem is NULL");
oc_mutex_lock(g_mutexObjectList);
if (svritem->fd >= 0)
{
close(svritem->fd);
+ svritem->fd = -1;
+ OIC_LOG(DEBUG, TAG, "close socket");
}
u_arraylist_remove(caglobals.tcp.svrlist, index);
OICFree(svritem->data);
return svritem;
}
}
-
+ OIC_LOG(DEBUG, TAG, "there is no session info in the svrlist");
return NULL;
}