diff options
author | Michael I. Bushnell <mib@gnu.org> | 1995-06-21 18:36:48 +0000 |
---|---|---|
committer | Michael I. Bushnell <mib@gnu.org> | 1995-06-21 18:36:48 +0000 |
commit | 6b82db63cc26425fe0ac66f21bb7f934a2fa86bc (patch) | |
tree | 5ea68918ce03579575725181864076995bda2f4e /libports | |
parent | 7d9da8e2cd087f4d4482a9d9ebe4ba7203614fbb (diff) |
Initial revision
Diffstat (limited to 'libports')
-rw-r--r-- | libports/Makefile | 45 | ||||
-rw-r--r-- | libports/bucket-iterate.c | 59 |
2 files changed, 104 insertions, 0 deletions
diff --git a/libports/Makefile b/libports/Makefile new file mode 100644 index 00000000..c8858f6a --- /dev/null +++ b/libports/Makefile @@ -0,0 +1,45 @@ +# +# Copyright (C) 1995 Free Software Foundation, Inc. +# Written by Michael I. Bushnell. +# +# This file is part of the GNU Hurd. +# +# The GNU Hurd is free software; you can redistribute it and/or +# modify it under the terms of the GNU General Public License as +# published by the Free Software Foundation; either version 2, or (at +# your option) any later version. +# +# The GNU Hurd is distributed in the hope that it will be useful, but +# WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU +# General Public License for more details. +# +# You should have received a copy of the GNU General Public License +# along with this program; if not, write to the Free Software +# Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + +dir := libports +makemode := library + +SRCS = create-bucket.c create-class.c allocate-port.c intern-external-port.c \ + reallocate-port.c reallocate-from-external.c destroy-right.c \ + lookup-port.c port-ref.c port-ref-weak.c port-deref.c port-deref-weak.c \ + no-senders.c begin-rpc.c end-rpc.c manage-one-thread.c manage-multithread.c \ + inhibit-port-rpcs.c inhibit-class-rpcs.c inhibit-bucket-rpcs.c \ + inhibit-all-rpcs.c resume-port-rpcs.c resume-class-rpcs.c \ + resume-bucket-rpcs.c resume-all-rpcs.c interrupt-rpc.c \ + init.c complete-deallocate.c get-right.c count-class.c count-bucket.c \ + enable-class.c enable-bucket.c bucket-iterate.c + +OBJS = $(subst .c,.o,$(SRCS)) +LCLHDRS = ports.h +REMHDRS = ../libihash/ihash.h +libname = libports +installhdrs = ports.h + +include ../Makeconf + +$(OBJS): ports.h +allocate-port.o complete-deallocate.o create-bucket.o destroy-right.o \ +inhibit-all-rpcs.o inhibit-bucket-rpcs.o intern-external-port.o \ +lookup-port.o reallocate-from-external.o reallocate-port.o: ../libihash/ihash.h diff --git a/libports/bucket-iterate.c b/libports/bucket-iterate.c new file mode 100644 index 00000000..a85b7863 --- /dev/null +++ b/libports/bucket-iterate.c @@ -0,0 +1,59 @@ +/* + Copyright (C) 1995 Free Software Foundation, Inc. + Written by Michael I. Bushnell. + + This file is part of the GNU Hurd. + + The GNU Hurd is free software; you can redistribute it and/or + modify it under the terms of the GNU General Public License as + published by the Free Software Foundation; either version 2, or (at + your option) any later version. + + The GNU Hurd is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + General Public License for more details. + + You should have received a copy of the GNU General Public License + along with this program; if not, write to the Free Software + Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111, USA. */ + +#include "ports.h" + +/* This is obsecenely ineffecient. ihash and ports need to cooperate + more closely to do it effeciently. */ +void +ports_bucket_iterate (struct port_bucket *bucket, + void (*fun)(void *)) +{ + struct item + { + struct item *next; + void *p; + } *list = 0; + struct item *i, nxt; + + error_t enqueue (void *pi) + { + struct item *j; + + j = malloc (sizeof (struct item)); + j->next = list; + j->p = pi; + list = j; + ((struct port_info *)pi)->refcnt++; + return 0; + } + + mutex_lock (&_ports_lock); + ihash_iterate (bucket->htable, enqueue); + mutex_unlock (&_ports_lock); + + for (i = list; i; i = nxt) + { + (*fun)(i->p); + ports_port_deref (i->p); + nxt = i->next; + free (i); + } +} |