123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311 |
- #include "optiga/dtls/DtlsTransportLayer.h"
- #include "optiga/common/MemoryMgmt.h"
- #ifdef MODULE_ENABLE_DTLS_MUTUAL_AUTH
- int32_t DtlsTL_Init(sTL_d* PpsTL)
- {
- int32_t i4Status = (int32_t)OCP_TL_ERROR;
- do
- {
-
- if((NULL == PpsTL) || (NULL == PpsTL->pzIpAddress))
- {
- i4Status = (int32_t)OCP_TL_NULL_PARAM;
- break;
- }
-
- PpsTL->phTLHdl = (pal_socket_t*)OCP_MALLOC(sizeof(pal_socket_t));
- if(NULL == PpsTL->phTLHdl)
- {
- i4Status = (int32_t)OCP_TL_MALLOC_FAILURE;
- break;
- }
- #define PS_COMMS_HANDLE ((pal_socket_t*)PpsTL->phTLHdl)
- PS_COMMS_HANDLE->wPort = PpsTL->wPort;
-
- i4Status = pal_socket_assign_ip_address(PpsTL->pzIpAddress,&(PS_COMMS_HANDLE->sIPAddress));
- if(i4Status != E_COMMS_SUCCESS)
- {
- break;
- }
-
- PS_COMMS_HANDLE->wTimeout = PpsTL->wTimeout ;
-
- PS_COMMS_HANDLE->bMode = (uint8_t)PpsTL->eCallType;
-
- LOG_TRANSPORTMSG("Initializing UDP Connection",eInfo);
-
- i4Status = pal_socket_init(PS_COMMS_HANDLE);
- if(E_COMMS_SUCCESS != i4Status)
- {
- break;
- }
- i4Status = (int32_t)OCP_TL_OK;
- }while(FALSE);
- if(OCP_TL_OK != i4Status)
- {
- if((NULL != PpsTL)&& (NULL != PpsTL->phTLHdl))
- {
- OCP_FREE(PpsTL->phTLHdl);
- PpsTL->phTLHdl = NULL;
- }
- }
- #undef PS_COMMS_HANDLE
- return i4Status;
- }
- int32_t DtlsTL_Connect(sTL_d* PpsTL)
- {
- int32_t i4Status = (int32_t)OCP_TL_ERROR;
- do
- {
-
- if((NULL == PpsTL) || (NULL == PpsTL->phTLHdl))
- {
- i4Status = (int32_t)OCP_TL_NULL_PARAM;
- break;
- }
- #define PS_COMMS_HANDLE ((pal_socket_t*)PpsTL->phTLHdl)
-
- LOG_TRANSPORTMSG("Connecting to UDP",eInfo);
-
- i4Status = pal_socket_connect(PS_COMMS_HANDLE, PS_COMMS_HANDLE->wPort);
- if(E_COMMS_SUCCESS != i4Status)
- {
- LOG_TRANSPORTMSG("Error connecting to UDP",eError);
- break;
- }
- PpsTL->eIsConnected = eConnected;
- i4Status = (int32_t)OCP_TL_OK;
- }while(FALSE);
- #undef PS_COMMS_HANDLE
- return i4Status;
- }
- int32_t DtlsTL_Send(const sTL_d* PpsTL,uint8_t* PpbBuffer,uint16_t PdwLen)
- {
- int32_t i4Status = (int32_t)OCP_TL_ERROR;
- do
- {
-
- if((NULL == PpsTL) || (NULL == PpsTL->phTLHdl) ||(NULL == PpbBuffer))
- {
- i4Status = (int32_t)OCP_TL_NULL_PARAM;
- break;
- }
- LOG_TRANSPORTDBARY("Sending Data over UDP", PpbBuffer, PdwLen, eInfo);
-
- #define PS_COMMS_HANDLE ((pal_socket_t*)PpsTL->phTLHdl)
- i4Status = pal_socket_send(PS_COMMS_HANDLE, PpbBuffer, PdwLen);
- if (E_COMMS_SUCCESS != i4Status)
- {
- LOG_TRANSPORTMSG("Error while sending data",eError);
- break;
- }
- i4Status = (int32_t)OCP_TL_OK;
- }while(FALSE);
- #undef PS_COMMS_HANDLE
- return i4Status;
- }
- int32_t DtlsTL_Recv(const sTL_d* PpsTL,uint8_t* PpbBuffer,uint16_t* PpdwLen)
- {
- int32_t i4Status = (int32_t)OCP_TL_ERROR;
- uint32_t dwRecvLen;
- do
- {
-
- if((NULL == PpsTL) || (NULL == PpsTL->phTLHdl) || (NULL == PpbBuffer))
- {
- i4Status = (int32_t)OCP_TL_NULL_PARAM;
- break;
- }
-
- LOG_TRANSPORTMSG("Receiving over UDP",eInfo);
- #define PS_COMMS_HANDLE ((pal_socket_t*)PpsTL->phTLHdl)
- PS_COMMS_HANDLE->wTimeout = PpsTL->wTimeout;
- dwRecvLen = *PpdwLen;
-
- i4Status = pal_socket_listen(PS_COMMS_HANDLE, PpbBuffer, &dwRecvLen);
- if ((int32_t)E_COMMS_UDP_NO_DATA_RECEIVED == i4Status)
- {
- i4Status = (int32_t)OCP_TL_NO_DATA;
- LOG_TRANSPORTMSG("No data received over UDP",eError);
- break;
- }
- if (E_COMMS_SUCCESS != i4Status)
- {
- LOG_TRANSPORTMSG("Error while receiving data over UDP",eError);
- break;
- }
- LOG_TRANSPORTMSG("Received Data",eInfo);
- LOG_TRANSPORTDBARY("Received Data over UDP", PpbBuffer, dwRecvLen, eInfo);
- *PpdwLen = (uint16_t)dwRecvLen;
- i4Status = (int32_t)OCP_TL_OK;
- }while(FALSE);
- #undef PS_COMMS_HANDLE
- return i4Status;
- }
- Void DtlsTL_Disconnect(sTL_d* PpsTL)
- {
-
- if(NULL != PpsTL)
- {
- if(NULL != PpsTL->phTLHdl)
- {
-
- LOG_TRANSPORTMSG("Closing UDP Connection",eInfo);
- #define PS_COMMS_HANDLE ((pal_socket_t*)PpsTL->phTLHdl)
-
- pal_socket_close(PS_COMMS_HANDLE);
-
- OCP_FREE(PS_COMMS_HANDLE);
- PpsTL->phTLHdl = NULL;
- PpsTL->eIsConnected = eDisconnected;
- #undef PS_COMMS_HANDLE
- }
- }
- }
- #endif
|