Method synchronous

tpool/aio_simulated.cc:180–209

Process the cb synchronously */

  Process the cb synchronously
*/
void aio::synchronous(aiocb *cb)
{
  intptr_t ret_len;
  int err= 0;
  switch (cb->m_opcode)
  {
  case aio_opcode::AIO_PREAD:
    ret_len= pread(cb->m_fh, cb->m_buffer, cb->m_len, cb->m_offset);
    break;
  case aio_opcode::AIO_PWRITE:
    ret_len= pwrite(cb->m_fh, cb->m_buffer, cb->m_len, cb->m_offset);
    break;
  default:
    abort();
  }

  if (ret_len < 0)
  {
#ifdef _WIN32
    err= GetLastError();
#else
    err= errno;
#endif
    ret_len= 0;
  }
  cb->m_ret_len = ret_len;
  cb->m_err = err;
  if (ret_len)
    finish_synchronous(cb);
}

} // namespace tpool