include/DbusConnection.h

Go to the documentation of this file.

#define DBUSCONNECTION_H 1

#ifndef _GLIBCXX_VECTOR
#include <vector>
#endif

#ifndef _GLIBCXX_STRING
#include <string>
#endif

#ifndef _GLIBCXX_IOSTREAM
#include <iostream>
#endif

#ifndef _GLIBCXX_SSTREAM
#include <sstream>
#endif

#ifndef _GLIBCXX_QUEUE
#include <queue>
#endif

#ifndef DBUS_GLIB_H
#include <dbus/dbus-glib.h>
#endif

#ifndef COMM_H
#include "Comm.h"
#endif

#ifndef GLOBALS_H
#include "Globals.h"
#endif

#ifndef BOOST_SHARED_PTR_HPP_INCLUDED
#include <boost/shared_ptr.hpp>
#endif

using namespace boost;
using namespace std;

//forward declarations:
class MessageController;
struct SomeObject
{
  GObject parent;
  MessageController *mc;
};

struct SomeObjectClass
{
  GObjectClass parent;
};

typedef struct SomeObject SomeObject;
typedef struct SomeObjectClass SomeObjectClass;

#define SOME_TYPE_OBJECT              (some_object_get_type ())
#define SOME_OBJECT(object)           (G_TYPE_CHECK_INSTANCE_CAST ((object), SOME_TYPE_OBJECT, SomeObject))
#define SOME_OBJECT_CLASS(klass)      (G_TYPE_CHECK_CLASS_CAST ((klass), SOME_TYPE_OBJECT, SomeObjectClass))
#define SOME_IS_OBJECT(object)        (G_TYPE_CHECK_INSTANCE_TYPE ((object), SOME_TYPE_OBJECT))
#define SOME_IS_OBJECT_CLASS(klass)   (G_TYPE_CHECK_CLASS_TYPE ((klass), SOME_TYPE_OBJECT))
#define SOME_OBJECT_GET_CLASS(obj)    (G_TYPE_INSTANCE_GET_CLASS ((obj), SOME_TYPE_OBJECT, SomeObjectClass))



class DbusConnection:public Comm {
        shared_ptr< queue< shared_ptr< vector< shared_ptr< string > > > > > outqueue;   //      Outgoing queue.
        pthread_mutex_t mutex;
        pthread_cond_t cond;

        pthread_t sendthread;
        pthread_t receivethread;
        bool sendthread_run;

        string thisapp;
        string thatapp;

        //      Dbus
        GMainLoop *mainloop;
        DBusGProxy *remote_object;

        void dbus_init();

        MessageController* msgcontroller;

        public:
        DbusConnection( string nthisapp , string nthatapp , MessageController *ptr );
        ~DbusConnection();
        bool sendMessage ( shared_ptr< vector< shared_ptr< string > > > messagebody );

        friend void* sendThread( void * );
        friend void* receiveThread( void * );
        friend gboolean _send_message( SomeObject* , char** , GError** );
};

---