diff options
Diffstat (limited to 'examples/echo_ecore/echo-client.cpp')
-rw-r--r-- | examples/echo_ecore/echo-client.cpp | 136 |
1 files changed, 136 insertions, 0 deletions
diff --git a/examples/echo_ecore/echo-client.cpp b/examples/echo_ecore/echo-client.cpp new file mode 100644 index 0000000..f84c093 --- /dev/null +++ b/examples/echo_ecore/echo-client.cpp @@ -0,0 +1,136 @@ +#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; +} |