File indexing completed on 2024-05-05 17:50:04

0001 /*
0002    Copyright (C) 2015 Andreas Hartmetz <ahartmetz@gmail.com>
0003 
0004    This library is free software; you can redistribute it and/or
0005    modify it under the terms of the GNU Library General Public
0006    License as published by the Free Software Foundation; either
0007    version 2 of the License, or (at your option) any later version.
0008 
0009    This library is distributed in the hope that it will be useful,
0010    but WITHOUT ANY WARRANTY; without even the implied warranty of
0011    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
0012    Library General Public License for more details.
0013 
0014    You should have received a copy of the GNU Library General Public License
0015    along with this library; see the file COPYING.LGPL.  If not, write to
0016    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
0017    Boston, MA 02110-1301, USA.
0018 
0019    Alternatively, this file is available under the Mozilla Public License
0020    Version 1.1.  You may obtain a copy of the License at
0021    http://www.mozilla.org/MPL/
0022 */
0023 
0024 #ifndef SELECTEVENTPOLLER_H
0025 #define SELECTEVENTPOLLER_H
0026 
0027 #include "ieventpoller.h"
0028 
0029 #include <unordered_map>
0030 
0031 #include <sys/select.h>
0032 
0033 class SelectEventPoller : public IEventPoller
0034 {
0035 public:
0036     SelectEventPoller(EventDispatcher *dispatcher);
0037     ~SelectEventPoller();
0038     IEventPoller::InterruptAction poll(int timeout) override;
0039     void interrupt(IEventPoller::InterruptAction) override;
0040 
0041     // reimplemented from IEventPoller
0042     void addFileDescriptor(FileDescriptor fd, uint32 ioRw) override;
0043     void removeFileDescriptor(FileDescriptor fd) override;
0044     void setReadWriteInterest(FileDescriptor fd, uint32 ioRw) override;
0045 
0046 private:
0047     void notifyRead(int fd);
0048     void resetFdSets();
0049 
0050     std::unordered_map<FileDescriptor, uint32 /*ioRw*/> m_fds;
0051 
0052     fd_set m_readSet;
0053     fd_set m_writeSet;
0054 
0055     int m_interruptPipe[2];
0056 };
0057 
0058 #endif // SELECTEVENTPOLLER_H