summaryrefslogtreecommitdiff
path: root/pfinet
diff options
context:
space:
mode:
authorMichael I. Bushnell <mib@gnu.org>1995-11-01 20:35:47 +0000
committerMichael I. Bushnell <mib@gnu.org>1995-11-01 20:35:47 +0000
commit323596bf9c6467cc985be186a0a608bd3d52795a (patch)
tree28a3cfd94116480684028cbc21adecc42b48755a /pfinet
parent6bdf4282622351abb26a79c07e7575cb8c0cea5e (diff)
Formerly io-ops.c.~3~
Diffstat (limited to 'pfinet')
-rw-r--r--pfinet/io-ops.c86
1 files changed, 86 insertions, 0 deletions
diff --git a/pfinet/io-ops.c b/pfinet/io-ops.c
index ded67992..9710ab45 100644
--- a/pfinet/io-ops.c
+++ b/pfinet/io-ops.c
@@ -146,3 +146,89 @@ S_io_readable (struct sock_user *user,
return err;
}
+error_t
+S_io_select (struct sock_user *user,
+ int *select_type,
+ int *id_tag)
+{
+ struct sock *sk;
+ error_t err;
+ int avail = 0;
+ int cancel = 0;
+ struct select_table table;
+ struct select_table_elt *elt, *nxt;
+
+ if (!user)
+ return EOPNOTSUPP;
+
+ mutex_lock (&global_lock);
+ become_task (user);
+
+ /* In Linux, this means (supposedly) that I/O will never be possible.
+ That's a lose, so prevent it from happening. */
+ assert (user->sock->ops->select);
+
+ condition_init (&table.master_condition);
+ table.head = 0;
+
+ /* The select function returns one if the specified I/O type is
+ immediately possible. If it returns zero, then it is not
+ immediately possible, and it has called select_wait. Eventually
+ it will wakeup the wait queue specified in the select_wait call;
+ at that point we should retry the call. */
+
+ for (;;)
+ {
+ if (*select_type & SELECT_READ)
+ avail |= ((*user->sock->ops->select) (user->sock, SEL_IN, &table)
+ ? SELECT_READ : 0);
+ if (*select_type & SELECT_WRITE)
+ avail |= ((*user->sock->ops->select) (user->sock, SEL_OUT, &table)
+ ? SELECT_WRITE : 0);
+ if (*select_type & SELECT_URG)
+ avail |= ((*user->sock->ops->select) (user->sock, SEL_EX, &table)
+ ? SELECT_URG : 0);
+
+ if (!avail)
+ cancel = hurd_condition_wait (&table.master_condition, &global_lock);
+
+ /* Drop the conditions implications and structures allocated in the
+ select table. */
+ for (elt = table.head; elt; elt = nxt)
+ {
+ condition_unimplies (elt->dependent_condition,
+ &table.master_condition);
+ nxt = elt->next;
+ free (elt);
+ }
+
+ if (avail)
+ {
+ mutex_unlock (&global_lock);
+ *select_type = avail;
+ return 0;
+ }
+
+ if (cancel)
+ {
+ mutex_unlock (&global_lock);
+ return EINTR;
+ }
+ }
+}
+
+/* Establish that the condition in WAIT_ADDRESS should imply
+ the condition in P. Also, add us to the queue in P so
+ that the relation can be undone at the proper time. */
+void
+select_wait (struct wait_queue **wait_address, select_table *p)
+{
+ struct select_table_elt *elt;
+
+ elt = malloc (sizeof (struct select_table_elt));
+ elt->dependent_condition = (*wait_address)->c;
+ elt->next = p->head;
+ p->head = elt;
+
+ condition_implies (elt->dependent_condition, p->master_condition);
+}