← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/drizzled.cc

  • Committer: Brian Aker
  • Date: 2008-08-08 15:38:16 UTC
  • Revision ID: brian@tangent.org-20080808153816-858pru9i35hq1rgz
Merging up a bunch of assert() and cleanup of my_sock typedef

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/drizzled.cc
560
560
 
561
561
    for (x= 0; x < pollfd_count; x++)
562
562
    {
563
 
      if (fds[x].fd != INVALID_SOCKET)
 
563
      if (fds[x].fd != -1)
564
564
      {
565
565
        (void) shutdown(fds[x].fd, SHUT_RDWR);
566
566
        (void) closesocket(fds[x].fd);
567
 
        fds[x].fd= INVALID_SOCKET;
 
567
        fds[x].fd= -1;
568
568
      }
569
569
    }
570
570
  }
654
654
 
655
655
    for (x= 0; x < pollfd_count; x++)
656
656
    {
657
 
      if (fds[x].fd != INVALID_SOCKET)
 
657
      if (fds[x].fd != -1)
658
658
      {
659
659
        (void) shutdown(fds[x].fd, SHUT_RDWR);
660
660
        (void) closesocket(fds[x].fd);
661
 
        fds[x].fd= INVALID_SOCKET;
 
661
        fds[x].fd= -1;
662
662
      }
663
663
    }
664
664
  }
1127
1127
 
1128
1128
    ip_sock= socket(next->ai_family, next->ai_socktype, next->ai_protocol);
1129
1129
 
1130
 
    if (ip_sock == INVALID_SOCKET)
 
1130
    if (ip_sock == -1)
1131
1131
    {
1132
1132
      sql_perror(ER(ER_IPSOCK_ERROR));          /* purecov: tested */
1133
1133
      unireg_abort(1);                          /* purecov: tested */
2789
2789
inline void kill_broken_server()
2790
2790
{
2791
2791
  /* hack to get around signals ignored in syscalls for problem OS's */
2792
 
  if ((ip_sock == INVALID_SOCKET))
 
2792
  if ((ip_sock == -1))
2793
2793
  {
2794
2794
    select_thread_in_use = 0;
2795
2795
    /* The following call will never return */
2806
2806
void handle_connections_sockets()
2807
2807
{
2808
2808
  int x;
2809
 
  my_socket sock,new_sock;
 
2809
  int sock,new_sock;
2810
2810
  uint error_count=0;
2811
2811
  THD *thd;
2812
2812
  struct sockaddr_storage cAddr;
2855
2855
      size_socket length= sizeof(struct sockaddr_storage);
2856
2856
      new_sock= accept(sock, (struct sockaddr *)(&cAddr),
2857
2857
                       &length);
2858
 
      if (new_sock != INVALID_SOCKET || (socket_errno != SOCKET_EINTR && socket_errno != SOCKET_EAGAIN))
 
2858
      if (new_sock != -1 || (socket_errno != SOCKET_EINTR && socket_errno != SOCKET_EAGAIN))
2859
2859
        break;
2860
2860
    }
2861
2861
 
2862
2862
 
2863
 
    if (new_sock == INVALID_SOCKET)
 
2863
    if (new_sock == -1)
2864
2864
    {
2865
2865
      if ((error_count++ & 255) == 0)           // This can happen often
2866
2866
        sql_perror("Error in accept");