in source/coreMQTT/sockets_wrapper.c [498:546]
static BaseType_t prvCellularSocketRegisterCallback( CellularSocketHandle_t cellularSocketHandle,
cellularSocketWrapper_t * pCellularSocketContext )
{
BaseType_t retRegCallback = SOCKETS_ERROR_NONE;
CellularError_t socketStatus = CELLULAR_SUCCESS;
if( cellularSocketHandle == NULL )
{
retRegCallback = SOCKETS_EINVAL;
}
if( retRegCallback == SOCKETS_ERROR_NONE )
{
socketStatus = Cellular_SocketRegisterDataReadyCallback( CellularHandle, cellularSocketHandle,
prvCellularSocketDataReadyCallback, ( void * ) pCellularSocketContext );
if( socketStatus != CELLULAR_SUCCESS )
{
IotLogError( "Failed to SocketRegisterDataReadyCallback. Socket status %d.", socketStatus );
retRegCallback = SOCKETS_SOCKET_ERROR;
}
}
if( retRegCallback == SOCKETS_ERROR_NONE )
{
socketStatus = Cellular_SocketRegisterSocketOpenCallback( CellularHandle, cellularSocketHandle,
prvCellularSocketOpenCallback, ( void * ) pCellularSocketContext );
if( socketStatus != CELLULAR_SUCCESS )
{
IotLogError( "Failed to SocketRegisterSocketOpenCallbac. Socket status %d.", socketStatus );
retRegCallback = SOCKETS_SOCKET_ERROR;
}
}
if( retRegCallback == SOCKETS_ERROR_NONE )
{
socketStatus = Cellular_SocketRegisterClosedCallback( CellularHandle, cellularSocketHandle,
prvCellularSocketClosedCallback, ( void * ) pCellularSocketContext );
if( socketStatus != CELLULAR_SUCCESS )
{
IotLogError( "Failed to SocketRegisterClosedCallback. Socket status %d.", socketStatus );
retRegCallback = SOCKETS_SOCKET_ERROR;
}
}
return retRegCallback;
}