/**
*
@brief TCP服務(wù)器任務(wù)
* @param
* @retval None
*/
void TCP_Server_task(void *arg)
{
err_t err=0;
err_t recv_err;
struct netconn *server_coon; //服務(wù)器連接
struct netbuf *recvbuf; //接收數(shù)據(jù)netbuf指針
struct pbuf *bufptr; //pbuf數(shù)據(jù)緩沖區(qū)指針
server_coon = netconn_new(NETCONN_TCP); //創(chuàng)建一個(gè)TCP鏈接
netconn_bind(server_coon,IP_ADDR_ANY,TCP_SERVER_PORT); //綁定端口
netconn_listen(server_coon); //進(jìn)入監(jiān)聽模式
server_coon->recv_timeout = 10; //禁止阻塞線程 等待10ms
while (1)
{
err = netconn_accept(server_coon,&client_conn); //接收連接請(qǐng)求
//printf("\r\nerr=0x%x\r\n",err);
if (err == ERR_OK) //正確說明有客戶端聯(lián)入
{
while(1)
{
if((recv_err = netconn_recv(client_conn,&recvbuf)) == ERR_OK) //接收到數(shù)據(jù)且正確
{
bufptr=recvbuf->p; //得到數(shù)據(jù)指針
memcpy(Data_buff,bufptr->payload,bufptr->tot_len); //拷貝數(shù)據(jù)
Data_buff[bufptr->tot_len]='\0'; //加入結(jié)束符
if(!memcmp(Data_buff,Video_Start,9)) //開始采集
{
Video_flag=1; //標(biāo)志位值1
CamFrame=0; //幀率清零
cam_start(); //開始采集
RTC_ITConfig(RTC_IT_WUT,ENABLE);
}
else if(!memcmp(Data_buff,Video_Stop,8)) //關(guān)閉采集
{
Video_flag=0; //標(biāo)志位值0，自動(dòng)采集完最后一幀，自動(dòng)停止
RTC_ITConfig(RTC_IT_WUT,DISABLE);
}
netbuf_delete(recvbuf); //清除緩沖netbuf
}
else if(recv_err == ERR_CLSD) //關(guān)閉連接
{
netconn_close(client_conn); //關(guān)閉連接
netconn_delete(client_conn); //刪除連接
break;
}
}
}
}
}
/*********************分割線*************************/
/**
* @brief 發(fā)送數(shù)據(jù)任務(wù)
* @param
* @retval None
*/
void CAM_Send_task(void *arg)
{
u16 len,i,temp;
u8 *ptr;
u8 flag;
while(1)
{
if(Buf_DoutPtr!=Buf_DinPtr)
{
len=(*Buf_DoutPtr);
ptr=(u8 *)(Buf_DoutPtr+1); //指向CAMbuf
flag=0;
for(i=0;i
{
if((ptr==0xFF)&&(ptr[i+1]==0xD9)) //找數(shù)據(jù)尾
{
ptr[i+2]='\r';
ptr[i+3]='\n';
temp=i+4; //有效數(shù)據(jù)長(zhǎng)度
flag=1;
break;
}
}
if(flag)
{
netconn_write(client_conn ,ptr,temp,NETCONN_COPY); //發(fā)送數(shù)據(jù)
CamFrame++; //幀率+1
}
Buf_DoutPtr+=BUFF_SIZE;
if(Buf_DoutPtr==Buf_EndPtr) Buf_DoutPtr=Buf_StartPtr; //到最后一個(gè)了
//回到開頭
}
OSTimeDly(1);
}
}
發(fā)表于 2016-12-14 14:21:37
收藏
頂
踩
樓主