utility.h

Go to the documentation of this file.

// SPDX-License-Identifier: LGPL-3.0-or-later OR BSD-3-Clause
/***************************************************************************
 *   Copyright (C) 2007,2008,2009,2010 by Rick L. Vinyard, Jr.             *
 *   rvinyard@cs.nmsu.edu                                                  *
 *                                                                         *
 *   This file is part of the dbus-cxx library.                            *
 ***************************************************************************/
#include <dbus-cxx/callmessage.h>
#include <dbus-cxx/returnmessage.h>
#include <dbus-cxx/demangle.h>
#include <dbus-cxx/messageiterator.h>
#include <dbus-cxx/signature.h>
#include <dbus-cxx/simplelogger_defs.h>
#include <functional>
#include <memory>
#include <sstream>
#include <string>
#include <tuple>
#include <typeinfo>
#include <vector>
#include <sigc++/sigc++.h>
#include <chrono>
#include <dbus-cxx/demangle.h>
#include <dbus-cxx/multiplereturn.h>
 
#ifndef DBUSCXX_UTILITY_H
#define DBUSCXX_UTILITY_H
 
#define DBUS_CXX_INTROSPECTABLE_INTERFACE "org.freedesktop.DBus.Introspectable"
#define DBUS_CXX_PEER_INTERFACE     "org.freedesktop.DBus.Peer"
#define DBUS_CXX_PROPERTIES_INTERFACE   "org.freedesktop.DBus.Properties"
#define DBUS_CXX_PROPERTY_EMITS_CHANGE_SIGNAL_ANNOTATION "org.freedesktop.DBus.Property.EmitsChangedSignal"
 
#define DBUS_CXX_ITERATOR_SUPPORT( CppType, DBusType )                                                \
    inline                                                                                              \
    DBus::MessageIterator& operator>>(DBus::MessageIterator& __msgiter, CppType& __cpptype)             \
    {                                                                                                   \
        DBusType __dbustype;                                                                              \
        __msgiter >> __dbustype;                                                                          \
        __cpptype = static_cast< CppType >( __dbustype );                                                 \
        return __msgiter;                                                                                 \
    }                                                                                                   \
    \
    inline                                                                                              \
    DBus::MessageAppendIterator& operator<<(DBus::MessageAppendIterator& __msgiter, CppType& __cpptype) \
    {                                                                                                   \
        __msgiter << static_cast< DBusType >( __cpptype );                                                \
        return __msgiter;                                                                                 \
    }                                                                                                   \
    \
    namespace DBus {                                                                                    \
    inline std::string signature( CppType ) { DBusType d; return signature( d ); }          \
    }
 
 
namespace DBus {
 
void set_logging_function( ::simplelogger_log_function function );
 
void log_std_err( const char* logger_name, const struct ::SL_LogLocation* location,
    const enum ::SL_LogLevel level,
    const char* log_string );
 
void set_log_level( const enum ::SL_LogLevel level );
 
void hexdump( const std::vector<uint8_t>* vec, std::ostream* stream );
 
void hexdump( const uint8_t* vec, const uint32_t len, std::ostream* stream );
 
void set_default_endianess(DBus::Endianess endianess);
 
DBus::Endianess default_endianess();
 
namespace priv {
/*
 * method_signature class - like dbus_signature, but outputs the args of the signature
 * in a C++-like manner
 */
template<typename... argn>
class method_signature;
 
template<> class method_signature<> {
public:
    std::string method_sig() const {
        return "";
    }
 
    std::string introspect( const std::vector<std::string>&, int, const std::string& ) const {
        return "";
    }
};
 
template<typename arg1, typename... argn>
class method_signature<arg1, argn...> : public method_signature<argn...> {
public:
    std::string method_sig() const {
        std::string arg1_name = demangle<arg1>();
        std::string remaining_args = method_signature<argn...>::method_sig();
 
        if( remaining_args.size() > 1 ) {
            arg1_name += ",";
        }
 
        return arg1_name + remaining_args;
    }
 
    std::string introspect( const std::vector<std::string>& names, int idx, const std::string& spaces ) const {
        arg1 arg;
        std::ostringstream output;
        std::string name = names.size() > idx ? names[idx] : "";
        output << spaces;
        output << "<arg ";
 
        if( name.size() > 0 ) { output << "name=\"" << name << "\" "; }
 
        output << "type=\"" << signature( arg ) << "\" ";
        output << "direction=\"in\"/>\n";
        output << method_signature<argn...>().introspect( names, idx + 1, spaces );
        return output.str();
    }
};
 
template<typename... argn>
class multireturn_signature;
 
template<> class multireturn_signature<> {
public:
    std::string multireturn_sig() const {
        return "";
    }
 
    std::string introspect( const std::vector<std::string>&, int, const std::string& ) const {
        return "";
    }
};
 
template<typename arg1, typename... argn>
class multireturn_signature<arg1, argn...> : public multireturn_signature<argn...> {
public:
    std::string multireturn_sig() const {
        std::string arg1_name = demangle<arg1>();
        std::string remaining_args = multireturn_signature<argn...>::multireturn_sig();
 
        if( remaining_args.size() > 1 ) {
            arg1_name += ",";
        }
 
        return arg1_name + remaining_args;
    }
 
