int do_eventsel_loop(HANDLE other_event)
{
- int n, nhandles, nallhandles;
+ int n, nhandles, nallhandles, netindex, otherindex;
long next, ticks;
HANDLE *handles;
SOCKET *sklist;
int skcount;
long now = GETTICKCOUNT();
- if (!netevent) {
- return -1; /* doom */
+ if (run_timers(now, &next)) {
+ ticks = next - GETTICKCOUNT();
+ if (ticks < 0) ticks = 0; /* just in case */
+ } else {
+ ticks = INFINITE;
}
handles = handle_get_events(&nhandles);
handles = sresize(handles, nhandles+2, HANDLE);
nallhandles = nhandles;
- handles[nallhandles++] = netevent;
+ if (netevent)
+ handles[netindex = nallhandles++] = netevent;
+ else
+ netindex = -1;
if (other_event)
- handles[nallhandles++] = other_event;
-
- if (run_timers(now, &next)) {
- ticks = next - GETTICKCOUNT();
- if (ticks < 0) ticks = 0; /* just in case */
- } else {
- ticks = INFINITE;
- }
+ handles[otherindex = nallhandles++] = other_event;
+ else
+ otherindex = -1;
n = MsgWaitForMultipleObjects(nallhandles, handles, FALSE, ticks,
QS_POSTMESSAGE);
if ((unsigned)(n - WAIT_OBJECT_0) < (unsigned)nhandles) {
handle_got_event(handles[n - WAIT_OBJECT_0]);
- } else if (n == WAIT_OBJECT_0 + nhandles) {
+ } else if (netindex >= 0 && n == WAIT_OBJECT_0 + netindex) {
WSANETWORKEVENTS things;
SOCKET socket;
extern SOCKET first_socket(int *), next_socket(int *);
now = GETTICKCOUNT();
}
- if (other_event && n == WAIT_OBJECT_0 + nhandles + 1)
+ if (otherindex >= 0 && n == WAIT_OBJECT_0 + otherindex)
return 1;
return 0;
*/
int ssh_sftp_loop_iteration(void)
{
- if (sftp_ssh_socket == INVALID_SOCKET)
- return -1; /* doom */
-
if (p_WSAEventSelect == NULL) {
fd_set readfds;
int ret;
long now = GETTICKCOUNT();
+ if (sftp_ssh_socket == INVALID_SOCKET)
+ return -1; /* doom */
+
if (socket_writable(sftp_ssh_socket))
select_result((WPARAM) sftp_ssh_socket, (LPARAM) FD_WRITE);