tcp_demo.c
4.61 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
/**
******************************************************************************
* @file tcp_demo.c
* @version V1.2
* @date 2017-11-01
* @brief TCP 演示函数
*
* @company 深圳炜世科技有限公司
* @information WIZnet W5500官方代理商，全程技术支持，价格绝对优势！
* @website www.wisioe.com
* @forum www.w5500.cn
* @qqGroup 383035001
******************************************************************************
*/
#include <stdio.h>
#include <string.h>
#include "tcp_demo.h"
#include "W5500_conf.h"
#include "w5500.h"
#include "socket.h"
#include "base_core_user.h"
#include "function_interface.h"
#include "platform_interface.h"
uint8 buff[2048]; /*定义一个2KB的缓存*/
unsigned char tcp_send_data_to_pc(unsigned char *buff,unsigned short len)
{
return send(SOCK_TCPS,buff,len);
}
/**
*@brief TCP Server回环演示函数。
*@param 无
*@return 无
*/
unsigned char test_stat;
void do_tcp_server(void)
{
uint16 len=0;
unsigned char sr_stat;
if( !function.TCPIP__SW) return ;
platform.disable_interrupt();
sr_stat =getSn_SR(SOCK_TCPS);
/*20200327 解决拔插网线后不能再连接的问题:
a,网线拔出后重新初始化socket;
b,和sdk连接时有时会进入到SOCK_SYNRECV状态导致无法连接，why? 重新初始化socket；*/
if( ( ((0x01&getPHYStatus() )==0) &&(sr_stat !=SOCK_LISTEN) ) || (sr_stat ==SOCK_SYNRECV) ){
socket(SOCK_TCPS ,Sn_MR_TCP,local_port,Sn_MR_ND); /*打开socket*/
listen(SOCK_TCPS); /*socket建立监听*/
}
switch(sr_stat ) /*获取socket的状态*/
{
case SOCK_CLOSED: /*socket处于关闭状态*/
socket(SOCK_TCPS ,Sn_MR_TCP,local_port,Sn_MR_ND); /*打开socket*/
break;
case SOCK_INIT: /*socket已初始化状态*/
listen(SOCK_TCPS); /*socket建立监听*/
break;
case SOCK_ESTABLISHED: /*socket处于连接建立状态*/
if(getSn_IR(SOCK_TCPS) & Sn_IR_CON)
{
setSn_IR(SOCK_TCPS, Sn_IR_CON); /*清除接收中断标志位*/
}
len=getSn_RX_RSR(SOCK_TCPS); /*定义len为已接收数据的长度*/
// if(len>0)
// {
// recv(SOCK_TCPS,buff,len); /*接收来自Client的数据*/
// buff[len]=0x00; /*添加字符串结束符*/
// //printf("%s\r\n",buff);
// send(SOCK_TCPS,buff,len); /*向Client发送数据*/
// }
if(len>0)
{
recv(SOCK_TCPS,buff,len); /*接收来自Client的数据*/
if( (buff[0] ==0xf5)&&(buff[1] ==0xaa)&&(buff[2] ==0xaa) ){
void set_pc_communication_type(unsigned char type);
set_pc_communication_type(1);
base_core.sdk_data_fifo_in(buff+3);
}
}
break;
case SOCK_SYNRECV:
break;
case SOCK_CLOSE_WAIT: /*socket处于等待关闭状态*/
close(SOCK_TCPS);
break;
}
platform.enable_interrupt();
}
/**
*@brief TCP Client回环演示函数。
*@param 无
*@return 无
*/
void do_tcp_client(void)
{
uint16 len=0;
switch(getSn_SR(SOCK_TCPC)) /*获取socket的状态*/
{
case SOCK_CLOSED: /*socket处于关闭状态*/
//printf("初始化\r\n");
socket(SOCK_TCPC,Sn_MR_TCP,local_port,Sn_MR_ND);
break;
case SOCK_INIT: /*socket处于初始化状态*/
//printf("连接\r\n");
connect(SOCK_TCPC,remote_ip,remote_port); /*socket连接服务器*/
break;
case SOCK_ESTABLISHED: /*socket处于连接建立状态*/
if(getSn_IR(SOCK_TCPC) & Sn_IR_CON)
{
setSn_IR(SOCK_TCPC, Sn_IR_CON); /*清除接收中断标志位*/
}
len=getSn_RX_RSR(SOCK_TCPC); /*定义len为已接收数据的长度*/
if(len>0)
{
recv(SOCK_TCPC,buff,len); /*接收来自Server的数据*/
buff[len]=0x00; /*添加字符串结束符*/
//printf("%s\r\n",buff);
send(SOCK_TCPC,buff,len); /*向Server发送数据*/
}
break;
case SOCK_CLOSE_WAIT: /*socket处于等待关闭状态*/
//printf("关闭\r\n");
close(SOCK_TCPC);
break;
}
}