Re: [lwip-users] lwip socket is stable

[Felipe de Andrade Neves L.]

Isolate the problem, what is the task that works, the one that has higher priority or the one initialized first?

It could be something with your tasks priorities, try to make the task that listen to 8081 higher in priority then the one that listen to 8080.

2011/8/15 vincent cui <address@hidden>

Dear everyone:

I create two task in freeRTOS. And use them to send/receive data from client..
But only one task works .. I don't know why...


xTaskCreate( SocketTask, (signed char *) NULL, SOCKET_TASK_STACK_SIZE, NULL, SOCKET_TASK_PRIORITY+0, NULL);
xTaskCreate( SocketTask1, (signed char *) NULL, SOCKET_TASK_STACK_SIZE, NULL, SOCKET_TASK_PRIORITY+1, NULL);

void SocketTask(void * pvArg)
{
       u8_t buf[32];
       int count;
       int listenfd;
       int remotefd;
       int len;
       struct sockaddr_in local_addr,remote_addr;
       fd_set readset;
       fd_set writeset;
       struct timeval timeout;
       timeout.tv_sec = 1;
       timeout.tv_usec = 0;
       // waiting for HDCP to get allocate IP
       while (IPaddress == netif.ip_addr.addr)
       {
               vTaskDelay(100);
       }

   listenfd = socket(AF_INET,SOCK_STREAM,0);
   local_addr.sin_family = AF_INET;
       local_addr.sin_port = htons(8080);
       local_addr.sin_len = sizeof(local_addr);
       local_addr.sin_addr.s_addr = INADDR_ANY;

       if (bind(listenfd, (struct sockaddr *) &local_addr, sizeof(local_addr)) < 0)
       {
               printf(" socket bind 8080fail \r\n");
               return ;
       }

   if (listen(listenfd, 1) == -1)
       {
               return;
       }
   len = sizeof(remote_addr);
       while(1)
       {
               remotefd = accept(listenfd, (struct sockaddr *)&remote_addr, &len);
               if(remotefd != -1)
               {
                       int ret;
                       send(remotefd,"start to work!\r\n",16,0);
                       for(;;)
                       {
                               FD_ZERO(&readset);
                               FD_ZERO(&writeset);
                               FD_SET(remotefd, &readset);
                               FD_SET(remotefd, &writeset);
               ret = lwip_select(remotefd+1, &readset, &writeset, 0, &timeout);
                               if(ret > 0)
                               {
                                       if (FD_ISSET(remotefd, &readset))
                                       {
                                                memset(buf,0,32);
                                                if(recv(remotefd,buf,32,0) <= 0)
                                                {
                                                       close(remotefd);
                                                       remotefd = -1;
                                                       break;
                                                }
                                                else
                                                {
                                                       int i = strlen(buf);
                                                       send(remotefd,buf,i ,0);
                                               }
                                       }
                               }
                               else if(ret < 0)
                               {
                                       close(remotefd);
                                       remotefd = -1;
                                       break;
                               }
                               vTaskDelay(100);
                       }
               }
               vTaskDelay(100);
       }

}

void SocketTask1(void * pvArg)
{
       u8_t buf[32];
       int count;
       int listenfd;
       int remotefd;
       int len;
       struct sockaddr_in local_addr,remote_addr;
       fd_set readset;
       fd_set writeset;
       struct timeval timeout;
       timeout.tv_sec = 1;
       timeout.tv_usec = 0;
       // waiting for HDCP to get allocate IP
       while (IPaddress == netif.ip_addr.addr)
       {
               vTaskDelay(100);
       }

   listenfd = socket(AF_INET,SOCK_STREAM,0);
   local_addr.sin_family = AF_INET;
       local_addr.sin_port = htons(port);
       local_addr.sin_len = sizeof(8081);
       local_addr.sin_addr.s_addr = INADDR_ANY;

       if (bind(listenfd, (struct sockaddr *) &local_addr, sizeof(local_addr)) < 0)
       {
               printf(" socket bind 8081 fail \r\n");
               return ;
       }

   if (listen(listenfd, 1) == -1)
       {
               return;
       }
   len = sizeof(remote_addr);
       while(1)
       {
               remotefd = accept(listenfd, (struct sockaddr *)&remote_addr, &len);
               if(remotefd != -1)
               {
                       int ret;
                       send(remotefd,"start to work!\r\n",16,0);
                       for(;;)
                       {
                               FD_ZERO(&readset);
                               FD_ZERO(&writeset);
                               FD_SET(remotefd, &readset);
                               FD_SET(remotefd, &writeset);
               ret = lwip_select(remotefd+1, &readset, &writeset, 0, &timeout);
                               if(ret > 0)
                               {
                                       if (FD_ISSET(remotefd, &readset))
                                       {
                                                memset(buf,0,32);
                                                if(recv(remotefd,buf,32,0) <= 0)
                                                {
                                                       close(remotefd);
                                                       remotefd = -1;
                                                       break;
                                                }
                                                else
                                                {
                                                       int i = strlen(buf);
                                                       send(remotefd,buf,i ,0);
                                               }
                                       }
                               }
                               else if(ret < 0)
                               {
                                       close(remotefd);
                                       remotefd = -1;
                                       break;
                               }
                               vTaskDelay(100);
                       }
               }
               vTaskDelay(100);
       }

}
----------------------------------------------------------------------

