dbus-cxx-0.7.0.zip_DBUS_DBUS 封装_dbus c++

/*************************************************************************** * Copyright (C) 2007,2008,2009 by Rick L. Vinyard, Jr. * * rvinyard@cs.nmsu.edu * * * * This file is part of the dbus-cxx library. * * * * The dbus-cxx library is free software; you can redistribute it and/or * * modify it under the terms of the GNU General Public License * * version 3 as published by the Free Software Foundation. * * * * The dbus-cxx 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 * * General Public License for more details. * * * * You should have received a copy of the GNU General Public License * * along with this software. If not see <http://www.gnu.org/licenses/>. * ***************************************************************************/ #include "connection.h" #include "utility.h" #include <iostream> #include <sys/time.h> #include <cassert> #include <dbus-cxx/signalmessage.h> namespace DBus { dbus_int32_t Connection::m_weak_pointer_slot = -1; Connection::Connection( DBusConnection* cobj, bool is_private ): m_cobj( cobj ) { if ( m_cobj ) { dbus_connection_ref( m_cobj ); this->initialize(is_private); } } Connection::Connection( BusType type, bool is_private ): m_cobj( NULL ) { Error::pointer error = Error::create(); if ( type != BUS_NONE ) { if ( is_private ) { m_cobj = dbus_bus_get_private(( DBusBusType )type, error->cobj() ); if ( error->is_set() ) throw error; if ( m_cobj == NULL ) throw ErrorFailed::create(); this->initialize(is_private); } else { m_cobj = dbus_bus_get(( DBusBusType )type, error->cobj() ); if ( error->is_set() ) throw error; if ( m_cobj == NULL ) throw ErrorFailed::create(); this->initialize(is_private); } } } Connection::Connection( const Connection& other ) { m_cobj = other.m_cobj; if ( m_cobj ) dbus_connection_ref( m_cobj ); } void conn_wp_deleter( void* v ) { Connection::weak_pointer* wp = static_cast<Connection::weak_pointer*>(v); delete wp; } Connection::pointer Connection::create( DBusConnection* cobj, bool is_private ) { pointer p = pointer( new Connection(cobj, is_private) ); if ( m_weak_pointer_slot == -1 ) throw ErrorNotInitialized::create(); if ( p and p->is_valid() ) { dbus_bool_t result; weak_pointer* wp = new weak_pointer; *wp = p; result = dbus_connection_set_data( p->cobj(), m_weak_pointer_slot, wp, conn_wp_deleter ); if ( not result ) throw -1; // TODO throw something better } return p; } Connection::pointer Connection::create( BusType type, bool is_private ) { pointer p = pointer( new Connection(type, is_private) ); if ( m_weak_pointer_slot == -1 ) throw ErrorNotInitialized::create(); if ( p and p->is_valid() ) { dbus_bool_t result; weak_pointer* wp = new weak_pointer; *wp = p; result = dbus_connection_set_data( p->cobj(), m_weak_pointer_slot, wp, conn_wp_deleter ); if ( not result ) throw -1; // TODO throw something better } return p; } Connection::pointer Connection::create( const Connection& other ) { pointer p = pointer( new Connection(other) ); if ( m_weak_pointer_slot == -1 ) throw ErrorNotInitialized::create(); if ( p and p->is_valid() ) { dbus_bool_t result; weak_pointer* wp = new weak_pointer; *wp = p; result = dbus_connection_set_data( p->cobj(), m_weak_pointer_slot, wp, conn_wp_deleter ); if ( not result ) throw -1; // TODO throw something better } return p; } Connection::~Connection() { if ( this->is_valid() and this->is_private() ) dbus_connection_close( m_cobj ); if ( m_cobj ) dbus_connection_unref( m_cobj ); } Connection::pointer Connection::self() { if ( not this->is_valid() or m_weak_pointer_slot == -1 ) return pointer(); void* v = dbus_connection_get_data(this->cobj(), m_weak_pointer_slot); if ( v == NULL ) return pointer(); weak_pointer* wp = static_cast<weak_pointer*>(v); pointer p = wp->lock(); return p; } Connection::pointer Connection::self(DBusConnection * c) { if ( c == NULL or m_weak_pointer_slot == -1 ) return Connection::pointer(); void* v = dbus_connection_get_data(c, m_weak_pointer_slot); if ( v == NULL ) return Connection::pointer(); Connection::weak_pointer* wp = static_cast<Connection::weak_pointer*>(v); Connection::pointer p = wp->lock(); return p; } DBusConnection* Connection::cobj() { return m_cobj; } Connection::operator bool() const { return m_cobj; } bool Connection::is_valid() const { return m_cobj; } bool Connection::is_private() const { return m_private_flag; } bool Connection::bus_register() { dbus_bool_t result; Error::pointer error = Error::create(); if ( not this->is_valid() ) return false; result = dbus_bus_register( m_cobj, error->cobj() ); if ( error->is_set() ) throw error; return result; } bool Connection::is_registered() const { return this->unique_name() != NULL; } const char * Connection::unique_name() const { if ( not this->is_valid() ) return NULL; return dbus_bus_get_unique_name(m_cobj); } unsigned long Connection::unix_user( const std::string & name ) const { Error::pointer error = Error::create(); if ( not this->is_valid() ) return -1; return dbus_bus_get_unix_user( m_cobj, name.c_str(), error->cobj() ); } const char* Connection::bus_id() const { Error::pointer error = Error::create(); if ( not this->is_valid() ) return NULL; return dbus_bus_get_id( m_cobj, error->cobj() ); } int Connection::request_name( const std::string& name, unsigned int flags ) { int result; Error::pointer error = Error::create(); if ( not this->is_valid() ) return -1; result = dbus_bus_request_name( m_cobj, name.c_str(), flags, error->cobj() ); if ( error->is_set() ) throw error; return result; } int Connection::release_name( const std::string& name ) { int result; Error::pointer error = Error::create(); if ( not this->is_valid() ) return -1; result = dbus_bus_release_name( m_cobj, name.c_str(), error->cobj() ); if ( error->is_set() ) throw error; return result; } bool Connection::name_has_owner( const std::string& name ) const { dbus_bool_t result; Error::pointer error = Error::create(); if ( not this->is_valid() ) return false; result = dbus_bus_name_has_owner( m_cobj, name.c_str(), error->cobj() ); if ( error->is_set() ) throw error; return result; } StartReply Connection::start_service( const std::string& name, uint32_t flags ) const { dbus_bool_t succeeded; dbus_uint32_t result_code; Error::pointer error = Error::create(); if ( not this->is_valid() ) return START_REPLY_FAILED; succeeded = dbus_bus_start_service_by_name( m_cobj, name.c_str(), flags, &result_code, error->cobj() ); if ( error->is_set() ) throw error; if ( succeeded ) switch ( result_code ) { case DBUS_START_REPLY_SUCCESS: return START_REPLY_SUCCESS; case DBUS_START_REPLY_ALREADY_RUNNING: return START_REPLY_ALREADY_RUNNING;