MiWi P2P & STAR Protocol Implementation.

#include "system.h"
#include "miwi_config.h"
#include "miwi_config_p2p.h"
#include "miwi_p2p_star.h"
#include "mimac_at86rf.h"
#include "mimem.h"
#include "delay.h"
#include "pdsDataServer.h"
#include "wlPdsTaskManager.h"
#include "miqueue.h"
#include "string.h"

Data Structures
struct	_gEstConnection

struct	_gSearchConnection

struct	_resyncConnection

struct	_TxFrame_t

struct	_TxFrameEntry_t

Macros
#define	CONNECTION_TABLE_LOST_MAX 2

#define	MAX_LINK_STATUS_FAILURES 3

#define	PROTOCOL_TIMER_INTERVAL 1000

#define	RECEIVE_ON_WHEN_IDLE 0x01

#define	SECURITY_INFO 0x80

Typedefs
typedef struct _gEstConnection	gEstConnection_t

typedef struct _gSearchConnection	gSearchConnection_t

typedef struct _resyncConnection	resyncConnection_t

typedef struct _TxFrame_t	TxFrame_t

typedef struct _TxFrameEntry_t	TxFrameEntry_t

Functions
uint8_t	AddConnection (uint8_t capacityInfo)

static void	CommandConfCallback (uint8_t msgConfHandle, miwi_status_t status, uint8_t *msgPointer)

static void	connectionRespConfCallback (uint8_t msgConfHandle, miwi_status_t status, uint8_t *msgPointer)

static void	connReqConfCallback (uint8_t msgConfHandle, miwi_status_t status, uint8_t *msgPointer)

static void	frameParse (MAC_RECEIVED_PACKET *macRxPacket)

bool	frameTransmit (INPUT bool Broadcast, API_UINT16_UNION DestinationPANID, INPUT uint8_t DestinationAddress, INPUT bool isCommand, INPUT bool SecurityEnabled, INPUT uint8_t msgLen, INPUT uint8_t msgPtr, INPUT uint8_t msghandle, INPUT bool ackReq, INPUT DataConf_callback_t ConfCallback)

static void	frameTxCallback (uint8_t handle, miwi_status_t status, uint8_t *msgPointer)

bool	isSameAddress (INPUT uint8_t Address1, INPUT uint8_t Address2)

void	macAckOnlyDataCallback (uint8_t handle, miwi_status_t status, uint8_t *msgPointer)

void	MiApp_ConnectionMode (INPUT uint8_t Mode)

uint8_t	MiApp_EstablishConnection (uint8_t Channel, uint8_t addr_len, uint8_t *addr, uint8_t Capability_info, connectionConf_callback_t ConfCallback)

bool	MiApp_Get (miwi_params_t id, uint8_t *value)

miwi_status_t	MiApp_ProtocolInit (defaultParametersRomOrRam_t defaultRomOrRamParams, defaultParametersRamOnly_t defaultRamOnlyParams)

void	MiApp_RemoveConnection (INPUT uint8_t ConnectionIndex)

bool	MiApp_ResetToFactoryNew (void)

bool	MiApp_SendData (uint8_t addr_len, uint8_t addr, uint8_t msglen, uint8_t msgpointer, uint8_t msghandle, bool ackReq, bool secEnabled, DataConf_callback_t ConfCallback)

bool	MiApp_Set (miwi_params_t id, uint8_t *value)

bool	MiApp_StartConnection (uint8_t Mode, uint8_t ScanDuration, uint32_t ChannelMap, connectionConf_callback_t ConfCallback)

bool	MiApp_SubscribeDataIndicationCallback (PacketIndCallback_t callback)

bool	MiApp_SubscribeReConnectionCallback (ReconnectionCallback_t callback)

void	P2PTasks (void)

static void	protocolTimerHandler (SYS_Timer_t *timer)

static void	protocolTimerInit (void)

