main.c

这是TCP/IP协议组播的实现代码

/********************** 此程序为IP视频会议终端C400程序 ************************/

/*************************** main.c 为系统主程序 ******************************/

/**************************** designed by wangxq    ***************************/

/****************************      2006-02-23       ***************************/

#include <stdio.h>               
#include <string.h>              
#include "user.h"
#include "rom400_init.h"
#include "rom400_task.h"
#include "rom400_sock.h"

#ifdef USE_KMEM_LIB
#include "rom400_kmem.h"
#endif
#ifdef USE_XNETSTACK_LIB
#include "rom400_xnetstack.h"
#endif

void main()
{
	unsigned int i;
	#ifdef USE_XNETSTACK_LIB
    	xnetstack_install();
	#endif

	#ifdef USE_KMEM_LIB
	    kmem_install(ROM400_KMEM_MODEL_SMALLEST + 2);
	#endif


	init_rom(RAM_START, RAM_END);
	//系统存储器的初始化，为ROMINIT.LIB的函数，完成对外接的存储器定标和分配地址  
    
	clear_param_buffers();

 	
	#ifdef USE_XNETSTACK_LIB
    	printf("DS80C400 Enhanced Network Library Version %d\r\n", xnetstack_version());
	#endif

	#ifdef USE_KMEM_LIB
    	printf("DS80C400 KMEM Library Version             %d\r\n", kmem_version());
	#endif

    puts("Timing test...please wait.\r\n");
    printf("Reload : %x\r\n", task_gettickreload());

	init();//自己定义的函数，初始化自己定义的变量

	puts("Wait IpAddress And Other Information");
	
	task_settickreload(RELOAD_73_728);//装载任务调度定时器的初值

    puts("About to wait 20...");

    wait_millis(20000);//等待5秒钟左右

    printf("Reload : %x\r\n", task_gettickreload()); 

	do_static();//设置本地IP地址属性（包括IP、网关等)

    network_config();//读取并打印设置参数


	/********************** 创建发送连接 *************************/	
	memset(&send_udp_video, 0, sizeof(struct sockaddr));
	send_udp_video.sin_addr[12] = 192;
    send_udp_video.sin_addr[13] = 168;
    send_udp_video.sin_addr[14] = 0;
    send_udp_video.sin_addr[15] = 201;
    send_udp_video.sin_port = SEND_VIDEO_PORT;
		
	video_sendhandle = socket(0, SOCKET_TYPE_DATAGRAM, 0);//创建UDP视频发送连接

	syn_setDatagramAddress(video_sendhandle, 1, &send_udp_video);//设置UDP命令字发送连接地址
	memset(&send_udp_audio, 0, sizeof(struct sockaddr));
	send_udp_audio.sin_addr[12] = 192;
    send_udp_audio.sin_addr[13] = 168;
    send_udp_audio.sin_addr[14] = 0;
    send_udp_audio.sin_addr[15] = 201;
    send_udp_audio.sin_port = SEND_G711_PORT;

	g711_sendhandle = socket(0, SOCKET_TYPE_DATAGRAM, 0);//创建UDP音频发送连接

	syn_setDatagramAddress(g711_sendhandle, 1, &send_udp_audio);//设置UDP命令字发送连接地址

	/*****************创建UDP命令字发送连接***********************/

	memset(&send_udp_command, 0, sizeof(struct sockaddr));
    send_udp_command.sin_addr[12] = 192;
    send_udp_command.sin_addr[13] = 168;
    send_udp_command.sin_addr[14] = 0;
    send_udp_command.sin_addr[15] = 201;

    send_udp_command.sin_port = SEND_COMMAND_PORT;

	command_sendhandle = socket(0, SOCKET_TYPE_DATAGRAM, 0);//创建UDP命令字发送连接

	if(command_sendhandle ==  0x0FFFF)
     	puts("\r\n Failed to create command send UDP socket \r\n");
    else
	{
        puts("\r\n Succeed to create command send UDP socket \r\n");
	}

	syn_setDatagramAddress(command_sendhandle, 1, &send_udp_command);//设置UDP命令字发送连接地址

	/*****************创建UDP命令字发送连接***********************/

	/******************** 创建发送连接 ***************************/	

	/******************** 创建接收连接 ***************************/	

	/******************创建UDP视频接收连接************************/

	memset(&rev_udp_video, 0, sizeof(struct sockaddr));
    rev_udp_video.sin_addr[12] = 192;
    rev_udp_video.sin_addr[13] = 168;
    rev_udp_video.sin_addr[14] = 0;
    rev_udp_video.sin_addr[15] = 200;

    rev_udp_video.sin_port = REV_VIDEO_PORT;

	video_revhandle = socket(0, SOCKET_TYPE_DATAGRAM, 0);//创建UDP接收命令字连接

	if(video_revhandle ==  0x0FFFF)
     	puts("\r\n Failed to create receive video UDP socket \r\n");
    else
        puts("\r\n Succeed to create receive video UDP socket \r\n");

	if(bind(video_revhandle,&rev_udp_video,sizeof(struct sockaddr)) == 0)//绑定命令字接收地址和端口
        printf(" successully bind receive video address and port - %u\r\n",REV_VIDEO_PORT);
    else
        printf(" failed to bind receive video address and port \r\n");

	syn_setDatagramAddress(video_revhandle, 0, &rev_udp_video);	

	/******************创建UDP视频接收连接************************/


	/******************创建UDP音频接收连接************************/

	memset(&rev_udp_audio, 0, sizeof(struct sockaddr));
    rev_udp_audio.sin_addr[12] = 192;
    rev_udp_audio.sin_addr[13] = 168;
    rev_udp_audio.sin_addr[14] = 0;
    rev_udp_audio.sin_addr[15] = 200;

    rev_udp_audio.sin_port = REV_G711_PORT;

	g711_revhandle = socket(0, SOCKET_TYPE_DATAGRAM, 0);//创建UDP接收命令字连接

	if(g711_revhandle ==  0x0FFFF)
     	puts("\r\n Failed to create receive audio UDP socket \r\n");
    else
        puts("\r\n Succeed to create receive audio UDP socket \r\n");
	

	if(bind(g711_revhandle,&rev_udp_audio,sizeof(struct sockaddr)) == 0)//绑定命令字接收地址和端口
    {	
		printf(" successully bind receive audio address and port - %u\r\n",REV_G711_PORT);
    }
	else
	{
        printf(" failed to bind receive audio address and port \r\n");
	}

	syn_setDatagramAddress(g711_revhandle, 0, &rev_udp_audio);	

	/******************创建UDP音频接收连接************************/

	
	/******************创建UDP命令接收连接************************/

	memset(&rev_udp_command, 0, sizeof(struct sockaddr));
    rev_udp_command.sin_addr[12] = 192;
    rev_udp_command.sin_addr[13] = 168;
    rev_udp_command.sin_addr[14] = 0;
    rev_udp_command.sin_addr[15] = 200;

    rev_udp_command.sin_port = REV_COMMAND_PORT;

	command_revhandle = socket(0, SOCKET_TYPE_DATAGRAM, 0);//创建UDP接收命令字连接

	if(command_revhandle ==  0x0FFFF)
     	puts("\r\n Failed to create receive command UDP socket \r\n");
    else
        puts("\r\n Succeed to create receive command UDP socket \r\n");

	if(bind(command_revhandle,&rev_udp_command,sizeof(struct sockaddr)) == 0)//绑定命令字接收地址和端口
        printf(" successully bind receive command address and port - %u\r\n",REV_COMMAND_PORT);
    else
        printf(" failed to bind receive command address and port \r\n");
	
	syn_setDatagramAddress(command_revhandle, 0, &rev_udp_command);	

	/******************创建UDP命令接收连接************************/


	/******************** 创建接收连接 ***************************/	
	
	//start_leave();

	task_entercritsection();   
    
	result = task_fork(NORM_PRIORITY, ROM_SAVESIZE);//创建两个任务线程
    
	if (result==0x0FFFF)//创建任务失败
    {
        task_leavecritsection();
        puts("Attempt to fork failed\r\n");
        return;
    }
	else if (result==0)//发送线程
    {
        while (1)
		{
			temp = ((*rd_fifo_ef) & 0x01);
			if(temp == 1)//检测视频FIFO是否为空
			{
				dp_read_video();
				if(trans_num < 50000)
				{
					if(syn_sendto(video_sendhandle, 1472, send_addr_video) == 0)//UDP发送视频数据
					{
						trans_num++;
					}
					else
					{
						puts("send error!\r\n");	
					}
				}
			}

			temp = ((*rd_fifo_hf) & 0x01);
			if(temp == 0)//检测音频FIFO是否半满
			{
				dp_read_audio();//读取音频数据
				syn_sendto(g711_sendhandle, 1024, send_addr_audio);//UDP发送音频数据
			}

			temp = ((*dual_rev) & 0x01);
			if(temp == 0x01)//判断是否有命令字需要发送
			{					
				command_length = *(dual_rev + 1);
				for(i = 0; i < command_length;i++)
				{
					*(send_addr_command + i + 5) = (*(dual_rev + 2 + i) & 0xff);
				}
				*dual_rev = 0;
				command_length = command_length + 5;
				*(send_addr_command) = command_length;//将从双口RAM中取出的命令字打包
				syn_sendto(command_sendhandle,command_length,send_addr_command);//UDP发送命令字
			}
			task_wait(0, 0, 16);//线程挂起，进入等待
		}
    }
    else 
    {
		command_result = task_fork(NORM_PRIORITY, ROM_SAVESIZE);//创建两个任务线程
		if(command_result == 0xffff)
		{
			puts("Attempt to fork failed\r\n");
        	return;
		}
		else if(command_result == 0)//接收视频数据线程
		{
			while (1)
			{
        		rev_length_video = syn_recvfrom(video_revhandle,1472,rev_addr_video);//UDP接收视频数据
				if(rev_length_video == 1472)
				{
					dp_write_video();
				}
			}
		}
		else
		{
			audio_result = task_fork(NORM_PRIORITY, ROM_SAVESIZE);//创建两个任务线程
			if(audio_result == 0xffff)
			{
				puts("Attempt to fork failed\r\n");
        		return;
			}
			else if(audio_result == 0)//接收音频线程
			{
				while(1)
				{
					rev_length_audio = syn_recvfrom(g711_revhandle,1024,rev_addr_audio);//UDP音频接收
					//rev_length_audio = recvfrom(g711_revhandle,rev_addr_audio,1024,0,&temp_addr,sizeof(struct sockaddr));//UDP音频接收
					if(rev_length_audio == 1024)
					{
						dp_write_audio();
						//printf("IP : %bu \r\n", temp_addr.sin_addr[15]);
						//temp_addr.sin_addr[15] = 0;
					}
				}
			}
			else//接收命令字线程
			{
				task_leavecritsection();
				while (1)
				{
					rev_length_command = syn_recvfrom(command_revhandle,210, rev_addr_command);//UDP接收
					if((rev_length_command < 210) && (rev_length_command > 0))
					{
						moveto_buf();//将网络接收到的命令字放入接收缓冲区
						rev_length_command = 0;
						while(head_r != tail_r)
						{
							send_command();
						}
					}
				}
			}
		}
	}
    while(1)
	{
   	}