#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include "echo-client.h"
#include <iostream>
#include <pthread.h>
#include <signal.h>
#include <stdio.h>
#include <cstring>

using namespace std;

static const char *ECHO_SERVER_NAME = "org.freedesktop.DBus.Examples.Echo";
static const char *ECHO_SERVER_PATH = "/org/freedesktop/DBus/Examples/Echo";

EchoClient::EchoClient(DBus::Connection &connection, const char *path, const char *name)
: DBus::ObjectProxy(connection, path, name)
{
}

void EchoClient::Echoed(const DBus::Variant &value)
{
	cout << "!";
}

/*
 * For some strange reason, libdbus frequently dies with an OOM
 */

static const size_t THREADS = 3;

static bool spin = true;

EchoClient *g_client = NULL;

DBus::Pipe *thread_pipe_list[THREADS];

DBus::BusDispatcher dispatcher;
DBus::DefaultTimeout *timeout;

void *greeter_thread(void *arg)
{
	char idstr[16];
	size_t i = (size_t) arg;

	snprintf(idstr, sizeof(idstr), "%lu", pthread_self());

	thread_pipe_list[i]->write (idstr, strlen (idstr) + 1);

	cout << idstr << " done (" << i << ")" << endl;

	return NULL;
}

void niam(int sig)
{
	spin = false;

	dispatcher.leave();
}

void handler1 (const void *data, void *buffer, unsigned int nbyte)
{
	char *str = (char*) buffer;
	cout << "buffer1: " << str << ", size: " << nbyte << endl;
	for (int i = 0; i < 30 && spin; ++i)
	{
		cout << "call1: " << g_client->Hello (str) << endl;
	}
}

void handler2 (const void *data, void *buffer, unsigned int nbyte)
{
	char *str = (char*) buffer;
	cout << "buffer2: " << str << ", size: " << nbyte <<endl;
	for (int i = 0; i < 30 && spin; ++i)
	{
		cout << "call2: " << g_client->Hello (str) << endl;
	}
}

void handler3 (const void *data, void *buffer, unsigned int nbyte)
{
	char *str = (char*) buffer;
	cout << "buffer3: " << str << ", size: " << nbyte <<endl;
	for (int i = 0; i < 30 && spin; ++i)
	{
		cout << "call3: " << g_client->Hello (str) << endl;
	}
}

int main()
{
	size_t i;

	signal(SIGTERM, niam);
	signal(SIGINT, niam);

	DBus::_init_threading();

  DBus::default_dispatcher = &dispatcher;

  // increase DBus-C++ frequency
  new DBus::DefaultTimeout(100, false, &dispatcher);

	DBus::Connection conn = DBus::Connection::SessionBus();

	EchoClient client (conn, ECHO_SERVER_PATH, ECHO_SERVER_NAME);
	g_client = &client;

	pthread_t threads[THREADS];

	thread_pipe_list[0] = dispatcher.add_pipe (handler1, NULL);
	thread_pipe_list[1] = dispatcher.add_pipe (handler2, NULL);
	thread_pipe_list[2] = dispatcher.add_pipe (handler3, NULL);
	for (i = 0; i < THREADS; ++i)
	{
		pthread_create(threads+i, NULL, greeter_thread, (void*) i);
	}
	
	dispatcher.enter();

	cout << "terminating" << endl;

	for (i = 0; i < THREADS; ++i)
	{
		pthread_join(threads[i], NULL);
	}

	dispatcher.del_pipe (thread_pipe_list[0]);
	dispatcher.del_pipe (thread_pipe_list[1]);
	dispatcher.del_pipe (thread_pipe_list[2]);

	return 0;
}