static void	removeConnection (uint8_t index)

static miwi_status_t	sendConnectionRequest (void)

static void	startCompleteProcedure (bool timeronly)

uint8_t	Total_Connections (void)

Variables
uint8_t	backupChannel = 0xFF

uint8_t	conn_size = 0

uint16_t	connectionTimeInterval = 0

uint8_t	ConnMode = DISABLE_ALL_CONN

uint8_t	currentChannel = 0xFF

MiQueue_t	frameTxQueue

gEstConnection_t	gEstConnectionInfo

gSearchConnection_t	gSearchConnectionInfo

API_UINT32_UNION	IncomingFrameCounter [CONNECTION_SIZE]

MiQueue_t	indirectFrameQueue

static MIWI_TICK	lastTxFrameTick

uint8_t	LatestConnection

MiQueue_t	macAckOnlyFrameQueue

MAC_RECEIVED_PACKET	MACRxPacket

defaultParametersRamOnly_t *	miwiDefaultRamOnlyParams

defaultParametersRomOrRam_t *	miwiDefaultRomOrRamParams

uint8_t	myConnectionIndex_in_PanCo

uint8_t	MyindexinPC

uint8_t	myLongAddress [MY_ADDRESS_LENGTH] = {EUI_0,EUI_1,EUI_2,EUI_3, EUI_4, EUI_5,EUI_6,EUI_7}

API_UINT16_UNION	myPANID

uint8_t	P2PCapacityInfo = RECEIVE_ON_WHEN_IDLE \| SECURITY_INFO

p2pStarState_t	p2pStarCurrentState = INITIAL_STATE

volatile P2P_STATUS	P2PStatus

PacketIndCallback_t	pktRxcallback = NULL

static SYS_Timer_t	protocolTimer

ReconnectionCallback_t	reconnectionCallback

resyncConnection_t	resyncInfo

RECEIVED_MESSAGE	rxMessage

TxFrame_t *	sentFrame

static uint32_t	transaction_duration_us = 0

bool	txCallbackReceived = true

#define CONNECTION_TABLE_LOST_MAX 2

#define MAX_LINK_STATUS_FAILURES 3

#define PROTOCOL_TIMER_INTERVAL 1000

Referenced by protocolTimerInit().

#define RECEIVE_ON_WHEN_IDLE 0x01

#define SECURITY_INFO 0x80

typedef struct _gEstConnection gEstConnection_t

typedef struct _gSearchConnection gSearchConnection_t

typedef struct _resyncConnection resyncConnection_t

typedef struct _TxFrame_t TxFrame_t

typedef struct _TxFrameEntry_t TxFrameEntry_t

void CommandConfCallback	(	uint8_t	msgConfHandle,
		miwi_status_t	status,
		uint8_t *	msgPointer
	)

static

References MiMem_Free().

Referenced by frameParse(), macAckOnlyDataCallback(), and removeConnection().

static void connectionRespConfCallback	(	uint8_t	msgConfHandle,
		miwi_status_t	status,
		uint8_t *	msgPointer
	)

static

References MiMem_Free().

Referenced by frameParse().

static void connReqConfCallback	(	uint8_t	msgConfHandle,
		miwi_status_t	status,
		uint8_t *	msgPointer
	)

static

References CONNECTION_INTERVAL, _gEstConnection::connectionRetries, connectionTimeInterval, SYS_Timer_t::handler, SYS_Timer_t::interval, MiMem_Free(), SYS_Timer_t::mode, RFD_DATA_WAIT, sendConnectionRequest(), SUCCESS, SYS_TIMER_INTERVAL_MODE, and SYS_Timer_t::timeout.

Referenced by sendConnectionRequest().

void frameParse ( MAC_RECEIVED_PACKET * macRxPacket )

static

Referenced by P2PTasks().

