+ struct pollfd fds[1];
+ short flags= 0;
+ int error;
+
+ if (read_or_write == MEM_WRITE) /* write */
+ flags= POLLOUT | POLLERR;
+ else
+ flags= POLLIN | POLLERR;
+
+ memset(&fds, 0, sizeof(struct pollfd));
+ fds[0].fd= ptr->hosts[server_key].fd;
+ fds[0].events= flags;
+
+ error= poll(fds, 1, ptr->poll_timeout);
+
+ if (error == 1)
+ return MEMCACHED_SUCCESS;
+ else if (error == 0)
+ {
+ return MEMCACHED_TIMEOUT;
+ }
+
+ WATCHPOINT;
+ /* Imposssible for anything other then -1 */
+ WATCHPOINT_ASSERT(error == -1);
+ memcached_quit_server(ptr, server_key, 1);
+
+ return MEMCACHED_FAILURE;
+
+}
+
+void memcached_io_preread(memcached_st *ptr)
+{
+ unsigned int x;
+
+ return;
+
+ for (x= 0; x < ptr->number_of_hosts; x++)
+ {
+ if (ptr->hosts[x].cursor_active &&
+ ptr->hosts[x].read_data_length < MEMCACHED_MAX_BUFFER )
+ {
+ size_t data_read;
+
+ data_read= read(ptr->hosts[x].fd,
+ ptr->hosts[x].read_ptr + ptr->hosts[x].read_data_length,
+ MEMCACHED_MAX_BUFFER - ptr->hosts[x].read_data_length);
+ if (data_read == -1)
+ continue;
+
+ ptr->hosts[x].read_buffer_length+= data_read;
+ ptr->hosts[x].read_data_length+= data_read;
+ }
+ }
+}
+
+ssize_t memcached_io_read(memcached_st *ptr, unsigned int server_key,
+ char *buffer, size_t length)
+{
+ char *buffer_ptr;
+
+ buffer_ptr= buffer;
+
+ while (length)
+ {
+ if (!ptr->hosts[server_key].read_buffer_length)
+ {
+ size_t data_read;
+
+ while (1)
+ {
+ data_read= read(ptr->hosts[server_key].fd,
+ ptr->hosts[server_key].read_buffer,
+ MEMCACHED_MAX_BUFFER);
+ if (data_read == -1)
+ {
+ switch (errno)
+ {
+ case EAGAIN:
+ {
+ memcached_return rc;
+
+ rc= io_wait(ptr, server_key, MEM_READ);
+
+ if (rc == MEMCACHED_SUCCESS)
+ continue;
+
+ memcached_quit_server(ptr, server_key, 1);
+ return -1;
+ }
+ default:
+ {
+ memcached_quit_server(ptr, server_key, 1);
+ ptr->cached_errno= errno;
+ return -1;
+ }
+ }
+ }
+ else if (data_read)
+ break;
+ /* If zero, just keep looping */
+ }
+
+ ptr->hosts[server_key].read_data_length= data_read;
+ ptr->hosts[server_key].read_buffer_length= data_read;
+ ptr->hosts[server_key].read_ptr= ptr->hosts[server_key].read_buffer;
+ }
+
+ if (length > 1)
+ {
+ size_t difference;
+
+ difference= (length > ptr->hosts[server_key].read_buffer_length) ? ptr->hosts[server_key].read_buffer_length : length;
+
+ memcpy(buffer_ptr, ptr->hosts[server_key].read_ptr, difference);
+ length -= difference;
+ ptr->hosts[server_key].read_ptr+= difference;
+ ptr->hosts[server_key].read_buffer_length-= difference;
+ buffer_ptr+= difference;
+ }
+ else
+ {
+ *buffer_ptr= *ptr->hosts[server_key].read_ptr;
+ length--;
+ ptr->hosts[server_key].read_ptr++;
+ ptr->hosts[server_key].read_buffer_length--;
+ buffer_ptr++;
+ }
+ }
+
+ return (size_t)(buffer_ptr - buffer);