| /* |
| * |
| * D-Bus++ - C++ bindings for D-Bus |
| * |
| * Copyright (C) 2005-2007 Paolo Durante <shackan@gmail.com> |
| * |
| * |
| * 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.1 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA |
| * |
| */ |
| |
| |
| #ifndef __DBUSXX_EVENTLOOP_INTEGRATION_H |
| #define __DBUSXX_EVENTLOOP_INTEGRATION_H |
| |
| #include <cstring> |
| #include <errno.h> |
| #include <unistd.h> |
| #include "api.h" |
| #include "dispatcher.h" |
| #include "util.h" |
| #include "eventloop.h" |
| |
| namespace DBus { |
| |
| /* |
| * Glue between the event loop and the DBus library |
| */ |
| |
| class BusDispatcher; |
| |
| class DXXAPI BusTimeout : public Timeout, public DefaultTimeout |
| { |
| BusTimeout(Timeout::Internal *, BusDispatcher *); |
| |
| void toggle(); |
| |
| friend class BusDispatcher; |
| }; |
| |
| class DXXAPI BusWatch : public Watch, public DefaultWatch |
| { |
| BusWatch(Watch::Internal *, BusDispatcher *); |
| |
| void toggle(); |
| |
| friend class BusDispatcher; |
| }; |
| |
| class DXXAPI BusDispatcher : public Dispatcher, public DefaultMainLoop |
| { |
| public: |
| |
| int _pipe[2]; |
| |
| BusDispatcher() : _running(false) |
| { |
| //pipe to create a new fd used to unlock a dispatcher at any |
| // moment (used by leave function) |
| int ret = pipe(_pipe); |
| if (ret == -1) { |
| char buffer[128]; // buffer copied in Error constructor |
| throw Error("PipeError:errno", strerror_r(errno, |
| buffer, |
| sizeof(buffer))); |
| } |
| _fdunlock[0] = _pipe[0]; |
| _fdunlock[1] = _pipe[1]; |
| |
| } |
| |
| ~BusDispatcher() |
| {} |
| |
| virtual void enter(); |
| |
| virtual void leave(); |
| |
| virtual void do_iteration(); |
| |
| virtual Timeout *add_timeout(Timeout::Internal *); |
| |
| virtual void rem_timeout(Timeout *); |
| |
| virtual Watch *add_watch(Watch::Internal *); |
| |
| virtual void rem_watch(Watch *); |
| |
| void watch_ready(DefaultWatch &); |
| |
| void timeout_expired(DefaultTimeout &); |
| |
| private: |
| |
| bool _running; |
| }; |
| |
| } /* namespace DBus */ |
| |
| #endif//__DBUSXX_EVENTLOOP_INTEGRATION_H |