+++ /dev/null
-/*
- * Copyright (c) 2000-2001 Apple Computer, Inc. All Rights Reserved.
- *
- * The contents of this file constitute Original Code as defined in and are
- * subject to the Apple Public Source License Version 1.2 (the 'License').
- * You may not use this file except in compliance with the License. Please obtain
- * a copy of the License at http://www.apple.com/publicsource and read it before
- * using this file.
- *
- * This Original Code and all software distributed under the License are
- * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESS
- * OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, INCLUDING WITHOUT
- * LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
- * PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. Please see the License for the
- * specific language governing rights and limitations under the License.
- */
-
-
-//
-// selector - I/O stream multiplexing
-//
-#ifndef _H_SELECTOR
-#define _H_SELECTOR
-
-#include <Security/utilities.h>
-#include <Security/fdsel.h>
-#include "timeflow.h"
-#include <sys/types.h>
-#include <cstdio>
-#include <cstdarg>
-#include <map>
-#include <Security/debugging.h>
-
-
-namespace Security {
-namespace UnixPlusPlus {
-
-
-//
-// A Selector is an I/O dispatch facility that can supervise any number of "file descriptors",
-// each of which can perform I/O. Obviously this is geared towards the UNIX facility.
-//
-class Selector {
-public:
- class Client; friend class Client;
-
- Selector();
- virtual ~Selector();
-
- //@@@ preliminary interface
- void operator () (); // run just once (now)
- void operator () (Time::Absolute stopTime);
- void operator () (Time::Interval duration)
- { (*this)(Time::now() + duration); }
-
- typedef unsigned int Type;
- static const Type none = 0x00;
- static const Type input = 0x01;
- static const Type output = 0x02;
- static const Type critical = 0x04;
- static const Type all = input | output | critical;
-
-public:
- class Client {
- public:
- typedef Selector::Type Type;
- friend class Selector;
-
- Client() : mSelector(NULL) { }
- virtual void notify(int fd, Type type) = 0;
- virtual ~Client() { }
-
- bool isActive() const { return mSelector != NULL; }
-
- static const Type input = Selector::input;
- static const Type output = Selector::output;
- static const Type critical = Selector::critical;
-
- protected:
- void events(Type type) { mSelector->set(mFd, type); mEvents = type; }
- Type events() const { return mEvents; }
-
- void enable(Type type) { events(events() | type); }
- void disable(Type type) { events(events() & ~type); }
-
- template <class Sel> Sel &selectorAs()
- { assert(mSelector); return safer_cast<Sel &>(*mSelector); }
-
- private:
- int mFd;
- Selector *mSelector;
- Type mEvents;
- };
-
- void add(int fd, Client &client, Type type = all);
- void remove(int fd);
- bool isEmpty() const { return clientMap.empty(); }
-
-private:
- void set(int fd, Type type); // (re)set mask for one client
-
- void singleStep(Time::Interval maxWait);
-
-private:
- unsigned int fdSetSize; // number of fd_masks allocated in FDSets
- int fdMin, fdMax; // highest/lowest fds in use
- FDSet inSet, outSet, errSet; // current in/out/error select masks
-
-private:
- typedef map<int, Client *> ClientMap;
- ClientMap clientMap;
-};
-
-
-} // end namespace UnixPlusPlus
-} // end namespace Security
-
-
-#endif //_H_SELECTOR