X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=resource%2Fcsdk%2Fconnectivity%2Fsrc%2Fcaconnectivitymanager.c;h=9f6aef8294797d0c6d4fa8c400b5b1a431aac0e1;hb=17c68b2fd1e74586f85e552eeab4e32dc121f8a0;hp=98b3ffd1d02df18d93a52d704e81d77553e92891;hpb=8c01dff2c5bc5496f7dc1632c498943ec6ecb015;p=platform%2Fupstream%2Fiotivity.git diff --git a/resource/csdk/connectivity/src/caconnectivitymanager.c b/resource/csdk/connectivity/src/caconnectivitymanager.c index 98b3ffd..9f6aef8 100644 --- a/resource/csdk/connectivity/src/caconnectivitymanager.c +++ b/resource/csdk/connectivity/src/caconnectivitymanager.c @@ -34,6 +34,10 @@ #include "caadapternetdtls.h" #endif +#ifdef TCP_ADAPTER +#include "catcpadapter.h" +#endif + CAGlobals_t caglobals = { 0 }; #define TAG "CA_CONN_MGR" @@ -43,7 +47,14 @@ static bool g_isInitialized = false; #ifdef __WITH_DTLS__ // CAAdapterNetDTLS will register the callback. // Taking callback all the way through adapters not the right approach, hence calling here. -extern void CADTLSSetCredentialsCallback(CAGetDTLSCredentialsHandler credCallback); +extern void CADTLSSetCredentialsCallback(CAGetDTLSPskCredentialsHandler credCallback); +#endif + +#ifdef __WITH_X509__ +// CAAdapterNetDTLS will register the callback. +// Taking callback all the way through adapters not the right approach, hence calling here. +extern void CADTLSSetX509CredentialsCallback(CAGetDTLSX509CredentialsHandler credCallback); +extern void CADTLSSetCrlCallback(CAGetDTLSCrlHandler crlCallback); #endif CAResult_t CAInitialize() @@ -88,6 +99,18 @@ CAResult_t CAStartListeningServer() return CAStartListeningServerAdapters(); } +CAResult_t CAStopListeningServer() +{ + OIC_LOG(DEBUG, TAG, "CAStopListeningServer"); + + if(!g_isInitialized) + { + return CA_STATUS_NOT_INITIALIZED; + } + + return CAStopListeningServerAdapters(); +} + CAResult_t CAStartDiscoveryServer() { OIC_LOG(DEBUG, TAG, "CAStartDiscoveryServer"); @@ -115,7 +138,7 @@ void CARegisterHandler(CARequestCallback ReqHandler, CAResponseCallback RespHand } #ifdef __WITH_DTLS__ -CAResult_t CARegisterDTLSCredentialsHandler(CAGetDTLSCredentialsHandler GetDTLSCredentialsHandler) +CAResult_t CARegisterDTLSCredentialsHandler(CAGetDTLSPskCredentialsHandler GetDTLSCredentialsHandler) { OIC_LOG(DEBUG, TAG, "CARegisterDTLSCredentialsHandler"); @@ -129,6 +152,34 @@ CAResult_t CARegisterDTLSCredentialsHandler(CAGetDTLSCredentialsHandler GetDTLSC } #endif //__WITH_DTLS__ +#ifdef __WITH_X509__ +CAResult_t CARegisterDTLSX509CredentialsHandler(CAGetDTLSX509CredentialsHandler GetDTLSX509CredentialsHandler) +{ + OIC_LOG(DEBUG, TAG, "CARegisterDTLSX509CredentialsHandler"); + + if(!g_isInitialized) + { + return CA_STATUS_NOT_INITIALIZED; + } + + CADTLSSetX509CredentialsCallback(GetDTLSX509CredentialsHandler); + return CA_STATUS_OK; +} + +CAResult_t CARegisterDTLSCrlHandler(CAGetDTLSCrlHandler GetDTLSCrlHandler) +{ + OIC_LOG(DEBUG, TAG, "CARegisterDTLSCrlHandler"); + + if(!g_isInitialized) + { + return CA_STATUS_NOT_INITIALIZED; + } + + CADTLSSetCrlCallback(GetDTLSCrlHandler); + return CA_STATUS_OK; +} +#endif //__WITH_X509__ + CAResult_t CACreateEndpoint(CATransportFlags_t flags, CATransportAdapter_t adapter, const char *addr, @@ -161,10 +212,6 @@ CAResult_t CAGenerateToken(CAToken_t *token, uint8_t tokenLength) { OIC_LOG(DEBUG, TAG, "CAGenerateToken"); - if(!g_isInitialized) - { - return CA_STATUS_NOT_INITIALIZED; - } return CAGenerateTokenInternal(token, tokenLength); } @@ -201,19 +248,6 @@ CAResult_t CASendRequest(const CAEndpoint_t *object,const CARequestInfo_t *reque return CADetachRequestMessage(object, requestInfo); } -CAResult_t CASendNotification(const CAEndpoint_t *object, const CAResponseInfo_t *responseInfo) -{ - OIC_LOG(DEBUG, TAG, "CASendNotification"); - - if(!g_isInitialized) - { - return CA_STATUS_NOT_INITIALIZED; - } - - return CADetachResponseMessage(object, responseInfo); - -} - CAResult_t CASendResponse(const CAEndpoint_t *object, const CAResponseInfo_t *responseInfo) { OIC_LOG(DEBUG, TAG, "CASendResponse"); @@ -224,7 +258,6 @@ CAResult_t CASendResponse(const CAEndpoint_t *object, const CAResponseInfo_t *re } return CADetachResponseMessage(object, responseInfo); - } CAResult_t CASelectNetwork(CATransportAdapter_t interestedNetwork) @@ -241,27 +274,37 @@ CAResult_t CASelectNetwork(CATransportAdapter_t interestedNetwork) if (interestedNetwork & CA_ADAPTER_IP) { res = CAAddNetworkType(CA_ADAPTER_IP); - OIC_LOG_V(ERROR, TAG, "CAAddNetworkType(CA_IP_ADAPTER) function returns error : %d", res); + OIC_LOG_V(DEBUG, TAG, "CAAddNetworkType(CA_IP_ADAPTER) function returns result: %d", res); } else if (interestedNetwork & CA_ADAPTER_RFCOMM_BTEDR) { res = CAAddNetworkType(CA_ADAPTER_RFCOMM_BTEDR); - OIC_LOG_V(ERROR, TAG, "CAAddNetworkType(CA_RFCOMM_ADAPTER) function returns error : %d", res); + OIC_LOG_V(DEBUG, TAG, "CAAddNetworkType(CA_RFCOMM_ADAPTER) function returns result : %d", res); } else if (interestedNetwork & CA_ADAPTER_GATT_BTLE) { res = CAAddNetworkType(CA_ADAPTER_GATT_BTLE); - OIC_LOG_V(ERROR, TAG, "CAAddNetworkType(CA_GATT_ADAPTER) function returns error : %d", res); + OIC_LOG_V(DEBUG, TAG, "CAAddNetworkType(CA_GATT_ADAPTER) function returns result : %d", res); } - #ifdef RA_ADAPTER +#ifdef RA_ADAPTER else if (interestedNetwork & CA_ADAPTER_REMOTE_ACCESS) { res = CAAddNetworkType(CA_ADAPTER_REMOTE_ACCESS); - OIC_LOG_V(ERROR, TAG, "CAAddNetworkType(CA_ADAPTER_REMOTE_ACCESS) function returns error : %d", - res); + OIC_LOG_V(DEBUG, TAG, + "CAAddNetworkType(CA_ADAPTER_REMOTE_ACCESS) function returns result : %d", res); + } +#endif + +#ifdef TCP_ADAPTER + else if (interestedNetwork & CA_ADAPTER_TCP) + { + res = CAAddNetworkType(CA_ADAPTER_TCP); + OIC_LOG_V(DEBUG, TAG, + "CAAddNetworkType(CA_ADAPTER_TCP) function returns result : %d", res); } - #endif +#endif + else { res = CA_NOT_SUPPORTED; @@ -283,26 +326,37 @@ CAResult_t CAUnSelectNetwork(CATransportAdapter_t nonInterestedNetwork) if (nonInterestedNetwork & CA_ADAPTER_IP) { res = CARemoveNetworkType(CA_ADAPTER_IP); - OIC_LOG_V(ERROR, TAG, "CARemoveNetworkType(CA_IP_ADAPTER) function returns error : %d", res); + OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_IP_ADAPTER) function returns result : %d", res); } else if (nonInterestedNetwork & CA_ADAPTER_RFCOMM_BTEDR) { res = CARemoveNetworkType(CA_ADAPTER_RFCOMM_BTEDR); - OIC_LOG_V(ERROR, TAG, "CARemoveNetworkType(CA_RFCOMM_ADAPTER) function returns error : %d", res); + OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_RFCOMM_ADAPTER) function returns result : %d", res); } else if (nonInterestedNetwork & CA_ADAPTER_GATT_BTLE) { res = CARemoveNetworkType(CA_ADAPTER_GATT_BTLE); - OIC_LOG_V(ERROR, TAG, "CARemoveNetworkType(CA_GATT_ADAPTER) function returns error : %d", res); + OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_GATT_ADAPTER) function returns result : %d", res); } - #ifdef RA_ADAPTER +#ifdef RA_ADAPTER else if (nonInterestedNetwork & CA_ADAPTER_REMOTE_ACCESS) { res = CARemoveNetworkType(CA_ADAPTER_REMOTE_ACCESS); - OIC_LOG_V(ERROR, TAG, "CARemoveNetworkType(CA_ADAPTER_REMOTE_ACCESS) function returns error : %d", - res); + OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_ADAPTER_REMOTE_ACCESS) function returns result : %d", + res); + } +#endif + + +#ifdef TCP_ADAPTER + else if (nonInterestedNetwork & CA_ADAPTER_TCP) + { + res = CARemoveNetworkType(CA_ADAPTER_TCP); + OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_ADAPTER_TCP) function returns result : %d", + res); } - #endif +#endif + else { res = CA_STATUS_FAILED;