• State Not Answered
  • Locked Locked
  • Replies 6 replies
  • Subscribers 22 subscribers
  • Views 2490 views
  • Users 0 members are here
Options
Related
How was your experience today?
This discussion has been locked.
You can no longer post new replies to this discussion. If you have a question you can start a new discussion

Non-blocking BSD socket - fast reconnect problem

Tomislav P

Hi

Parents
  • 0 in reply to Tomislav P

    __task void bsd_tcp_server(void)
    { SOCKADDR_IN addr; unsigned long sck_mode = 1;

    int32_t sock, sd, res; char buf[256];

    while (1) { if ((sock = socket (AF_INET, SOCK_STREAM, 0)) > 0) { addr.sin_port = htons(1000); addr.sin_family = PF_INET; addr.sin_addr.s_addr = INADDR_ANY;

    if ((res = bind(sock, (SOCKADDR *)&addr, sizeof(addr))) == SCK_SUCCESS) { if ((res = listen(sock, 1)) == SCK_SUCCESS) { sd = accept(sock, NULL, NULL); closesocket(sock);

    if (sd > 0) { sock = sd;

    if (ioctlsocket (sock, FIO_DELAY_ACK, &sck_mode) == SCK_SUCCESS) { if (ioctlsocket (sock, FIONBIO, &sck_mode) == SCK_SUCCESS) { while (1) { res = recv(sock, buf, sizeof(buf), 0);

    if ((res <= 0) && (res != SCK_EWOULDBLOCK) && (res!=SCK_ELOCKED)) { break; }

    else if (res > 0) { // analyse request, send response // if send() returns error, close socket if (analyse_response(sock, (uint8_t *) buf, res) < 0) { close_nonblocking_socket(sock); break; } }

    os_dly_wait(25);

    // if there is pending event, perform send() // if send() returns error, close socket if (send_status_update(sock) < 0) { close_nonblocking_socket(sock); break; } } } } } } }

    closesocket(sock); } os_dly_wait(25); }
    }

Reply
  • 0 in reply to Tomislav P

    __task void bsd_tcp_server(void)
    { SOCKADDR_IN addr; unsigned long sck_mode = 1;

    int32_t sock, sd, res; char buf[256];

    while (1) { if ((sock = socket (AF_INET, SOCK_STREAM, 0)) > 0) { addr.sin_port = htons(1000); addr.sin_family = PF_INET; addr.sin_addr.s_addr = INADDR_ANY;

    if ((res = bind(sock, (SOCKADDR *)&addr, sizeof(addr))) == SCK_SUCCESS) { if ((res = listen(sock, 1)) == SCK_SUCCESS) { sd = accept(sock, NULL, NULL); closesocket(sock);

    if (sd > 0) { sock = sd;

    if (ioctlsocket (sock, FIO_DELAY_ACK, &sck_mode) == SCK_SUCCESS) { if (ioctlsocket (sock, FIONBIO, &sck_mode) == SCK_SUCCESS) { while (1) { res = recv(sock, buf, sizeof(buf), 0);

    if ((res <= 0) && (res != SCK_EWOULDBLOCK) && (res!=SCK_ELOCKED)) { break; }

    else if (res > 0) { // analyse request, send response // if send() returns error, close socket if (analyse_response(sock, (uint8_t *) buf, res) < 0) { close_nonblocking_socket(sock); break; } }

    os_dly_wait(25);

    // if there is pending event, perform send() // if send() returns error, close socket if (send_status_update(sock) < 0) { close_nonblocking_socket(sock); break; } } } } } } }

    closesocket(sock); } os_dly_wait(25); }
    }

Children
  • 0 in reply to Tomislav P 

    __task void bsd_tcp_server(void)
{
   SOCKADDR_IN addr;
   unsigned long sck_mode = 1;

   int32_t sock, sd, res;
   char buf[256];

   while (1)
   {
      if ((sock = socket (AF_INET, SOCK_STREAM, 0)) > 0)
      {
         addr.sin_port        = htons(1000);
         addr.sin_family      = PF_INET;
         addr.sin_addr.s_addr = INADDR_ANY;

         if ((res = bind(sock, (SOCKADDR *)&addr, sizeof(addr))) == SCK_SUCCESS)
         {
            if ((res = listen(sock, 1)) == SCK_SUCCESS)
            {
               sd = accept(sock, NULL, NULL);
               closesocket(sock);

               if (sd > 0)
               {
                  sock = sd;

                  if (ioctlsocket (sock, FIO_DELAY_ACK, &sck_mode) == SCK_SUCCESS)
                  {
                     if (ioctlsocket (sock, FIONBIO, &sck_mode) == SCK_SUCCESS)
                     {
                        while (1)
                        {
                           res = recv(sock, buf, sizeof(buf), 0);

                           if ((res <= 0) && (res != SCK_EWOULDBLOCK) && (res!=SCK_ELOCKED))
                           {
                              break;
                           }

                           else if (res > 0)
                           {
                              // analyse request, send response
                              // if send() returns error, close socket
                              if (analyse_response(sock, (uint8_t *) buf, res) < 0)
                              {
                                 close_nonblocking_socket(sock);
                                 break;
                              }
                           }

                           os_dly_wait(25);

                           // if there is pending event, perform send()
                           // if send() returns error, close socket
                           if (send_status_update(sock) < 0)
                           {
                              close_nonblocking_socket(sock);
                              break;
                           }
                        }
                     }
                  }
               }
            }
         }

         closesocket(sock);
      }
      os_dly_wait(25);
   }
}

  • 0 Arm Employee Badge in reply to Tomislav P

    Socket close function also needs time to complete. When the socket is in non-blocking mode, the function closesocket() needs additional calls until the function returns SCK_SUCCESS.