【已解决】CME-M7芯片RTT+LWIP求助[遗留一个8小时固定死机问题]

发布于 2015-04-03 12:17:56 浏览：8355 订阅该版

27 个回答

aozima 2015-04-03

调网络不抓包，调I2C等时序不上逻辑分析仪，就像电工不用万用表！多用整理的好的文字，比截图更省流量，还能在整理过程中思考。

toasun 2015-04-03

这家伙很懒，什么也没写！

>收发音频不需要buffer吗？

下面这个程序是问题2里的，我个人感觉能用的……其他程序也类似。

```c
#define THREAD_TIME 1
#define THREAD_PRIORITY (RT_THREAD_PRIORITY_MAX - 2)
```

```c
tid_audio = rt_thread_create("audio_int",
			init_tcp_recv,
			RT_NULL,
			2048,
			THREAD_PRIORITY+1,
			THREAD_TIME);

if (tid_audio != RT_NULL)
			rt_thread_startup(tid_audio);[/code]
[code]//tcp连接线程
static void init_tcp_send(void* parameter)
{
	struct sockaddr_in local_addr,server_addr;

int sock_audio_send = -1;
	int val = SO_KEEPALIVE;
	int keepIdle = 2; // 如该连接在2秒内没有任何数据往来,则进行探测   
	int keepInterval = 1; // 探测时发包的时间间隔为1 秒  
	int keepCount = 3;// 探测尝试的次数.如果第1次探测包就收到响应了,则后2次的不再发.

//建立开关socket
	server_addr.sin_family = AF_INET;
	server_addr.sin_port = htons(port_audio);
	server_addr.sin_addr.s_addr = inet_addr(server_ip); //使用INADDR_ANY 指示任意地址
	rt_memset(&(server_addr.sin_zero),0,sizeof(server_addr.sin_zero));

//接收客户端
	while(1)
	{
		//通道没有全部退出不接收客户端
		if (lock_send_audio == 1)
		{
			rt_thread_delay(DELAY_TIME);
			continue;
		}
		else if (lock_send_audio == 0)
		{
#ifdef DBG
			rt_kprintf("set up send!
");
#endif
			//通道全部退出，释放已结束的socket
			if ( sock_audio_send!= -1)
			{
#ifdef DBG
				rt_kprintf("close sock_audio_send socket!
");
#endif
				lwip_close(sock_audio_send);
				sock_audio_send = -1;
			}

//建立新socket
			sock_audio_send = socket(AF_INET, SOCK_STREAM, 0);
			if(sock_audio_send ==  -1)
			{
				rt_kprintf("sock_audio_send error
");
				rt_thread_delay(DELAY_TIME);
				continue;
			}

//心跳帧

setsockopt(sock_audio_send, SOL_SOCKET, SO_KEEPALIVE, &val, 4);
			setsockopt(sock_audio_send, IPPROTO_TCP, TCP_KEEPIDLE, (void *)&keepIdle, sizeof(keepIdle));
			setsockopt(sock_audio_send, IPPROTO_TCP,TCP_KEEPINTVL, (void *)&keepInterval, sizeof(keepInterval));
			setsockopt(sock_audio_send,IPPROTO_TCP, TCP_KEEPCNT, (void *)&keepCount, sizeof(keepCount));

//打开开关量发送线程
			while (1)
			{
				if (connect(sock_audio_send, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1)
				{
					rt_kprintf("connect sock_audio_send faild!
");
					rt_thread_delay(DELAY_TIME);
					continue;
				}
				break;
			}

rt_kprintf("sock_audio_send: %d!
",sock_audio_send);
			lock_send_audio = 1;
			//hl_thread_start(&sock_audio_send,SEND_AUDIO);
			
			send_audio_thread(&sock_audio_send);

}
	}
}

//音频发送线程
static void send_audio_thread(void* parameter)
{
	int sock = *(int *)parameter;
	int i;
	int ret;
	rt_err_t result;
	uint32_t *buf_audio;
	uint8_t buf[(BUFF_AUDIO_LEN+4)*4];
	uint8_t signal;
	lock_send_audio = 1;

buf_audio = (uint32_t *)buf;
#ifdef DBG
	rt_kprintf("send_audio_thread enter: %d
",sock);
#endif

buf_audio[0] = 0x01eeeeee;
	buf_audio[1] = 0x00000004;//保留2开关量1数量1
	buf_audio[2] = 0x00000000;//时间2保留2
	buf_audio[BUFF_AUDIO_LEN+3] = 0xdddddd00;
	while(1)
	{
		buf_audio[2] += (0x0001<<16);//时间累加
		signal = GPIO_getBits(KGL_IN_0)
			+ GPIO_getBits(KGL_IN_1)*2
			+ GPIO_getBits(KGL_IN_2)*4
			+ GPIO_getBits(KGL_IN_3)*8;

buf[8] = signal;

//连接服务器  
		fp0_int_enable();
		result=rt_sem_take(&sem_fifo_a,RT_WAITING_FOREVER);
		if(result==RT_EOK)
		{
			for(i = 3;i < BUFF_AUDIO_LEN+3;i+=2)
			{
				buf_audio[i] = FIFO_AHB_a->fifo_data;
				buf_audio[i+1] = FIFO_AHB_c->fifo_data;
				//test
				//FIFO_AHB_b->fifo_data = fifo_ram_a[i];
			}

ret = send(sock,(uint8_t*)buf,(BUFF_AUDIO_LEN+4)*4,0);
			if(ret < 0)
			{
				rt_kprintf("send_audio_thread lost connection!
");
				break;
			}	
		}
		fp0_int_enable();//开FIFO中断	
	}

#ifdef DBG
	rt_kprintf("send_audio_thread.....leave.
");
#endif 
	lock_send_audio = 0;
};
```