-/* $Id$ */
-
/* rl_transport - RL specific functions for transport */
-/* Copyright (c) 2004 Martin Quinson. All rights reserved. */
+/* Copyright (c) 2004, 2005, 2006, 2007, 2009, 2010. The SimGrid Team.
+ * All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
gras_socket_t gras_trp_select(double timeout)
{
xbt_dynar_t sockets =
- ((gras_trp_procdata_t) gras_libdata_by_id(gras_trp_libdata_id))->sockets;
+ ((gras_trp_procdata_t)
+ gras_libdata_by_id(gras_trp_libdata_id))->sockets;
int done = -1;
double wakeup = gras_os_time() + timeout;
double now = 0;
/* Check whether there is more data to read from the socket we selected last time.
This can happen with tcp buffered sockets since we try to get as much data as we can for them */
- if (_gras_lastly_selected_socket && _gras_lastly_selected_socket->moredata) {
- VERB0
- ("Returning _gras_lastly_selected_socket since there is more data on it");
+ if (_gras_lastly_selected_socket
+ && _gras_lastly_selected_socket->moredata) {
+ XBT_VERB
+ ("Returning _gras_lastly_selected_socket since there is more data on it");
return _gras_lastly_selected_socket;
}
fd_setsize = getdtablesize();
# else
fd_setsize = FD_SETSIZE;
-# endif /* !USE_SYSCONF */
+# endif /* !USE_SYSCONF */
#endif
}
while (done == -1) {
if (timeout > 0) { /* did we timeout already? */
now = gras_os_time();
- DEBUG2("wakeup=%f now=%f", wakeup, now);
+ XBT_DEBUG("wakeup=%f now=%f", wakeup, now);
if (now == -1 || now >= wakeup) {
/* didn't find anything; no need to update _gras_lastly_selected_socket since its moredata is 0 (or we would have returned it directly) */
THROW1(timeout_error, 0,
continue;
if (sock_iter->incoming) {
- DEBUG1("Considering socket %d for select", sock_iter->sd);
+ XBT_DEBUG("Considering socket %d for select", sock_iter->sd);
#ifndef HAVE_WINSOCK_H
if (max_fds < sock_iter->sd)
max_fds = sock_iter->sd;
#endif
FD_SET(sock_iter->sd, &FDS);
} else {
- DEBUG1("Not considering socket %d for select", sock_iter->sd);
+ XBT_DEBUG("Not considering socket %d for select", sock_iter->sd);
}
}
if (max_fds == -1) {
if (timeout > 0) {
- DEBUG1("No socket to select onto. Sleep %f sec instead.", timeout);
+ XBT_DEBUG("No socket to select onto. Sleep %f sec instead.", timeout);
gras_os_sleep(timeout);
THROW1(timeout_error, 0,
"No socket to select onto. Sleep %f sec instead", timeout);
} else {
- DEBUG0("No socket to select onto. Return directly.");
+ XBT_DEBUG("No socket to select onto. Return directly.");
THROW0(timeout_error, 0,
"No socket to select onto. Return directly.");
}
/* we cannot have more than FD_SETSIZE sockets
... but with WINSOCK which returns sockets higher than the limit (killing this optim) */
if (++max_fds > fd_setsize && fd_setsize > 0) {
- WARN1("too many open sockets (%d).", max_fds);
+ XBT_WARN("too many open sockets (%d).", max_fds);
done = 0;
break;
}
max_fds = fd_setsize;
#endif
+ tout.tv_sec = tout.tv_usec = 0;
if (timeout > 0) {
/* set the timeout */
tout.tv_sec = (unsigned long) (wakeup - now);
tout.tv_usec =
- ((wakeup - now) - ((unsigned long) (wakeup - now))) * 1000000;
+ ((wakeup - now) - ((unsigned long) (wakeup - now))) * 1000000;
p_tout = &tout;
} else if (timeout == 0) {
/* polling only */
p_tout = NULL;
}
- DEBUG2("Selecting over %d socket(s); timeout=%f", max_fds - 1, timeout);
+ XBT_DEBUG("Selecting over %d socket(s); timeout=%f", max_fds - 1,
+ timeout);
ready = select(max_fds, &FDS, NULL, NULL, p_tout);
- DEBUG1("select returned %d", ready);
+ XBT_DEBUG("select returned %d", ready);
if (ready == -1) {
switch (errno) {
case EINTR: /* a signal we don't care about occured. we don't care */
xbt_dynar_cursor_unlock(sockets);
accepted = (sock_iter->plugin->socket_accept) (sock_iter);
- DEBUG2("accepted=%p,&accepted=%p", accepted, &accepted);
+ XBT_DEBUG("accepted=%p,&accepted=%p", accepted, &accepted);
accepted->meas = sock_iter->meas;
break;
}
if (recvd < 0) {
- WARN2("socket %d failed: %s", sock_iter->sd, strerror(errno));
+ XBT_WARN("socket %d failed: %s", sock_iter->sd, strerror(errno));
/* done with this socket; remove it and break the foreach since it will change the dynar */
xbt_dynar_cursor_unlock(sockets);
gras_socket_close(sock_iter);
break;
} else if (recvd == 0) {
/* Connection reset (=closed) by peer. */
- DEBUG1("Connection %d reset by peer", sock_iter->sd);
+ XBT_DEBUG("Connection %d reset by peer", sock_iter->sd);
sock_iter->valid = 0; /* don't close it. User may keep references to it */
} else {
/* Got a suited socket ! */
- XBT_OUT;
+ XBT_OUT();
sock_iter->recvd = 1;
- DEBUG3("Filled little buffer (%c %x %d)", sock_iter->recvd_val,
+ XBT_DEBUG("Filled little buffer (%c %x %d)", sock_iter->recvd_val,
sock_iter->recvd_val, recvd);
_gras_lastly_selected_socket = sock_iter;
/* break sync dynar iteration */
}
/* No socket found. Maybe we had timeout=0 and nothing to do */
- DEBUG0("TIMEOUT");
+ XBT_DEBUG("TIMEOUT");
THROW0(timeout_error, 0, "Timeout");
}
