/*****************************************************************************
 *
 * Microchip DeviceNet Stack (Bit-Strobed Messaging Connection Object Source)
 *
 *****************************************************************************
 * FileName:        conn3.c
 * Dependencies:    
 * Processor:       PIC18F with CAN
 * Compiler:       	C18 02.20.00 or higher
 * Linker:          MPLINK 03.40.00 or higher
 * Company:         Microchip Technology Incorporated
 *
 * Software License Agreement
 *
 * The software supplied herewith by Microchip Technology Incorporated
 * (the "Company") is intended and supplied to you, the Company's
 * customer, for use solely and exclusively with products manufactured
 * by the Company. 
 *
 * The software is owned by the Company and/or its supplier, and is 
 * protected under applicable copyright laws. All rights are reserved. 
 * Any use in violation of the foregoing restrictions may subject the 
 * user to criminal sanctions under applicable laws, as well as to 
 * civil liability for the breach of the terms and conditions of this 
 * license.
 *
 * THIS SOFTWARE IS PROVIDED IN AN "AS IS" CONDITION. NO WARRANTIES, 
 * WHETHER EXPRESS, IMPLIED OR STATUTORY, INCLUDING, BUT NOT LIMITED 
 * TO, IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A 
 * PARTICULAR PURPOSE APPLY TO THIS SOFTWARE. THE COMPANY SHALL NOT, 
 * IN ANY CIRCUMSTANCES, BE LIABLE FOR SPECIAL, INCIDENTAL OR 
 * CONSEQUENTIAL DAMAGES, FOR ANY REASON WHATSOEVER.
 *
 *
 * This file contains Bit-Strobe messaging support for the Connection Object 
 * described in Section 5-4 and Chapter 7 of Volume 1 of the DeviceNet 
 * specification. Additional support is in the UsrConn.c file.
 * 
 *
 *
 * Author               Date        Comment
 *~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 * Ross Fosler			04/28/03	...	
 * 
 *****************************************************************************/

#include	"dnet.def"			// Global definitions file

#include 	"typedefs.h"

#if SUPPORT_BIT_STROBED

#include	"conn.h"			// Connection prototypes and symbols

#include	"services.h"		// Service codes
#include	"errors.h"			// Error codes
#include	"class.h"			// Class codes

#include	"route.h"			// Global symbols defined by the router
#include	"dnet.h"			// DeviceNet prototypes and symbols
#include	"CAN.h"



#pragma	udata
/*********************************************************************
 * Connection related variables
 ********************************************************************/
CONN_STROBE 	uConn3;



/*********************************************************************
 * Function:        unsigned char _Conn3Create(void)
 *
 * PreCondition:    The CAN (or other) driver must be prepared to 
 *					accept some filter settings.
 *
 * Input:       	none	
 *                  
 * Output:      	unsigned char handle to the connection	
 *
 * Side Effects:    none
 *
 * Overview:        This function creates a connection 
 *					in the predefined set and returns a 
 *					handle to the connection. The connection is 
 *					placed into a 'configuring' state. 
 *					
 *					This function will call out to the users code
 *					for additional resource allocation. If the 
 *					user returns NULL then the allocation will not
 *					occur.
 *
 * Note:            This function is not called directly by 
 *					application code.
 ********************************************************************/
unsigned char _Conn3Create()
{
	if (UsrConnCreateEvent(3))
	{
		//Initialize the connection attributes
		uConn3.attrib.state = _STATE_CONFIGURING;
		uConn3.attrib.transportClass.byte = 0x83;
		uConn3.attrib.produced_cid.bytes.LSB = (uDNet.MACID >> 3) | (0xE << 3);
		uConn3.attrib.produced_cid.bytes.MSB = uDNet.MACID << 5;
		uConn3.attrib.consumed_cid.bytes.LSB = uDNet.AllocInfo.MasterMACID | 0x80; 
		uConn3.attrib.consumed_cid.bytes.MSB = 0x00;
		uConn3.attrib.expected_packet_rate.word = 0;
		
		_existentFlags.bits.strobe = 1;
		
		// Setup the pointer and other info for the receiving side
		uConn3.rx.lenMax = uConn3.attrib.consumed_con_size.bytes.LSB;
						
		// Setup the pointer and other info for the transmitting side
		uConn3.tx.lenMax = uConn3.attrib.produced_con_size.bytes.LSB;
						
		//Issue a request to start receiving the CID
		CANSetFilter(uConn3.attrib.consumed_cid.word);
		return (3);
	}
	else return (0);
}


