#include "shrink.h"

/************************************************************************

  全局变量定义
  
*************************************************************************/

struct mimeentry mimes[] = 
{
	{"css", "text/css",0},
	{"htm", "text/html",0},
	{"html", "text/html",0},
	{"js", "text/html",0},
	{"wav", "audio/x-wav",0},
	{"swf", "application/x-shockwave-flash",0},
	{"mp3", "audio/x-mp3",0},
	{"mid", "audio/mid",0},
	{"ram", "audio/x-pn-realaudio",0},
	{"ra", "audio/x-pn-realaudio",0},
	{"doc", "application/msword",0},
	{"zip", "application/x-zip-compressed",0},
	{"xls", "application/excel",0},
	{"tgz", "application/x-tar-gz",0},
	{"tar.gz", "application/x-tar-gz",0},
	{"tar", "application/x-tar",0},
	{"gz", "application/x-gunzip",0},
	{"arj", "application/x-arj-compressed",0},
	{"rar", "application/x-arj-compressed",0},
	{"rtf", "application/rtf",0},
	{"pdf", "application/pdf",0},
	{"jpeg", "image/jpeg",0},
	{"png", "image/png",0},
	{"mpg", "video/mpeg",0},
	{"mpeg", "video/mpeg",0},
	{"asf", "video/x-ms-asf",0},
	{"avi", "video/x-msvideo",0},
	{"bmp", "image/bmp",0},
	{"jpg", "image/jpeg",0},
	{"gif", "image/gif",0},
	{"ico", "image/x-icon",0},
};

const int mine_len = sizeof(mimes) / sizeof(*mimes);


struct configentry configs[] = 
{
	{"root",			"D:\\wangjie\\wangjie\\WebServer\\trunk\\src\\WebServer_PC\\root"},
	{"default_page",	"index.html,index.cgi"},
	{"cgi_ext",			".cgi"},
	{"listen_port",		"80"},
};


struct requestlist rlist[TH_NUM];
struct requestlist * prlfree;


struct TP_threadpool tp;

////////////////////////////////////////////////////////////////////////
struct filemap fms[FILE_MAX];
int fmno=0;

/************************************************************************
** Function name:		shrink_init
** Descriptions:		初始化服务器
** output parameters:	pcom：连接指针
*************************************************************************/
void shrink_init(struct comm *pcom)
{	
	int i;
	int len;
	
#ifdef _WIN32	
	
	WSADATA data;
	WSAStartup(MAKEWORD(2,2), &data);

#endif

	for (i=0;i<mine_len;i++)                                            /*初始化mime					*/
	{
		mimes[i].extlen = strlen(mimes[i].ext);
	}

#ifdef _WINFS
	if (GETCONF(CONF_ROOT) == NULL)
	GETCONF(CONF_ROOT) = getcwd(NULL, 0);
	
#endif

#if _UCOS
	for (i=0;i<cgi_len;i++)                                             /*初始化静态cgi					*/
	{
		cgiinfos[i].envsem = sem_create(1);
		cgiinfos[i].cgisem = sem_create(0);
		cgiinfos[i].wssem = sem_create(0);
		
		thread_create(CGI_PRIO_START+i,&cgiinfos[i].CGITaskStk[CGITaskStkLengh-1],cgiinfos[i].pcgitask,(void *)0);
	}	
	
	li.luasem = sem_create(0);                                          /*初始化lua cgi					*/
	li.wssem = sem_create(0);
	thread_create(LUA_PRIO_START,LuaTaskStk,LuaParse,(void *)0);
#endif

	comm_open(pcom);													/*初始化网络                    */
	shrink_setport(pcom, atoi(GETCONF(CONF_LISPORT)));					/*设置端口						*/

	for (i=0;i<TH_NUM-1;++i)											/*初始化线程池					*/
	{
		rlist[i].next = &rlist[i+1];
	}
	rlist[i].next = 0;

	prlfree = rlist;
	
	TP_create(&tp,0,0,0,0);
	
#ifdef _FLASHFS

#define DATAADDR 0x80100000
	memcpy(&fmno,(const void *)DATAADDR,4);                             /*初始化flash文件信息			*/
	len = sizeof(struct filemap);
	for(i=0;i<fmno;++i)
	{
		memcpy(&fms[i],(const void *)(DATAADDR+4+len*i),len);
	}

#endif
}

/************************************************************************
** Function name:		shrink_finish
** Descriptions:		服务器关闭时关闭一些资源
** input parameters:	com：连接
*************************************************************************/
void shrink_finish(struct comm com)
{
	comm_close(com);
	
#ifdef _WIN32
	WSACleanup();
#endif
}

/************************************************************************
** Function name:		shrink_setport
** Descriptions:		设置服务器监听端口
** input parameters:	port：端口号
** output parameters:	pcom：连接指针
*************************************************************************/
void shrink_setport(struct comm * pcom, int port)
{
	comm_bind(pcom, port);
}

/************************************************************************
** Function name:		shrink_poll
** Descriptions:		轮询服务
** input parameters:	com：连接
*************************************************************************/
void shrink_poll(struct comm com)
{
	struct requestlist *prl;

	while (1)
	{
		
		
		if(prlfree == NULL)												/*	这里判断下是否还有空闲request*/
		{
#ifdef _UCOS
			OSTimeDly(20);
#endif
			continue;
		}
		prl = prlfree;													/*	获得一个空闲的request内存区	*/
		prlfree = prlfree->next;

		memset(&(prl->r),0,sizeof(struct request));
		comm_accept(com,&(prl->r).comm_remote);
		
		#ifdef _ZLGIP
		if(prl->r.comm_remote.us !=0xff)
		{
		#endif
			prl->r.io_remote.readlen = comm_read(prl->r.comm_remote,prl->r.io_remote.buf,IO_REMOTE);
			prl->r.io_remote.buf[prl->r.io_remote.readlen] = '\0';
#ifdef _DEBUG
			printf("read\n%s",prl->r.io_remote.buf);
#endif

			#ifdef _ZLGIP
			if(prl->r.io_remote.readlen == 0)
			{
				prl->next = prlfree;
				prlfree = prl;
				continue;
			}
			#endif
			
			TP_myworking(&tp,(TP_Work_Fun)server,prl);						/*	让工作线程开始处理请求		*/
		#ifdef _ZLGIP
		}
		else
		{
			prl->next = prlfree;
			prlfree = prl;
		}
		#endif
	}
}