Commit Graph

  • bed58891ea merge MQ parameters in the variable_map container of FairMQProgramOptions class winckler 2016-08-04 17:53:58 +0200
  • 2ed0c52ae8 Test nanomsg transport only when nanomsg library is found. Alexey Rybalchenko 2016-08-04 13:33:52 +0200
  • 13a5cea1d7 fix parallel running tests failure Alexey Rybalchenko 2016-07-11 10:58:30 +0200
  • 64f1fd2a3b - add test for serialization examples 1&2 - rename serialization files and scripts - remove policy and host header files from fairmq installation winckler 2016-06-30 16:46:25 +0200
  • c57bbf58fa - Remove GenericSampler, GenericProcessor, and CRTP policy base classes - Rename GenericFileSink to BaseMQFileSink, and move it to base/MQ/hosts directory - Rename and clean files in the serialization examples winckler 2016-06-28 15:45:33 +0200
  • 75aad5676d Use Boost_ variables instead of hardcoded names. Florian Uhlig 2016-06-08 15:38:14 +0200
  • 92944fe322 Correct shell scripts to work correctly with dash. Florian Uhlig 2016-05-30 17:10:54 +0200
  • f3bebe9321 Use different ports in tests to prevent parallel run fail Alexey Rybalchenko 2016-06-01 11:49:33 +0200
  • 7062a3d280 Run FairMQ tests with both ZeroMQ and nanomsg Alexey Rybalchenko 2016-05-31 10:19:32 +0200
  • eb306a2c0d Remove color output from tests Alexey Rybalchenko 2016-05-30 12:36:55 +0200
  • fd09321fd9 Modified runDDSCommandUI to accept command line argument. If no arguments, it behaves like before. Removed runDDSCommand and replaced calls to it in controlDDS. Radoslaw Karabowicz 2016-05-30 11:25:47 +0200
  • 65ca151620 MQ/example9 Adapted to the new running scheme with DDS. Radoslaw Karabowicz 2016-05-27 14:28:10 +0200
  • 253604344f nanomsg: reset maximum receive msg size Alexey Rybalchenko 2016-05-27 10:14:15 +0200
  • cc88339791 Cleanup command line options Alexey Rybalchenko 2016-05-23 14:55:42 +0200
  • 4944d7ec41 Meaningful error on wrong channel name Alexey Rybalchenko 2016-05-20 12:54:10 +0200
  • a05dc80402 Refactor DDS example and tools to be able to run with/without DDS Alexey Rybalchenko 2016-05-19 10:22:02 +0200
  • af971c6ab1 Allow rate limiting in the Shared Memory example Alexey Rybalchenko 2016-05-18 16:00:26 +0200
  • 1f09317cd0 Handle both single and multi part payloads in splitter/merger/proxy Alexey Rybalchenko 2016-05-17 10:34:55 +0200
  • e9f09143b2 Gracefully end the device also in the termination case (instead of abort). Alexey Rybalchenko 2016-05-17 08:55:42 +0200
  • ce42f36126 Remove redundant state change call and revert the termination handler. Alexey Rybalchenko 2016-05-12 15:21:12 +0200
  • 28aa5e4caa Let ParseAll exit if unsuccessfull Alexey Rybalchenko 2016-05-12 11:35:24 +0200
  • 31456e71ff Threads safe socket rate stats Alexey Rybalchenko 2016-05-12 09:13:57 +0200
  • 3353e214a7 Add shared memory example Alexey Rybalchenko 2016-04-07 17:02:37 +0200
  • 599d1b3e05 MQ/example9 Added testing of the static MQ execution. Radoslaw Karabowicz 2016-05-06 14:46:17 +0200
  • 58754e03c7 Make sure logger is used before configuring it. Alexey Rybalchenko 2016-04-28 09:51:02 +0200
  • e039931098 Fix the logger conflict issue Alexey Rybalchenko 2016-04-27 17:00:27 +0200
  • 5421922668 Add a cmd option to control state change mechanism Alexey Rybalchenko 2016-04-27 15:04:29 +0200
  • b9883d3b13 Configuration and DDS example/tools updates Alexey Rybalchenko 2016-03-31 14:41:05 +0200
  • 151d3b5de8 Fix dereference before null check in example and formatting Alexey Rybalchenko 2016-04-14 13:23:09 +0200
  • a892a5a744 Update FairMQParts with doxygen comments and non-blocking send Alexey Rybalchenko 2016-04-04 09:43:48 +0200
  • 82090c356c Fix identity setting for req/rep socket Alexey Rybalchenko 2016-04-07 15:13:51 +0200
  • e977dfb609 update generic sampler with new serialization api winckler 2016-04-06 12:05:50 +0200
  • 3b985cd2cd encapsulate and use fairmq default xml and json parser if command line mq-config file.extension is called. The .xml and .json files are recognized internally. Remove explicit json parsing in runSimpleMQStateMAchine.h. Propagate the new commandline mq-config where the runstatemachine function is used winckler 2016-04-05 17:52:10 +0200
  • 8df656a302 enable object array parsing in JSON parser for devices, channels, and sockets. device, channel, and socket are parsed as before winckler 2016-04-04 11:45:28 +0200
  • 819a21f46a remove obsolete documentation winckler 2016-03-28 23:14:31 +0200
  • e215049db9 remove alternative serialization API winckler 2016-03-28 22:55:43 +0200
  • 835c88c6d2 change serialization API so that it takes a FairMQMessage reference winckler 2016-03-28 19:13:49 +0200
  • 4c50409af5 add serialization API winckler 2016-03-24 15:59:33 +0100
  • 9a340fb7f6 Use Variables for Boost libraries instead of explicit names Use the vairables filled by FindBoost instead explicit names in the cmake files Mohammad Al-Turany 2016-03-29 15:31:29 +0200
  • 732373faa2 Update multi-part features (nanomsg) and various fixes Alexey Rybalchenko 2016-03-21 09:59:00 +0100
  • 4ca66e33da Fix compiler warnings. Florian Uhlig 2016-03-17 13:19:49 +0100
  • fa7040fe65 Fix compiler warnings. Florian Uhlig 2016-03-09 15:52:10 +0100
  • bb36147099 Allocate dynamic size flatbuffers structure on the heap Alexey Rybalchenko 2016-03-10 11:48:12 +0100
  • 1ad58653e7 Fix return value of multipart send/receive methods Alexey Rybalchenko 2016-03-03 15:35:39 +0100
  • c564a3f066 Merge branch 'fix-uint' of https://github.com/rbx/FairRoot into rbx-fix-uint Mohammad Al-Turany 2016-03-03 15:35:36 +0100
  • 10f997f680 Fix return value of multipart send/receive methods Alexey Rybalchenko 2016-03-03 15:35:39 +0100
  • c42b6ca4ae Include device ID in the zeromq socket identity. Alexey Rybalchenko 2016-03-03 11:23:47 +0100
  • e1fef82657 FairMQ: Extend Multipart and messaging API Alexey Rybalchenko 2016-02-23 18:00:35 +0100
  • 82ab7670a9 Add FlatBuffers & MessagePack examples Alexey Rybalchenko 2015-12-04 15:18:46 +0100
  • f1abb9ecdd Remove compile time transport interface switch Alexey Rybalchenko 2016-01-13 17:21:24 +0100
  • 0e1a1ad552 Allow to limit number of messages for the Benchmark sampler and sink Alexey Rybalchenko 2016-01-07 17:37:43 +0100
  • c10a6abeef Fix memory leaks in Tutorial3 Alexey Rybalchenko 2016-01-07 13:39:17 +0100
  • e4fed2fa1b Fix copy constructor & assignment operator warning in FairMQChannel Alexey Rybalchenko 2016-01-06 13:52:24 +0100
  • 9a0a8c7516 Add a acknowledgement channel to Tutorial 3... Alexey Rybalchenko 2015-12-02 16:24:47 +0100
  • d254efb91f Fix compiler warnings. Mostly unused parameters have been removed. Florian Uhlig 2015-12-15 21:56:41 +0100
  • 2060f0b1d7 FairMQLogger : remove pragma command and use CMake include SYSTEM command instead NicolasWinckler 2015-11-24 12:06:07 +0100
  • 2afa0652f4 Extend DDS Example to use command interface Alexey Rybalchenko 2015-11-23 11:28:15 +0100
  • 35c64c67a2 add a command line to enable/disable the color format in the fairmq log console output NicolasWinckler 2015-11-20 15:25:34 +0100
  • 10d6482716 remove unfinished doc NicolasWinckler 2015-11-19 16:51:49 +0100
  • 8f32579984 add a pointer data type serializer function in the boost serializer add the zmq and nanomsg directories in cmaklists that use the runSimpleMQStateMachine NicolasWinckler 2015-11-19 16:49:03 +0100
  • afda64a83d Simplify the handling of send/receive timeouts Alexey Rybalchenko 2015-11-19 15:30:37 +0100
  • 0894900f52 Add missing link dependencies. Florian Uhlig 2015-11-19 15:51:44 +0100
  • 89d57db5ea - create 3 test scripts for bin, boost, and root serialization format NicolasWinckler 2015-11-11 12:23:41 +0100
  • 76626b4f4b add test dir to examples/MQ/GenericDevices + change policy typedef in generic device from private to protected NicolasWinckler 2015-11-11 12:04:54 +0100
  • 1467360f75 access channel map with at NicolasWinckler 2015-11-11 09:41:04 +0100
  • 383a220333 Update device configuration Alexey Rybalchenko 2015-11-11 11:06:11 +0100
  • 837490cc38 add FairProgOptionsHelper.h in header list to be installed of fairmq/CMakeLists.txt NicolasWinckler 2015-11-09 13:08:02 +0100
  • 819a8df952 add function helpers for FairProgOptions which simplify FairProgOptions.cxx NicolasWinckler 2015-11-09 12:18:34 +0100
  • 13d3729fec enable/disable multipart functionnality for sending header if source policy has the proper signature NicolasWinckler 2015-11-06 12:03:36 +0100
  • 6ce6887212 formatting, change and clean generic_sampler and SimpleTreeReader NicolasWinckler 2015-11-06 11:07:16 +0100
  • d0c20d3729 Rename /example to /examples and move MQ examples in it Alexey Rybalchenko 2015-11-09 10:36:24 +0100
  • 307d698736 Add example for sending multipart messages Alexey Rybalchenko 2015-11-06 13:20:11 +0100
  • 2e789e4439 Add ParameterMQServer and example of its use Alexey Rybalchenko 2015-10-27 09:32:52 +0100
  • 19b3347ade - rename tutorial7 and move it to example/MQ/GenericDevices - rename functions of MQ examples and change directory structures - move FairMQUnpacker.h from example/MQ/LmdSampler to base/MQ/devices - add runSimpleMQStateMachine.h helper function in fairmq/tools NicolasWinckler 2015-11-04 13:01:10 +0100
  • 93b82767eb correct some coverity issues and add empty string to the logger if boost version = 1,59.0 NicolasWinckler 2015-11-04 10:54:33 +0100
  • 3a7175f8e8 add lmd sampler-unpacker-sink chain in example/MQ/lmdSampler NicolasWinckler 2015-11-02 13:13:18 +0100
  • 323033c9eb Add CRTP base class for the policies of the generic device NicolasWinckler 2015-10-14 17:12:19 +0200
  • 559c7babca add doc for the generic devices NicolasWinckler 2015-10-13 16:32:08 +0200
  • fe91aa1634 add typedef for policies in host class, and make the sampler task container optional. NicolasWinckler 2015-10-13 16:05:49 +0200
  • 946f1c9d00 add doc for the tutorial7 and the generic device NicolasWinckler 2015-10-12 14:25:46 +0200
  • daba1771fa Fix return values of nanomsg send/receive calls Alexey Rybalchenko 2015-11-03 13:16:07 +0100
  • 4be6ba6e66 Check return values of Receive calls in the examples Alexey Rybalchenko 2015-11-03 13:15:13 +0100
  • 6dc4dc84b3 Add proper return value in set timeout Alexey Rybalchenko 2015-11-03 13:14:16 +0100
  • ada23500be Return if an unknown exception has been cought in Channel Alexey Rybalchenko 2015-11-03 09:45:00 +0100
  • d52d7d4ebc Merge branch 'sink-io-threads' of https://github.com/rbx/FairRoot into rbx-sink-io-threads Mohammad Al-Turany 2015-11-02 19:54:36 +0100
  • 7ee479084c Add missing return statement Giulio Eulisse 2015-11-02 16:56:28 +0100
  • 6000e86e74 Remove redundant io-threads cmd option from Sink Alexey Rybalchenko 2015-11-02 09:27:12 +0100
  • af70d03ab0 Add missing include directories for ZeroMQ and NanoMsg. They have been found by chance when the packages are in SIMPATH. They are not found if they are in another path. Florian Uhlig 2015-10-21 17:12:04 +0200
  • 8f59db1283 Add methods to set timeout on blocking Send/Receive Alexey Rybalchenko 2015-10-15 16:43:30 +0200
  • 91d3f013c0 Fix setting of ZeroMQ I/O Threads (setting was not propagated before) Alexey Rybalchenko 2015-10-08 12:05:50 +0200
  • 023d88d0ef Add FairMQ Example 6 - Working with multiple channels Alexey Rybalchenko 2015-10-07 15:50:10 +0200
  • 0b11ad9274 Fix the type mismatch in the multi-channel poller Alexey Rybalchenko 2015-10-07 15:49:25 +0200
  • 19afacb504 FairMQ Examples cleanup Alexey Rybalchenko 2015-09-29 11:07:27 +0200
  • a75486f3ec * split log console output sink into two sinks, one for cout and one for cerr. * remove logger_oldboost_version files and add ifdef boost version in logger.cxx instead winckler 2015-09-29 16:50:44 +0200
  • 54e1777c00 Small adjustments for the new logger. Alexey Rybalchenko 2015-09-11 15:38:16 +0200
  • 5136c88d3a Simplify Tutorial3 structure. Alexey Rybalchenko 2015-09-09 16:57:04 +0200
  • 8b71e4d20b Use FairMQDevice::CatchSignals for Tutorial7 Alexey Rybalchenko 2015-09-08 16:16:05 +0200
  • dc6fb4698c Fix bug in nanomsg implementation of poller check. Alexey Rybalchenko 2015-09-08 14:34:05 +0200
  • 35ff6c8fc8 Fix a bug in nanomsg implementation when sending empty messages. Alexey Rybalchenko 2015-09-08 12:07:12 +0200
  • f13bb5995d Add FairMQ tests (PUB-SUB, PUSH-PULL, REQ-REP). Alexey Rybalchenko 2015-09-04 17:04:52 +0200