gras_socket_t **dst) {
gras_error_t errcode;
+ gras_dynar_t *sockets= gras_socketset_get();
int done = -1;
double wakeup = gras_time() + 1000000*timeout;
double now = 0;
/* construct the set of socket to ear from */
FD_ZERO(&FDS);
- gras_dynar_foreach(_gras_trp_sockets,cursor,sock_iter) {
+ gras_dynar_foreach(sockets,cursor,sock_iter) {
if (sock_iter->incoming) {
if (max_fds < sock_iter->sd)
max_fds = sock_iter->sd;
continue; /* this was a timeout */
}
- gras_dynar_foreach(_gras_trp_sockets,cursor,sock_iter) {
+ gras_dynar_foreach(sockets,cursor,sock_iter) {
if(!FD_ISSET(sock_iter->sd, &FDS)) { /* this socket is not ready */
continue;
}
gras_socket_t *accepted;
TRY(sock_iter->plugin->socket_accept(sock_iter,&accepted));
- TRY(gras_dynar_push(_gras_trp_sockets,&accepted));
+ accepted->raw = sock_iter->raw;
} else {
#if 0
FIXME: this fails of files. quite logical
return timeout_error;
}
+
+gras_error_t gras_trp_sg_setup(gras_trp_plugin_t *plug) {
+ return mismatch_error;
+}