bool frameTransmit	(	INPUT bool	Broadcast,
		API_UINT16_UNION	DestinationPANID,
		INPUT uint8_t *	DestinationAddress,
		INPUT bool	isCommand,
		INPUT bool	SecurityEnabled,
		INPUT uint8_t	msgLen,
		INPUT uint8_t *	msgPtr,
		INPUT uint8_t	msghandle,
		INPUT bool	ackReq,
		INPUT DataConf_callback_t	ConfCallback
	)

static void frameTxCallback	(	uint8_t	handle,
		miwi_status_t	status,
		uint8_t *	msgPointer
	)

static

References _TxFrameEntry_t::frameConfCallback, MiMem_Free(), txCallbackReceived, and _TxFrame_t::txFrameEntry.

Referenced by P2PTasks().

bool isSameAddress	(	INPUT uint8_t *	Address1,
		INPUT uint8_t *	Address2
	)

References i, and MY_ADDRESS_LENGTH.

Referenced by AddConnection(), frameParse(), MiApp_SendData(), and MiMAC_ReceivedPacket().

void macAckOnlyDataCallback	(	uint8_t	handle,
		miwi_status_t	status,
		uint8_t *	msgPointer
	)

References __CONNECTION_ENTRY::Address, _DataFrame_t::broadcast, CommandConfCallback(), _DataFrame_t::confCallback, __defaultParametersRomOrRam::ConnectionTable, _P2PStarDataFrame_t::dataFrame, frameTransmit(), _DataFrame_t::fromEDToED, MiMem_Alloc(), MiMem_Free(), miQueueRemove(), _DataFrame_t::msg, and PACKETLEN_CMD_DATA_TO_ENDDEV_SUCCESS.

Referenced by frameParse(), and MiApp_SendData().

void MiApp_ConnectionMode ( INPUT uint8_t Mode )

References ConnMode, P2PCapacityInfo, PDS_CONNECTION_MODE_ID, and PDS_Store().

Referenced by Initialize_Demo().

uint8_t MiApp_EstablishConnection	(	uint8_t	Channel,
		uint8_t	addr_len,
		uint8_t *	addr,
		uint8_t	Capability_info,
		connectionConf_callback_t	ConfCallback
	)

References _gEstConnection::address, _gEstConnection::addrLen, _gEstConnection::backupState, CHANNEL, _gEstConnection::confCallback, CONNECTION_RETRY_TIMES, _gEstConnection::connectionRetries, ConnMode, ENABLE_ALL_CONN, ESTABLISHING_NETWORK, INITIAL_STATE, MiApp_Set(), p2pStarCurrentState, SCAN_NO_BEACON, sendConnectionRequest(), and _gEstConnection::status.

Referenced by Initialize_Demo().

bool MiApp_Get	(	miwi_params_t	id,
		uint8_t *	value
	)

References CHANNEL, currentChannel, PANID, and API_UINT16_UNION::Val.

miwi_status_t MiApp_ProtocolInit	(	defaultParametersRomOrRam_t *	defaultRomOrRamParams,
		defaultParametersRamOnly_t *	defaultRamOnlyParams
	)

void MiApp_RemoveConnection ( INPUT uint8_t ConnectionIndex )

References __CONNECTION_STATUS::bits, CONNECTION_SIZE, __defaultParametersRomOrRam::ConnectionTable, i, __CONNECTION_STATUS::_CONNECTION_STAUTS_bits::isValid, PDS_CONNECTION_TABLE_ID, PDS_Store(), removeConnection(), __CONNECTION_ENTRY::status, and __CONNECTION_STATUS::Val.

bool MiApp_ResetToFactoryNew ( void )

References PDS_DeleteAll().

bool MiApp_SendData	(	uint8_t	addr_len,
		uint8_t *	addr,
		uint8_t	msglen,
		uint8_t *	msgpointer,
		uint8_t	msghandle,
		bool	ackReq,
		bool	secEnabled,
		DataConf_callback_t	ConfCallback
	)