/*********************************************************************
 * Function:        unsigned char _Conn3Close()
 *
 * PreCondition:    The connection should have already been open.
 *
 * Input:       	none
 *                  
 * Output:      	unsigned char instance that closed
 *
 * Side Effects:    none
 *
 * Overview:        Closes the specified connection. Users code is 
 *					notified to release any used resources.
 *
 * Note:            none
 ********************************************************************/
unsigned char _Conn3Close()
{	
	// Transition to the non-existent state
	uConn3.attrib.state = _STATE_NON_EXISTENT;
	
	_establishFlags.bits.strobe = 0;
	_existentFlags.bits.strobe = 0;
	
	// Issue a request to the driver to stop receiving the message
	CANClrFilter(uConn3.attrib.consumed_cid.word);
	
	UsrConnCloseEvent(3);

	return(1);
}



/*********************************************************************
 * Function:        void _Conn3TimerEvent(void)
 *
 * PreCondition:    None
 *
 * Input:       	None	
 *                  
 * Output:      	None
 *
 * Side Effects:    None
 *
 * Overview:        Update timer and process any timer events. If the 
 *					timer overflows then the state of the connection
 *					is changed.
 *
 * Note:            None
 ********************************************************************/
void _Conn3TimerEvent(void)
{
	// Process the watchdog if the packet rate is other than 0
	if (uConn3.attrib.expected_packet_rate.word)
	{
		// Adjust the time
		uConn3.timer.word -= TICK_RESOLUTION;

		// If the wdt expires then change the state of the connection
		if (uConn3.timer.word == 0) 
		{
			uConn3.attrib.state = _STATE_TIMED_OUT;
			_establishFlags.bits.strobe = 0;
		}
	}	   
}	   





/*********************************************************************
 * Function:        void _Conn3RxEvent(void)
 *
 * PreCondition:    none
 *
 * Input:       	none
 *                  
 * Output:      	none
 *
 * Side Effects:    none
 *
 * Overview:        Process received data for this connection.
 *
 * Note:            This event occures when data has been received
 *					for this connection instance.
 ********************************************************************/
void _Conn3RxEvent(void)
{
	// Get the length of the message
	uConn3.rx.len = CANGetRxCnt();

 	// Copy the message to the connection buffer
 	CANGetRxDataTyp0(uConn3.rx.pMsg);
 	//*((_MSG_DATA *)(uConn3.rx.pMsg)) = *((_MSG_DATA *)CANGetRxDataPtr());
     
 	// Reset the connection wdt
 	uConn3.timer.word = uConn3.attrib.expected_packet_rate.word;	
		
 	// Indicate message has been received (located in conn.c)	
 	_rxFlag.bits.strobe = 1;
	
	// Notify the application
	UsrConnRxDataEvent(3);
	
  	// Release the hardware to continue receiving
   	CANRead();	
}




/*********************************************************************
 * Function:        void _Conn3TxOpenEvent(void)
 *
 * PreCondition:    A transmit request must have been made.
 *
 * Input:       	none	
 *                  
 * Output:      	none
 *
 * Side Effects:    none
 *
 * Overview:        Process open transmit que event
 *
 * Note:            This event occurs when the buffer is available 
 *					for this connection instance to transmit. A 
 *					transmit request must have been made to enter 
 *					this function.
 ********************************************************************/
void _Conn3TxOpenEvent(void)
{
 	// Copy the message to the hardware buffer
 	CANPutTxDataTyp0(uConn3.tx.pMsg);
	//*((_MSG_DATA *)CANGetTxDataPtr()) = *((_MSG_DATA *)(uConn3.tx.pMsg));

	// Set the produced CID
	CANPutTxCID(uConn3.attrib.produced_cid.word);

	// Set the length of the message
	CANPutTxCnt(uConn3.tx.len);

	// Request the hardware to queue the message to send
	CANSend(3);
	
	// Clear the transmit flag to open access to the write buffer
	// Notice the queue is cleared regardless of actually sending data
	_txFlag.bits.strobe = 0;		
}


/*********************************************************************
 * Function:        void _Conn3TxEvent(void)
 *
 * PreCondition:    Data must have been queued to transmit.
 *
 * Input:       	none	
 *                  
 * Output:      	none
 *
 * Side Effects:    none