-#ifdef WIN32
- // Initiate overlapped read if needed
- get_event_handle();
-
- if(priv->overlapped)
- {
- DWORD ret;
- if(!GetOverlappedResult(*handle[0], priv->overlapped, &ret, !priv->buf_avail))
- throw system_error("GetOverlappedResult");
- else
- {
- priv->buf_avail += ret;
- delete priv->overlapped;
- priv->overlapped = 0;
- }
- }
-
- unsigned ret = min(priv->buf_avail, size);
- memcpy(buf, priv->buf_next, ret);
- priv->buf_next += ret;
- priv->buf_avail -= ret;
-
- // Initiate another overlapped read in case someone is polling us
- get_event_handle();
-#else
- int ret = ::read(*handle[0], buf, size);
- if(ret==-1)
- {
- if(errno==EAGAIN)
- return 0;
- else
- throw system_error("read");
- }
-#endif
-