diff options
| author | Thomas Schwinge <thomas@schwinge.name> | 2011-11-24 08:21:16 +0100 |
|---|---|---|
| committer | Thomas Schwinge <thomas@schwinge.name> | 2011-11-24 08:21:16 +0100 |
| commit | ac67fbb6e2a503e27a579bdd92bfcd180f377ac4 (patch) | |
| tree | 4f2db284b587ac7c61f76f8b9a88cf17af53dfed /libpager/demuxer.c | |
| parent | f1d119a500a9294c81330ecd52a3221578a22bc3 (diff) | |
Further port sequence number cleanup.
* libpager/priv.h (struct pager): Make seqno member of type mach_port_seqno_t.
Change all users.
* libpager/seqnos.c (_pager_stubs_update_seqno): Rename to _pager_update_seqno.
Change all users.
* libpager/demuxer.c (pager_demuxer): Make use of _pager_update_seqno.
* libpager/notify-stubs.c: Remove unused attribute where no longer appropriate.
Diffstat (limited to 'libpager/demuxer.c')
| -rw-r--r-- | libpager/demuxer.c | 20 |
1 files changed, 4 insertions, 16 deletions
diff --git a/libpager/demuxer.c b/libpager/demuxer.c index d6b99fc2..79c0ddc5 100644 --- a/libpager/demuxer.c +++ b/libpager/demuxer.c @@ -1,5 +1,5 @@ /* Demuxer for pager library - Copyright (C) 1994, 1995, 2002 Free Software Foundation + Copyright (C) 1994, 1995, 2002, 2011 Free Software Foundation This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as @@ -33,20 +33,8 @@ pager_demuxer (mach_msg_header_t *inp, int result = _pager_seqnos_memory_object_server (inp, outp) || _pager_seqnos_notify_server (inp, outp); if (!result) - { - struct pager *p; - - p = ports_lookup_port (0, inp->msgh_local_port, _pager_class); - if (p) - { - /* Synchronize our bookkeeping of the port's seqno with - the one consumed by this bogus message. */ - mutex_lock (&p->interlock); - _pager_wait_for_seqno (p, inp->msgh_seqno); - _pager_release_seqno (p, inp->msgh_seqno); - mutex_unlock (&p->interlock); - ports_port_deref (p); - } - } + /* Synchronize our bookkeeping of the port's seqno with the one consumed by + this bogus message. */ + _pager_update_seqno (inp->msgh_local_port, inp->msgh_seqno); return result; } |