Network/multiobserver.cpp

   1 /*
   2  * Copyright (c) 2000-2001 Apple Computer, Inc. All Rights Reserved.
   3  *
   4  * The contents of this file constitute Original Code as defined in and are
   5  * subject to the Apple Public Source License Version 1.2 (the 'License').
   6  * You may not use this file except in compliance with the License. Please obtain
   7  * a copy of the License at http://www.apple.com/publicsource and read it before
   8  * using this file.
   9  *
  10  * This Original Code and all software distributed under the License are
  11  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESS
  12  * OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, INCLUDING WITHOUT
  13  * LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
  14  * PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. Please see the License for the
  15  * specific language governing rights and limitations under the License.
  16  */
  17
  18
  19 //
  20 // multiobserver - Observer multiplexer
  21 //
  22 #include "multiobserver.h"
  23
  24
  25
  26 namespace Security {
  27 namespace Network {
  28
  29
  30 //
  31 // Manage the observer set
  32 //
  33 void MultiplexObserver::add(Observer &obs)
  34 {
  35     mObservers.insert(&obs);
  36     Observer::setEvents(getEvents() | obs.getEvents());
  37 }
  38
  39 void MultiplexObserver::remove(Observer &obs)
  40 {
  41     mObservers.erase(&obs);
  42     setEvents();
  43 }
  44
  45
  46 //
  47 // (Re)calculate the event mask
  48 //
  49 void MultiplexObserver::setEvents()
  50 {
  51     Events eventSet = noEvents;
  52     for (set<Observer *>::const_iterator it = mObservers.begin(); it != mObservers.end(); it++)
  53         eventSet |= (*it)->getEvents();
  54     Observer::setEvents(eventSet);
  55 }
  56
  57
  58 //
  59 // Fan out an observation
  60 //
  61 void MultiplexObserver::observe(Events events, Transfer *xfer, const void *info)
  62 {
  63     for (set<Observer *>::const_iterator it = mObservers.begin(); it != mObservers.end(); it++)
  64         if ((*it)->wants(events))
  65             (*it)->observe(events, xfer, info);
  66 }
  67
  68
  69 }       // end namespace Network
  70 }       // end namespace Security