GitLab

This results in a much cleaner collectagent.cpp file and main function.
However, further cleanups are necessary and the respective TODOs can be
found in the code.

Fixed a bug in the SimpleMQTTServer that would lead to message corruption when a message is being decoded from multiple read()s.

FilePusher now accepts a topic string at the command line.

get stuck due to the messageThread not yielding and hogging the fdsMtx
lock. This caused long waiting times for new connections to be
accept()ed.

Cross platform issues compiling C++11 code (Mac OS has two C++ standard libraries, only one supports C++11 but Thrift fails to build with it).
Fix: Replace C++11 system_error with Boost system_error.
Some other minor fixes.

Removed mosquitto dependency entirely. Started reworking collectagent main routines and message handling.

the SimpleMQTTServer after receiving an MQTT message.

stream works. Fixed a race condition to the message threads struct pollfd fds
array.

connections and does thread management.

Cassandra Header Fixes are applied only once now.

Some speedups through native Thrift API instead of CQL3. Some more speedups through bigint timestamps instead of Cassandra timestamps.

again.

values into the data store. Also shows the achieved message rate. Still
pretty dirty and naive.

Currently, this is only a proof of concept for using the Thrift API
provided by Cassandra a bit from C++. Let's hope to evolve this into
what we're aiming for, soon.