autotest
/
xiuos
forked from xuos/xiuos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix LwIP client bug from Yu_Dongdong 

it is OK
This commit is contained in:
xuedongliang 2021-06-09 16:27:59 +08:00
parent 06c351e27c 8b1a886e13
commit b9a6714ed7
3 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
Ubiquitous/XiUOS/kernel/thread/ktask.c
View File

@ -269,12 +269,13 @@ x_err_t _KTaskPrioSet(KTaskDescriptorType task, uint8 prio)
case KTASK_INIT: case KTASK_INIT:
case KTASK_SUSPEND: case KTASK_SUSPEND:
case KTASK_RUNNING: case KTASK_RUNNING:
task->task_dync_sched_member.cur_prio = prio; KTaskDescriptorType tid; task->task_dync_sched_member.cur_prio = prio;
__BitmapSiteMask(task);
break;
case KTASK_CLOSE: case KTASK_CLOSE:
ShowTask();
KPrintf("the close stat task is forbidden to change priority.\n"); KPrintf("the close stat task is forbidden to change priority.\n");
ret = -ERROR; ret = EOK;
break; break;
default: default:
KPrintf("invalid stat task is forbidden to change priority.\n"); KPrintf("invalid stat task is forbidden to change priority.\n");

2
Ubiquitous/XiUOS/resources/ethernet/LwIP/arch/sys_arch.h
View File

@ -56,7 +56,7 @@
#include <xs_base.h> #include <xs_base.h>
/* USER CODE BEGIN 0 */ /* USER CODE BEGIN 0 */
#define SET_AS_SERVER 1 /* define this terminal is udp server or not*/ // #define SET_AS_SERVER 1 /* define this terminal is udp server or not*/
#define LOCAL_PORT_SERVER 5001 #define LOCAL_PORT_SERVER 5001
#define TARGET_PORT_CLIENT LOCAL_PORT_SERVER #define TARGET_PORT_CLIENT LOCAL_PORT_SERVER

18
Ubiquitous/XiUOS/resources/ethernet/LwIP/arch/udp_echo.c
View File

@ -107,6 +107,7 @@ static void UdpEchoThreadServer(void *arg)
while(1) while(1)
{ {
memset(recv_data, 0, RECV_DATA);
recv_data_len=recvfrom(sock,recv_data, recv_data_len=recvfrom(sock,recv_data,
RECV_DATA,0, RECV_DATA,0,
(struct sockaddr*)&seraddr, (struct sockaddr*)&seraddr,
@ -131,7 +132,7 @@ __exit:
static void UdpEchoThreadClient(void *arg) static void UdpEchoThreadClient(void *arg)
{ {
KPrintf("UdpEchoThreadClient start.\n"); KPrintf("UdpEchoThreadClient start.\n");
MdelayKTask(5000);
int sock_udp_send_once = -1; int sock_udp_send_once = -1;
sock_udp_send_once = socket(AF_INET, SOCK_DGRAM, 0); sock_udp_send_once = socket(AF_INET, SOCK_DGRAM, 0);
if (sock_udp_send_once < 0) if (sock_udp_send_once < 0)
@ -155,17 +156,20 @@ static void UdpEchoThreadClient(void *arg)
KPrintf("UDP connect sucess, start to send.\n"); KPrintf("UDP connect sucess, start to send.\n");
KPrintf("\n\nTarget Port:%d\n\n", udp_sock.sin_port); KPrintf("\n\nTarget Port:%d\n\n", udp_sock.sin_port);
sendto(sock_udp_send_once,send_msg,
strlen(send_msg),0,
(struct sockaddr*)&udp_sock,
sizeof(struct sockaddr));
KPrintf("Send UDP msg: %s ", send_msg);
while (1) while (1)
{ {
KPrintf("Lwip client is running.\n"); KPrintf("Lwip client is running.\n");
MdelayKTask(3000);
sendto(sock_udp_send_once,send_msg,
strlen(send_msg),0,
(struct sockaddr*)&udp_sock,
sizeof(struct sockaddr));
KPrintf("Send UDP msg: %s ", send_msg);
MdelayKTask(1000);
} }
__exit: __exit: