初级会员

- 积分
- 166
- 金钱
- 166
- 注册时间
- 2014-11-21
- 在线时间
- 10 小时
|

楼主 |
发表于 2015-12-8 09:11:31
|
显示全部楼层
回复【5楼】wangjakn:
---------------------------------
不知道应该贴哪部分啊,昨天又试了下,发现我把发送关了,就坚挺了,是不是发送函数没有释放内存啊,但是不知道那哪里释放。
static err_t
low_level_output(struct netif *netif, struct pbuf *p)//这是发送底层
{
struct pbuf *q;
int l = 0;
// u32_t result;
u8 *buffer = (u8 *)ETH_GetCurrentTxBuffer();
for(q = p; q != NULL; q = q->next)
{
memcpy((u8_t*)&buffer[l], q->payload, q->len);
l = l + q->len;
}
ETH_TxPkt_ChainMode(l);
return ERR_OK;
}
void tcp_server_thread(void *arg)//这个线程使用的原子哥例程里的
{
OS_CPU_SR cpu_sr;
u32 data_len = 0;
struct pbuf *q;
err_t err;
u8 remot_addr[4];
struct netconn *conn, *newconn;
static ip_addr_t ipaddr;
static u16_t port;
LWIP_UNUSED_ARG(arg);
conn = netconn_new(NETCONN_TCP); //创建一个TCP链接
if(conn !=NULL)
{
err=netconn_bind(conn,IP_ADDR_ANY,TCPSERVER_PORT_NO); //绑定端口
if(err==ERR_OK)
{
netconn_listen(conn); //进入监听模式
conn->recv_timeout = 10; //禁止阻塞线程 等待10ms
}
}
while (1)
{
newconn = netconn_accept(conn); //接收连接请求
if(newconn!=NULL) newconn->recv_timeout = 10;
if (newconn!=NULL) //处理新连接的数据
{
struct netbuf *recvbuf;
netconn_getaddr(newconn,&ipaddr,&port,0); //获取远端IP地址和端口号
remot_addr[3] = (uint8_t)(ipaddr.addr >> 24);
remot_addr[2] = (uint8_t)(ipaddr.addr>> 16);
remot_addr[1] = (uint8_t)(ipaddr.addr >> 8);
remot_addr[0] = (uint8_t)(ipaddr.addr);
printf("主机%d.%d.%d.%d连接上服务器,主机端口号为:%d\r\n",remot_addr[0], remot_addr[1],remot_addr[2],remot_addr[3],port);
while(1)
{
if((tcp_server_flag & LWIP_SEND_DATA) == LWIP_SEND_DATA) //有数据要发送
{
err = netconn_write(newconn ,tcp_server_sendbuf,strlen((char*)tcp_server_sendbuf),NETCONN_COPY); //发送tcp_server_sendbuf中的数据
if(err != ERR_OK)
{
printf("发送失败\r\n");
}
tcp_server_flag &= ~LWIP_SEND_DATA;
memset(tcp_server_sendbuf,0,sizeof(tcp_server_sendbuf));
}
ERR_CHERK= newconn->err;
if((recvbuf = netconn_recv(newconn)) != NULL) //接收到数据
{
OS_ENTER_CRITICAL(); //关中断
memset(tcp_server_recvbuf,0,TCP_SERVER_RX_BUFSIZE); //数据接收缓冲区清零
for(q=recvbuf->p;q!=NULL;q=q->next) //遍历完整个pbuf链表
{
//判断要拷贝到TCP_SERVER_RX_BUFSIZE中的数据是否大于TCP_SERVER_RX_BUFSIZE的剩余空间,如果大于
//的话就只拷贝TCP_SERVER_RX_BUFSIZE中剩余长度的数据,否则的话就拷贝所有的数据
if(q->len > (TCP_SERVER_RX_BUFSIZE-data_len)) memcpy(tcp_server_recvbuf+data_len,q->payload,(TCP_SERVER_RX_BUFSIZE-data_len));//拷贝数据
else memcpy(tcp_server_recvbuf+data_len,q->payload,q->len);
data_len += q->len;
if(data_len > TCP_SERVER_RX_BUFSIZE) break; //超出TCP客户端接收数组,跳出
}
OS_EXIT_CRITICAL(); //开中断
data_len=0; //复制完成后data_len要清零。
netbuf_delete(recvbuf);
}else if(newconn->err==ERR_CLSD) //关闭连接
{
netconn_close(newconn);
netconn_delete(newconn);
printf("主机:%d.%d.%d.%d断开与服务器的连接\r\n",remot_addr[0], remot_addr[1],remot_addr[2],remot_addr[3]);
break;
}
LwIP_Periodic_Handle();
}
}
else
{
}
//delay_ms(100);
}
} |
|