Method init

sql/threadpool_winsockets.cc:230–258

}

void win_aiosocket::init(Vio *vio)
{
  m_is_pipe= vio->type == VIO_TYPE_NAMEDPIPE;
  m_handle=
      m_is_pipe ? vio->hPipe : (HANDLE) mysql_socket_getfd(vio->mysql_socket);

  SetFileCompletionNotificationModes(m_handle, FILE_SKIP_SET_EVENT_ON_HANDLE);
  if (vio->type == VIO_TYPE_SSL)
  {
    /*
    TODO : This requires fixing viossl to call our manipulated VIO
    */
    return;
  }

  if (!(m_buf_ptr = read_buffers.acquire_buffer()))
  {
    /* Ran out of buffers, that's fine.*/
    return;
  }

  vio->tp_ctx= this;

  m_orig_vio_has_data= vio->has_data;
  vio->has_data= my_vio_has_data;

  m_orig_vio_read= vio->read;
  vio->read= my_vio_read;
}

void init_win_aio_buffers(unsigned int n_buffers)
{