← Back to branch summary

~brianaker/libmemcached/1164440

« back to all changes in this revision

Viewing changes to libmemcached/connect.cc

  • Committer: Continuous Integration
  • Date: 2013-02-21 09:02:24 UTC
  • mfrom: (1148.1.13 libmemcached-1.0)
  • Revision ID: ci@tangent.org-20130221090224-dpkss7vogxu15cw8
Merge lp:~tangent-org/libmemcached/1.0-build/ Build: jenkins-Libmemcached-230

Show diffs side-by-side

added added

removed removed

Lines of Context:
libmemcached/connect.cc
87
87
      int local_errno= get_socket_errno(); // We cache in case closesocket() modifies errno
88
88
      switch (local_errno)
89
89
      {
90
 
#ifdef TARGET_OS_LINUX
 
90
#ifdef __linux__
91
91
      case ERESTART:
92
92
#endif
93
93
      case EINTR:
103
103
 
104
104
      default: // This should not happen
105
105
        break;
106
 
#if 0
107
 
        if (fds[0].revents & POLLERR)
108
 
        {
109
 
          int err;
110
 
          socklen_t len= sizeof(err);
111
 
          if (getsockopt(server->fd, SOL_SOCKET, SO_ERROR, (char*)&err, &len) == 0)
112
 
          {
113
 
            if (err == 0)
114
 
            {
115
 
              // This should never happen, if it does? Punt.  
116
 
              continue;
117
 
            }
118
 
            local_errno= err;
119
 
          }
120
 
        }
121
 
#endif
122
106
      }
123
107
 
124
108
      assert_msg(server->fd != INVALID_SOCKET, "poll() was passed an invalid file descriptor");
146
130
        }
147
131
      }
148
132
 
149
 
      return  memcached_set_error(*server, MEMCACHED_TIMEOUT, MEMCACHED_AT);
 
133
      return  memcached_set_error(*server, MEMCACHED_TIMEOUT, MEMCACHED_AT, memcached_literal_param("(number_of == 0)"));
150
134
    }
151
135
 
152
 
#if 0
153
 
    server->revents(fds[0].revents);
154
 
#endif
155
 
 
156
136
    assert (number_of == 1);
157
137
 
158
138
    if (fds[0].revents & POLLERR or
267
247
 
268
248
static inline void set_socket_nonblocking(org::libmemcached::Instance* server)
269
249
{
270
 
#ifdef WIN32
 
250
#if defined(_WIN32)
271
251
  u_long arg= 1;
272
252
  if (ioctlsocket(server->fd, FIONBIO, &arg) == SOCKET_ERROR)
273
253
  {
372
352
 
373
353
#if defined(_WIN32)
374
354
#else
375
 
#if defined(SO_NOSIGPIPE)
 
355
# if defined(SO_NOSIGPIPE)
376
356
  if (SO_NOSIGPIPE)
377
357
  {
378
358
    int set= 1;
388
368
#endif
389
369
    }
390
370
  }
391
 
#endif // SO_NOSIGPIPE
 
371
# endif // SO_NOSIGPIPE
392
372
#endif // _WIN32
393
373
 
394
374
  if (server->root->flags.no_block)
461
441
 
462
442
static memcached_return_t unix_socket_connect(org::libmemcached::Instance* server)
463
443
{
464
 
#ifndef WIN32
 
444
#ifndef _WIN32
465
445
  WATCHPOINT_ASSERT(server->fd == INVALID_SOCKET);
466
446
 
467
447
  do {
663
643
 
664
644
  if (timeout_error_occured and server->state < MEMCACHED_SERVER_STATE_IN_PROGRESS)
665
645
  {
666
 
    return memcached_set_error(*server, MEMCACHED_TIMEOUT, MEMCACHED_AT);
 
646
    return memcached_set_error(*server, MEMCACHED_TIMEOUT, MEMCACHED_AT,
 
647
                               memcached_literal_param("if (timeout_error_occured and server->state < MEMCACHED_SERVER_STATE_IN_PROGRESS)"));
667
648
  }
668
649
 
669
650
  return memcached_set_error(*server, MEMCACHED_CONNECTION_FAILURE, MEMCACHED_AT); /* The last error should be from connect() */