    std::string introspect( const std::vector<std::string>& names, int& idx, const std::string& spaces ) const {
        arg1 arg;
        std::ostringstream output;
        std::string name = names.size() > idx ? names[idx] : "";
        output << spaces;
        output << "<arg ";
 
        if( name.size() > 0 ) { output << "name=\"" << name << "\" "; }
 
        output << "type=\"" << signature( arg ) << "\" ";
        output << "direction=\"out\"/>\n";
        idx++;
        output << multireturn_signature<argn...>().introspect( names, idx, spaces );
        return output.str();
    }
};
 
 
/*
 * dbus_function_traits - given a function, get information about it needed for dbus operations.
 */
template<typename T>
struct dbus_function_traits;
 
template<typename ...Args>
struct dbus_function_traits<std::function<void( Args... )>> {
    std::string dbus_sig() const {
        return dbus_signature<Args...>().dbus_sig();
    }
 
    std::string debug_string() const {
        return "void (" + method_signature<Args...>().method_sig() + ")";
    }
 
    std::string introspect( const std::vector<std::string>& names, int idx, const std::string& spaces ) const {
        std::ostringstream sout;
        sout << method_signature<Args...>().introspect( names, idx + 1, spaces );
        return sout.str();
    }
 
    void extractAndCall( std::shared_ptr<const CallMessage> callmsg, std::shared_ptr<ReturnMessage>, sigc::slot<void( Args... )> slot ) {
        MessageIterator i = callmsg->begin();
        std::tuple<Args...> tup_args;
        std::apply( [i]( auto&& ...arg ) mutable {
            ( void )( i >> ... >> arg );
        },
        tup_args );
 
        std::apply( slot, tup_args );
    }
};
 
template<typename T_ret, typename ...Args>
struct dbus_function_traits<std::function<T_ret( Args... )>> {
    std::string dbus_sig() const {
        return dbus_signature<Args...>().dbus_sig();
    }
 
    std::string debug_string() const {
        std::ostringstream ret;
        ret << demangle<T_ret>();
        ret << "(";
        ret << method_signature<Args...>().method_sig();
        ret << ")";
        return ret.str();
    }
 
    std::string introspect( const std::vector<std::string>& names, int idx, const std::string& spaces ) const {
        std::ostringstream sout;
        T_ret ret_type;
        std::string name = "";
 
        if( names.size() > 0 ) {
            name = names[0];
        }
 
        sout << spaces << "<arg ";
 
        if( name.size() > 0 ) { sout << "name=\"" << name << "\" "; }
 
        sout << "type=\"" << signature( ret_type ) << "\" "
            << "direction=\"out\"/>\n";
        sout << method_signature<Args...>().introspect( names, idx + 1, spaces );
        return sout.str();
    }
 
    /*
      std::tuple<Args...> extract(Message::iterator i){
        std::tuple<Args...> tup_args;
        std::apply( [i](auto ...arg){
                   (i >> ... >> arg);
                  },
        tup_args );
        return tup_args;
      }
    */
    void extractAndCall( std::shared_ptr<const CallMessage> callmsg, std::shared_ptr<ReturnMessage> retmsg, sigc::slot<T_ret( Args... )> slot ) {
        MessageIterator i = callmsg->begin();
        std::tuple<Args...> tup_args;
        std::apply( [i]( auto&& ...arg ) mutable {
            ( void )( i >> ... >> arg );
        },
        tup_args );
        T_ret retval;
 
        retval = std::apply( slot, tup_args );
        retmsg << retval;
    }
};
 
 
template<typename... T_ret,typename ...Args>
struct dbus_function_traits<std::function<DBus::MultipleReturn<T_ret...>( Args... )>> {
    std::string dbus_sig() const {
        return dbus_signature<Args...>().dbus_sig();
    }
 
    std::string debug_string() const {
        std::ostringstream ret;
        ret << "DBus::MultipleReturn<" << multireturn_signature<T_ret...>().multireturn_sig() << ">";
        ret << "(";
        ret << method_signature<Args...>().method_sig();
        ret << ")";
        return ret.str();
    }
 
    std::string introspect( const std::vector<std::string>& names, int idx, const std::string& spaces ) const {
        std::ostringstream sout;
        sout << multireturn_signature<T_ret...>().introspect( names, idx, spaces );
        sout << method_signature<Args...>().introspect( names, idx + 1, spaces );
        return sout.str();
    }
 
    void extractAndCall( std::shared_ptr<const CallMessage> callmsg, std::shared_ptr<ReturnMessage> retmsg, sigc::slot<DBus::MultipleReturn<T_ret...>( Args... )> slot ) {
        MessageIterator i = callmsg->begin();
        std::tuple<Args...> tup_args;
        std::apply( [i]( auto&& ...arg ) mutable {
          ( void )( i >> ... >> arg );
        },
        tup_args );
        DBus::MultipleReturn<T_ret...> retval;
 
        retval = std::apply( slot, tup_args );
        retmsg << retval;
    }
};
 
std::tuple<bool, int, std::vector<int>, std::chrono::milliseconds> wait_for_fd_activity( std::vector<int> fds, int timeout_ms );
 
} /* namespace priv */
 
} /* namespace DBus */
 
#endif