/usr/include/net6/select.hpp is in libnet6-1.3-dev 1:1.3.14-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 | /* net6 - Library providing IPv4/IPv6 network access
* Copyright (C) 2005, 2006 Armin Burgmeier / 0x539 dev group
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library 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
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free
* Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*/
#ifndef _NET6_SELECT_HPP_
#define _NET6_SELECT_HPP_
#include <map>
#include "non_copyable.hpp"
#include "default_accumulator.hpp"
#include "socket.hpp"
namespace net6
{
/** The selector may be used to wait until something occurs with a socket:
* Either if data comes available for reading, or kernel buffer gets
* available for writing (without blocking), or an error occurs on a
* socket.
*/
class selector
{
public:
typedef sigc::signal<void, const socket&, io_condition> signal_io_type;
// Virtual destructor makes the compiler happy
virtual ~selector() {}
/** @brief Gets all conditions currently set on a socket
*
* The function can be used to retrieve the conditions
* the socket is currently watched for. It will return
* <em>IO_NONE</em> if the socket is not being monitored.
*
* @param sock The socket which conditions should be queried
*/
io_condition get(const socket& sock) const;
/** @brief Sets conditions on a socket
*
* The function can be used to set conditions the socket is
* watched for. The socket will be added and deleted as
* deemed appropriate.
*
* @param sock The socket to watch for conditions to occur
* @param condition A combination of conditions to watch for. If the
* condition contains net6::IO_TIMEOUT, a timeout value must
* be set via the selector::set_timeout function that tells
* the selector when to emit the timeout.
*/
void set(const socket& sock,
io_condition condition);
/** @brief Emits a timeout signal for the given socket after
* <em>timeout</em> milliseconds.
*
* The signal is only emitted when the socket is watched for
* net6::IO_TIMEOUT.
*
* A previous timeout for this socket is automatically cancelled
* through this function. If <em>timeout</em> is 0, no new timeout
* is set. Note that calling set without net6::IO_TIMEOUT also cancels
* the timeout for a socket. The timeout is automatically unset when
* it has elapsed.
*/
void set_timeout(const socket& sock, unsigned long timeout);
/** @brief Returns the remaining milliseconds to elapse until
* the timeout for the given socket is triggered.
*
* The function returns 0 if no timeout is set for the socket.
*/
unsigned long get_timeout(const socket& sock);
/** @brief Selects infinitely until an event occurs on one or more
* selected sockets.
*/
void select();
/** @brief Selects until an event occurs on ore or more
* selectes sockets, or the given timeout exceeds.
*
* @param timeout Timeout in milliseconds. May be 0 to perform
* a quick poll.
*/
void select(unsigned long timeout);
/** @brief Runs in a blocking call until someone calls selector::quit.
*/
void run();
/** @brief Makes the selector return from run().
*
* Does not work from a different thread as the one that called run().
*/
void quit();
protected:
struct selected_type {
io_condition condition;
unsigned long timeout_begin;
unsigned long timeout;
};
typedef std::map<const socket*, selected_type> map_type;
void select_impl(timeval* tv);
map_type sock_map;
bool running;
};
}
#endif // _NET6_SELECT_HPP_
|