锘?Vincent Cui
Sr.Firmware Engineer
Mobile: +8613482482211
Tel: +86 21 34612525x6104
Fax: +86 21 34619770
E-Mail: address@hidden
Shanghai EnLogic Electric Technology Co., Ltd.
Address: 1104-1106, Building A, No.391, Guiping Road, Xuhui District, Shanghai, 200233
http://www.enlogic.com
-----Original Message-----

From: lwip-users-bounces+vincent.cui=address@hidden [mailto:lwip-users-bounces+vincent.cui=address@hidden] On Behalf Of FreeRTOS Info
Sent: 2011年8月12日 16:38
To: Mailing list for lwIP users
Subject: Re: [lwip-users] lwip socket is stable

I think, to get a reasonable answer, you would fist have to post the
relevant snippet of your code - the bit that is accepting and using
connections.


Regards,
Richard.

+ http://www.FreeRTOS.org
Designed for Microcontrollers.
More than 7000 downloads per month.




On 12/08/2011 08:53, vincent cui wrote:
> Kieran Mansley:
>
> I create a task that will listen 8080 port and receive data from client. And I use TCP tool to connect it and send data, it works well
>
> But, I add to create a task that will listen 8081 port. After the first task connect and work,, the second task cann't connect...
>
> Why ?
>
>
> Vincent
>
>
>
> ï»?Vincent Cui
> Sr.Firmware Engineer
> Mobile: +8613482482211
> Tel: +86 21 34612525x6104
> Fax: +86 21 34619770
> E-Mail: address@hidden
> Shanghai EnLogic Electric Technology Co., Ltd.
> Address: 1104-1106, Building A, No.391, Guiping Road, Xuhui District, Shanghai, 200233
> http://www.enlogic.com
> -----Original Message-----
> From: lwip-users-bounces+vincent.cui=address@hidden [mailto:lwip-users-bounces+vincent.cui=address@hidden] On Behalf Of Kieran Mansley
> Sent: 2011Äê8ÔÂ11ÈÕ 22:44
> To: Mailing list for lwIP users
> Subject: Re: [lwip-users] lwip socket is stable
>
> On Thu, 2011-08-11 at 14:27 +0000, vincent cui wrote:
>> I mean lwIP socket code is without error correction .
>
> If you use a SOCK_STREAM socket it will be reliable, and in order, as
> for any SOCK_STREAM socket on any other system.  If you use a SOCK_DGRAM
> socket it will (again, as for other systems) be unreliable and
> potentially out of order.
>
>> I will port BOA webserver base on lwIP..is it feasible ?
>
> No idea; I've no experience of that webserver I'm afraid.
>
> Kieran
>
>
> _______________________________________________
> lwip-users mailing list
> address@hidden
> https://lists.nongnu.org/mailman/listinfo/lwip-users
> _______________________________________________
> lwip-users mailing list
> address@hidden
> https://lists.nongnu.org/mailman/listinfo/lwip-users


_______________________________________________
lwip-users mailing list
address@hidden
https://lists.nongnu.org/mailman/listinfo/lwip-users
_______________________________________________
lwip-users mailing list
address@hidden
https://lists.nongnu.org/mailman/listinfo/lwip-users