http_server.c

Embeded MCU Tcpip code.

/* THIS SAMPLE CODE IS PROVIDED AS IS AND IS SUBJECT TO ALTERATIONS. FUJITSU */
/* MICROELECTRONICS ACCEPTS NO RESPONSIBILITY OR LIABILITY FOR ANY ERRORS OR */
/* ELIGIBILITY FOR ANY PURPOSES.                                             */
/*                 (C) Fujitsu Microelectronics Europe GmbH                  */
/*---------------------------------------------------------------------------

/*
 *Copyright (c) 2000-2002 Viola Systems Ltd.
 *All rights reserved.
 *
 *Redistribution and use in source and binary forms, with or without 
 *modification, are permitted provided that the following conditions 
 *are met:
 *
 *1. Redistributions of source code must retain the above copyright 
 *notice, this list of conditions and the following disclaimer.
 *
 *2. Redistributions in binary form must reproduce the above copyright 
 *notice, this list of conditions and the following disclaimer in the 
 *documentation and/or other materials provided with the distribution.
 *
 *3. The end-user documentation included with the redistribution, if 
 *any, must include the following acknowledgment:
 *	"This product includes software developed by Viola 
 *	Systems (http://www.violasystems.com/)."
 *
 *Alternately, this acknowledgment may appear in the software itself, 
 *if and wherever such third-party acknowledgments normally appear.
 *
 *4. The names "OpenTCP" and "Viola Systems" must not be used to 
 *endorse or promote products derived from this software without prior 
 *written permission. For written permission, please contact 
 *[e-mail].
 *
 *5. Products derived from this software may not be called "OpenTCP", 
 *nor may "OpenTCP" appear in their name, without prior written 
 *permission of the Viola Systems Ltd.
 *
 *THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED 
 *WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 
 *MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. 
 *IN NO EVENT SHALL VIOLA SYSTEMS LTD. OR ITS CONTRIBUTORS BE LIABLE 
 *FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 
 *CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 
 *SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR 
 *BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 
 *WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE 
 *OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, 
 *EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *====================================================================
 *
 *OpenTCP is the unified open source TCP/IP stack available on a series 
 *of 8/16-bit microcontrollers, please see <http://www.opentcp.org>.
 *
 *For more information on how to network-enable your devices, or how to 
 *obtain commercial technical support for OpenTCP, please see 
 *<http://www.violasystems.com/>.
 */
 
/** \file http_server.c
 *	\brief Simple HTTP server
 *	\author 
 *		\li Jari Lahti ([e-mail])
 *	\version 1.0
 *	\date 9.10.2002
 *  \bug
 *	\warning
 *	\todo
 *
 *	This file implements a simple http 1.0 server that can manage several
 *	simultaneous HTTP connections.
 */
#include <stdio.h>
#include <string.h>

#include "../../mb96348hs.h"
#include "../inet/datatypes.h"
#include "../inet/globalvariables.h"
#include "../inet/debug.h"
#include "../inet/system.h"
#include "../inet/tcp_ip.h"
#include "../inet/http/http_server.h"

UINT8 https_enabled = 0; /**< Defines whether https_init has already been invoked or not */

/** \brief Used for storing state information about different HTTP sessions
 *
 *	This is an array of http_server_state structures holding various state 
 *	information about the HTTP sessions. HTTP server uses this information
 *	to determine actions that need to be taken on sockets.
 */
struct http_server_state https[NO_OF_HTTP_SESSIONS];
struct _GETmsg GETmessage;

/** \brief Initialize HTTP server variables
 * 	\author 
 *		\li Jari Lahti ([e-mail])
 *	\date 13.10.2002
 *
 *	This function should be called before the HTTP Server application
 *	is used to set the operating parameters of it	
 */
INT8 https_init(void)
{
	UINT8 i;
	INT8 soch;


	for( i=0; i<NO_OF_HTTP_SESSIONS; i++)
	{
		https[i].state = HTTPS_STATE_FREE;
		https[i].ownersocket = 0;
		https[i].fstart = 0;
		https[i].fpoint = 0;
		https[i].flen  = 0;
		https[i].funacked = 0;
		https[i].headersent = 0;
		https[i].bodysent = 0;
		https[i].unicount = 0;
		https[i].portPin = 0;
		https[i].filesize = 0;
		soch = 	tcp_getsocket(TCP_TYPE_SERVER, TCP_TOS_NORMAL, TCP_DEF_TOUT, https_eventlistener);
		
		if(soch < 0)
		{
			DEBUGOUT("HTTP Server uncapable of getting socket\r\n");
			RESET_SYSTEM();
			/*return(-1);*/
		}
		
		https[i].ownersocket = soch;
		
		//kick_WD();
		
		soch = tcp_listen(https[i].ownersocket, HTTPS_SERVERPORT);
		
		if(soch < 0)
		{
			DEBUGOUT("HTTP Server uncapable of setting socket to listening mode\r\n");
			RESET_SYSTEM();
			/*return(-1);*/
		}		
		
	
	} 
	
	https_enabled  = 1;
	
	return(i);	
	
}


/********************************************************************************
Function:		https_run

Parameters:		void	
				
Return val:		void
				
Date:			13.10.2002

Desc:			This function is main 'thread' of HTTP server program
				and should be called periodically from main loop.
*********************************************************************************/

void https_run (void)
{
	UINT8 i;
	INT16 len;
	static UINT8 ses = 0;
	
	if( https_enabled == 0)
		return;
		
	/* Walk thru all sessions untill we found something to send or so	*/
	
	for(i=0; i<NO_OF_HTTP_SESSIONS; i++)
	{
		//kick_WD();
		
		if(ses >= NO_OF_HTTP_SESSIONS)
			ses = 0;
			
		/* Keep sockets listening	*/
		
		if(tcp_getstate(https[ses].ownersocket) < TCP_STATE_LISTENING)
		{
			tcp_listen(https[ses].ownersocket, HTTPS_SERVERPORT);
			ses++;
			continue;	
		}

		if(https[ses].state != HTTPS_STATE_ACTIVE)
		{
			ses++;
			continue;
		}
		
		if(https[ses].funacked != 0)
		{
			ses++;
			continue;		
		}
		
		if(https[ses].fstart == 0)
		{
			ses++;
			continue;		
		}		
		
		/* End of data?	*/
		
		if( https[ses].fpoint >= https[ses].flen)
		{
			tcp_close(https[ses].ownersocket);
			tcp_abort(https[ses].ownersocket);
			https_deletesession(ses);
			
			ses++;
			
			return;			
		
		}
		
		/* More data to send	*/
		
		len = https_loadbuffer(ses, &net_buf[TCP_APP_OFFSET], NETWORK_TX_BUFFER_SIZE - TCP_APP_OFFSET);
			
		if(len<0)
			return;
			
		len = tcp_send(https[ses].ownersocket, &net_buf[TCP_APP_OFFSET], NETWORK_TX_BUFFER_SIZE - TCP_APP_OFFSET, len);	
		
		if(len<0)
		{
			tcp_close(https[ses].ownersocket);
			https_deletesession(ses);
			
			ses++; 
			
			return;			
		
		}
		
		https[ses].funacked = len;
		
		
		/* Serve another session on next run	*/
		
		ses++;
		
		return;		
		
	
	}	
	
	


}

/********************************************************************************
Function:		https_eventlistener

Parameters:		INT8 cbhandle - handle to TCP socket where event is coming from	
				UINT8 event - type of event
				UINT32 par1 - parameter the meaning of depends on event
				UINT32 par2 - parameter the meaning of depends on event
				
Return val:		INT32 - depends on event but usually (-1) is error of some
						kind and positive reply means OK
				
Date:			13.10.2002

Desc:			This function is given to TCP socket as function pointer to be
				used by TCP engine to make callbacks to inform about events
				on TCP e.g. arriving data. 
*********************************************************************************/


INT32 https_eventlistener (INT8 cbhandle, UINT8 event, UINT32 par1, UINT32 par2)
{
	/* This function is called by TCP stack to inform about events	*/
	
	INT16 	i;
	INT16 	session;
	par2 = 0; // Just to prevent warnings
		
	if( https_enabled == 0)
		return(-1);
	
	if(cbhandle < 0)
		return(-1);	
		
	/* Search for rigth session	*/
	
	session = https_searchsession(cbhandle);	
	
	switch( event )
	{
	
		case TCP_EVENT_CONREQ:
		
			/* Do we have a session for requesting socket?	*/
			
			if(session < 0)
				return(-1);

			
			/* Try to get new session	*/
			
			session = https_bindsession(cbhandle);
			
			if(session < 0)			/* No resources	*/
				return(-1);

			
			return(1);
	
		case TCP_EVENT_ABORT:
		
			if(session < 0)
				return(1);
			
			https_deletesession((UINT8)session);		
			
			return(1);
		
		case TCP_EVENT_CONNECTED:
		
			if(session < 0)
				return(-1);