00001 /* ==================================================================== 00002 * The Kannel Software License, Version 1.0 00003 * 00004 * Copyright (c) 2001-2008 Kannel Group 00005 * Copyright (c) 1998-2001 WapIT Ltd. 00006 * All rights reserved. 00007 * 00008 * Redistribution and use in source and binary forms, with or without 00009 * modification, are permitted provided that the following conditions 00010 * are met: 00011 * 00012 * 1. Redistributions of source code must retain the above copyright 00013 * notice, this list of conditions and the following disclaimer. 00014 * 00015 * 2. Redistributions in binary form must reproduce the above copyright 00016 * notice, this list of conditions and the following disclaimer in 00017 * the documentation and/or other materials provided with the 00018 * distribution. 00019 * 00020 * 3. The end-user documentation included with the redistribution, 00021 * if any, must include the following acknowledgment: 00022 * "This product includes software developed by the 00023 * Kannel Group (http://www.kannel.org/)." 00024 * Alternately, this acknowledgment may appear in the software itself, 00025 * if and wherever such third-party acknowledgments normally appear. 00026 * 00027 * 4. The names "Kannel" and "Kannel Group" must not be used to 00028 * endorse or promote products derived from this software without 00029 * prior written permission. For written permission, please 00030 * contact org@kannel.org. 00031 * 00032 * 5. Products derived from this software may not be called "Kannel", 00033 * nor may "Kannel" appear in their name, without prior written 00034 * permission of the Kannel Group. 00035 * 00036 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED 00037 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 00038 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 00039 * DISCLAIMED. IN NO EVENT SHALL THE KANNEL GROUP OR ITS CONTRIBUTORS 00040 * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, 00041 * OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT 00042 * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR 00043 * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 00044 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE 00045 * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, 00046 * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 00047 * ==================================================================== 00048 * 00049 * This software consists of voluntary contributions made by many 00050 * individuals on behalf of the Kannel Group. For more information on 00051 * the Kannel Group, please see <http://www.kannel.org/>. 00052 * 00053 * Portions of this software are based upon software originally written at 00054 * WapIT Ltd., Helsinki, Finland for the Kannel project. 00055 */ 00056 00057 /* 00058 * fdset.h - module for managing a large collection of file descriptors 00059 */ 00060 00061 typedef struct FDSet FDSet; 00062 00063 /* 00064 * A function of this type will be called to indicate that a file descriptor 00065 * has shown activity. The revents parameter is in the same format as 00066 * returned by poll(). The data pointer was supplied by the caller who 00067 * registered the fd with us in the first place. 00068 * NOTE: Beware of concurrency issues. The callback function will run 00069 * in the fdset's private thread, not in the caller's thread. 00070 * This also means that if the callback does a lot of work it will slow 00071 * down the polling process. This may be good or bad. 00072 */ 00073 typedef void fdset_callback_t(int fd, int revents, void *data); 00074 00075 /* 00076 * Create a new, empty file descriptor set and start its thread. 00077 * @timeout - idle timeout for any filedescriptor in this fdset after which 00078 * callback function will be called with POLLERR as event. 00079 */ 00080 #define fdset_create() fdset_create_real(-1) 00081 FDSet *fdset_create_real(long timeout); 00082 00083 /* 00084 * Destroy a file descriptor set. Will emit a warning if any file 00085 * descriptors are still registered with it. 00086 */ 00087 void fdset_destroy(FDSet *set); 00088 00089 /* 00090 * Register a file descriptor with this set, and listen for the specified 00091 * events (see fdset_listen() for details on that). Record the callback 00092 * function which will be used to notify the caller about events. 00093 */ 00094 void fdset_register(FDSet *set, int fd, int events, 00095 fdset_callback_t callback, void *data); 00096 00097 /* 00098 * Change the set of events to listen for for this file descriptor. 00099 * Events is in the same format as the events field in poll() -- in 00100 * practice, use POLLIN for "input available", POLLOUT for "ready to 00101 * accept more output", and POLLIN|POLLOUT for both. 00102 * 00103 * The mask field indicates which event flags can be affected. For 00104 * example, if events is POLLIN and mask is POLLIN, then the POLLOUT 00105 * setting will not be changed by this. If mask were POLLIN|POLLOUT, 00106 * then the POLLOUT setting would be turned off. 00107 * 00108 * The fd must first have been registered. Locks are used to 00109 * guarantee that the callback function will not be called for 00110 * the old events after this function returns. 00111 */ 00112 void fdset_listen(FDSet *set, int fd, int mask, int events); 00113 00114 /* 00115 * Forget about this fd. Locks are used to guarantee that the callback 00116 * function will not be called for this fd after this function returns. 00117 */ 00118 void fdset_unregister(FDSet *set, int fd); 00119 00123 void fdset_set_timeout(FDSet *set, long timeout);