#include "lwip/tcp.h"
#include "lwip/err.h"
#include "stm32f10x.h"
#include <string.h>
#include <stdio.h>
extern struct netif *enc28j60;
enum tcp_client_state{
CLIENT_CONNECTED = 0x00U,
CLIENT_WAITING_FOR_CMD,
CLIENT_BUSY,
CLIENT_SENT,
CLIENT_ERROR,
CLIENT_CLOSE,
CLIENT_WAITING_FOR_CONNECTION
};
struct tcp_client_app_arg{
uint8_t app_state;
uint8_t textlen;
uint8_t* dataptr;
};
static struct ip_addr destip;
void tcp_client_errf(void *arg, err_t err)
{
struct tcp_client_app_arg* pro_arg = (struct tcp_client_app_arg*)arg;
printf("tcp client err\n");
pro_arg->app_state = CLIENT_ERROR;
switch(err){
case ERR_MEM: printf("Out of memory error\n"); break;
case ERR_BUF: printf("Buffer error\n"); break;
case ERR_TIMEOUT: printf("Timeout\n"); break;
case ERR_RTE: printf("Routing problem\n"); break;
case ERR_ABRT: printf("Connection aborted\n"); break;
case ERR_RST: printf("Connection reset\n"); break;
case ERR_CLSD: printf("Connection closed\n"); break;
case ERR_CONN: printf("Not connected\n"); break;
case ERR_VAL: printf("Illegal value\n"); break;
case ERR_ARG: printf("Illegal argument\n"); break;
case ERR_USE: printf("Address in use\n"); break;
case ERR_IF: printf("Low-level netif error\n"); break;
case ERR_ISCONN: printf("Already connected\n"); break;
case ERR_INPROGRESS: printf("Operation in progress\n"); break;
default: printf("Unknown error\n");
}
}
err_t tcp_client_recv(void *arg, struct tcp_pcb *pcb, struct pbuf *p, err_t err)
{
struct pbuf *q;
struct tcp_client_app_arg *appcmd = (struct tcp_client_app_arg *)arg;
uint16_t i = 0;
uint8_t ip[4];
uint8_t* str;
const char* cmd1 = "hello";
const char* cmd2 = "LEDON";
const char* cmd3 = "LEDOFF";
const char* cmd4 = "echo IP";
const char* cmd5 = "bye";
printf("tcp client recieve\n");
/* We perform here any necessary processing on the pbuf */
if (p != NULL)
{
/* We call this function to tell the LwIp that we have processed the data */
/* This lets the stack advertise a larger window, so more data can be received*/
tcp_recved(pcb, p->tot_len);
/* Check the name if NULL, no data passed, return withh illegal argument error */
if(appcmd == NULL)
{
pbuf_free(p);
return ERR_ARG;
}
appcmd->dataptr = (uint8_t*)mem_calloc(sizeof(uint8_t), p->tot_len);
if(appcmd->dataptr == NULL){
printf("Memory error\n");
return ERR_MEM;
}
appcmd->textlen = p->tot_len;
for(q=p; q!=NULL; q=q->next){
memcpy((uint8_t*)&appcmd->dataptr[i], q->payload, q->len); //同一个数据包会存在一个pbuf链表中
i = i + q->len;
}
//应用层代码
switch(appcmd->app_state){
case CLIENT_CONNECTED:
case CLIENT_WAITING_FOR_CMD: {
if(memcmp(appcmd->dataptr, cmd1, strlen(cmd1)) == 0)
{
str = "hello\n";
// tcp_write(pcb, (uint8_t*)str, strlen(str), 1);
}
else if(memcmp(appcmd->dataptr, cmd2, strlen(cmd2)) == 0)
{
GPIO_ResetBits(GPIOF,GPIO_Pin_6 | GPIO_Pin_7 | GPIO_Pin_8 | GPIO_Pin_9);
str="LEDON\n";
//还可以加上这样
/*if(GPIO_ReadInputDataBit(GPIOF,GPIO_Pin_6) == RESET)str="LEDON\n";*/
}
else if(memcmp(appcmd->dataptr, cmd3, strlen(cmd3)) == 0)
{
GPIO_SetBits(GPIOF,GPIO_Pin_6 | GPIO_Pin_7 | GPIO_Pin_8 | GPIO_Pin_9);
str="LEDOFF\n";
}
else if(memcmp(appcmd->dataptr, cmd4, strlen(cmd4)) == 0)
{
ip[0] = 192;
ip[1] = 168;
ip[2] = 0;
ip[3] = 16;
// ip[0] = enc28j60->ip_addr.addr>>24; //打出来有点不对
// ip[1] = enc28j60->ip_addr.addr>>16;
// ip[2] = enc28j60->ip_addr.addr>>8;
// ip[3] = enc28j60->ip_addr.addr;
// ip[0] = pcb->remote_ip.addr>>24;
// ip[1] = pcb->remote_ip.addr>>16;
// ip[2] = pcb->remote_ip.addr>>8;
// ip[3] = pcb->remote_ip.addr;
str = mem_calloc(sizeof(uint8_t), 30);
sprintf((char*)str, "ipaddr:%d,%d,%d,%d\n", ip[3], ip[2], ip[1], ip[0]);
tcp_write(pcb, (const char *)str, strlen(str), 1);
mem_free(str);
break;
}
else if(memcmp(appcmd->dataptr, cmd5, strlen(cmd5)) == 0)
{
appcmd->app_state = CLIENT_CLOSE;
break;
}
else
{
str = "unknown cmd\n";
// tcp_write(pcb, (uint8_t*)str, strlen(str), 1);
}
tcp_write(pcb, (const char *)str, strlen(str), 1);
break;
}
default:
{
str = "lwip down\n";
tcp_write(pcb, (const char *)str, strlen(str), 1);
break;
}
}
mem_free(appcmd->dataptr);
//取得应用层数据后，先释放pbuf队列相应数据链，再对数据进行解析与执行操作
/* End of processing, we free the pbuf */
pbuf_free(p);
}
else if (err == ERR_OK)
{
/* When the pbuf is NULL and the err is ERR_OK, the remote end
is closing the connection. */
/* We free the allocated memory and we close the connection */
mem_free(appcmd);
return tcp_close(pcb);
}
return ERR_OK;
}
err_t tcp_client_sent(void *arg, struct tcp_pcb *pcb, u16_t len)
{
struct tcp_client_app_arg* pro_arg = (struct tcp_client_app_arg*)arg;
printf("tcp client sent\n");
switch(pro_arg->app_state){
case CLIENT_WAITING_FOR_CMD:{
printf("acked!\n");
break;
}
case CLIENT_CLOSE:{
mem_free(pro_arg);
return tcp_close(pcb);
}
default:{}
}
return ERR_OK;
}
err_t tcp_client_poll(void *arg, struct tcp_pcb *pcb)
{
const char* str = "The data come from the stm32 client\n";
printf("tcp client poll\n");
tcp_write(pcb, (const char*)str, strlen(str), 1);
return ERR_OK;
}
err_t tcp_client_connected(void *arg, struct tcp_pcb *pcb, err_t err)
{
struct tcp_client_app_arg* app_arg = (struct tcp_client_app_arg*)arg;
uint8_t* str = "Welcome to the client\n";
printf("tcp client connected\n");
tcp_err(pcb, tcp_client_errf); //指定出错时的回调函数
tcp_recv(pcb, tcp_client_recv); //指定接收到新数据时的回调函数
tcp_sent(pcb, tcp_client_sent); //指定远程主机成功接收到数据的回调函数
tcp_poll(pcb, tcp_client_poll, 4); //指定轮询的时间间隔和回调函数（*250ms）
tcp_write(pcb, (const char *)str, strlen(str), 1);
app_arg->app_state = CLIENT_WAITING_FOR_CMD;
return ERR_OK;
}
void tcp_client_init(void)
{
struct tcp_pcb* client_pcb;
struct tcp_client_app_arg* app_arg;
printf("tcp client inti\n");
destip.addr = (uint32_t)192+(168<<8)+(0<<16)+(105<<24);
client_pcb = tcp_new();
if(client_pcb != NULL)
{
// tcp_bind(client_pcb,IP_ADDR_ANY,2200);
tcp_arg(client_pcb, mem_calloc(sizeof(struct tcp_client_app_arg), 1));
app_arg = client_pcb->callback_arg;
app_arg->app_state = CLIENT_WAITING_FOR_CONNECTION;
tcp_connect(client_pcb, &destip, 2200, tcp_client_connected); //按需求连接，加上条件
}
else
{
printf("tcp alloc failed\n");
}
}
楼主
标题置顶
标题高亮
