Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-21 04:21:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Commit Graph

  • 65c19f07bf Fix compatibility with ZeroMQ 4.2.1 Alexey Rybalchenko 2017-02-09 09:15:06 +01:00
  • 617042b3c6 For tests on MacOSX use new MacOSX version 10.11 and FairSoft version may16p1. Run fairmq tests sequentialy. Florian Uhlig 2016-11-10 15:21:21 +01:00
  • 62df0b609b disable feature not available on GCC < 5 Alexey Rybalchenko 2016-12-19 10:25:53 +01:00
  • a332d9fc83 First version of the shared memory transport. Alexey Rybalchenko 2016-06-03 11:24:12 +02:00
  • 6c3b01f09c AttachChannel must update the config after it's done, use boost::split Alexey Rybalchenko 2016-12-13 13:23:21 +01:00
  • 0fb49a0986 State machine update Alexey Rybalchenko 2016-11-24 13:59:26 +01:00
  • b166cedb63 Convert factory methods to return smart ptrs Alexey Rybalchenko 2016-11-16 16:27:21 +01:00
  • 12f04c7237 Fix race condition in the state machine & channel. Alexey Rybalchenko 2016-11-15 13:08:38 +01:00
  • 94a4d599eb Validate connection method per endpoint, not socket mkrzewic 2016-11-13 14:22:51 +01:00
  • 892aa8008b Add missing #include <cstring> mkrzewic 2016-11-13 00:05:57 +01:00
  • 6bec8fc1db Simplify Tokenize(): nicer looking code = better code mkrzewic 2016-11-12 18:04:14 +01:00
  • c2d7c49cf5 Support multiple endpoints per socket mkrzewic 2016-11-11 16:35:23 +01:00
  • 0a3f14c0e3 all: apply fer-json-fmt Sebastien Binet 2016-11-10 15:20:09 +01:00
  • 02f5e63784 all: use strict(er) and more regular JSON schema Sebastien Binet 2016-11-10 14:22:11 +01:00
  • 581e93968e fairmq/options: fix JSON example Sebastien Binet 2016-11-10 10:55:50 +01:00
  • 79fba8ec4c Update JSON files & readme, use FairMQDevicePtr, cleanup. Alexey Rybalchenko 2016-10-28 15:42:15 +02:00
  • da3010b20c Move config & control DDS functionality into plugins. Alexey Rybalchenko 2016-10-19 16:20:40 +02:00
  • 16fd63cd5b Enable new callback API Alexey Rybalchenko 2016-08-10 09:47:53 +02:00
  • e0a03242ac Simplify logger filtering options, fix log error double printing issue winckler 2016-09-16 11:46:51 +02:00
  • 9ceab6099c add a signal/slot mechanism. 2 APIs : one generic version, and one string API (commented) winckler 2016-08-09 14:02:43 +02:00
  • 5e5ddd5b7b Fix further effc++ and reorder warnings. Alexey Rybalchenko 2016-09-07 10:23:38 +02:00
  • 7c99bd77cc Fix unused variables, init order and effc++ warnings. Alexey Rybalchenko 2016-09-02 13:44:30 +02:00
  • 827c8dcd45 Remove warnings about unused parameters. Florian Uhlig 2016-08-11 18:08:24 +02:00
  • bed58891ea merge MQ parameters in the variable_map container of FairMQProgramOptions class winckler 2016-08-04 17:53:58 +02:00
  • 2ed0c52ae8 Test nanomsg transport only when nanomsg library is found. Alexey Rybalchenko 2016-08-04 13:33:52 +02:00
  • 13a5cea1d7 fix parallel running tests failure Alexey Rybalchenko 2016-07-11 10:58:30 +02:00
  • 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 +02:00
  • 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 +02:00
  • 75aad5676d Use Boost_ variables instead of hardcoded names. Florian Uhlig 2016-06-08 15:38:14 +02:00
  • 92944fe322 Correct shell scripts to work correctly with dash. Florian Uhlig 2016-05-30 17:10:54 +02:00
  • f3bebe9321 Use different ports in tests to prevent parallel run fail Alexey Rybalchenko 2016-06-01 11:49:33 +02:00
  • 7062a3d280 Run FairMQ tests with both ZeroMQ and nanomsg Alexey Rybalchenko 2016-05-31 10:19:32 +02:00
  • eb306a2c0d Remove color output from tests Alexey Rybalchenko 2016-05-30 12:36:55 +02:00
  • 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 +02:00
  • 65ca151620 MQ/example9 Adapted to the new running scheme with DDS. Radoslaw Karabowicz 2016-05-27 14:28:10 +02:00
  • 253604344f nanomsg: reset maximum receive msg size Alexey Rybalchenko 2016-05-27 10:14:15 +02:00
  • cc88339791 Cleanup command line options Alexey Rybalchenko 2016-05-23 14:55:42 +02:00
  • 4944d7ec41 Meaningful error on wrong channel name Alexey Rybalchenko 2016-05-20 12:54:10 +02:00
  • a05dc80402 Refactor DDS example and tools to be able to run with/without DDS Alexey Rybalchenko 2016-05-19 10:22:02 +02:00
  • af971c6ab1 Allow rate limiting in the Shared Memory example Alexey Rybalchenko 2016-05-18 16:00:26 +02:00
  • 1f09317cd0 Handle both single and multi part payloads in splitter/merger/proxy Alexey Rybalchenko 2016-05-17 10:34:55 +02:00
  • e9f09143b2 Gracefully end the device also in the termination case (instead of abort). Alexey Rybalchenko 2016-05-17 08:55:42 +02:00
  • ce42f36126 Remove redundant state change call and revert the termination handler. Alexey Rybalchenko 2016-05-12 15:21:12 +02:00
  • 28aa5e4caa Let ParseAll exit if unsuccessfull Alexey Rybalchenko 2016-05-12 11:35:24 +02:00
  • 31456e71ff Threads safe socket rate stats Alexey Rybalchenko 2016-05-12 09:13:57 +02:00
  • 3353e214a7 Add shared memory example Alexey Rybalchenko 2016-04-07 17:02:37 +02:00
  • 599d1b3e05 MQ/example9 Added testing of the static MQ execution. Radoslaw Karabowicz 2016-05-06 14:46:17 +02:00
  • 58754e03c7 Make sure logger is used before configuring it. Alexey Rybalchenko 2016-04-28 09:51:02 +02:00
  • e039931098 Fix the logger conflict issue Alexey Rybalchenko 2016-04-27 17:00:27 +02:00
  • 5421922668 Add a cmd option to control state change mechanism Alexey Rybalchenko 2016-04-27 15:04:29 +02:00
  • b9883d3b13 Configuration and DDS example/tools updates Alexey Rybalchenko 2016-03-31 14:41:05 +02:00
  • 151d3b5de8 Fix dereference before null check in example and formatting Alexey Rybalchenko 2016-04-14 13:23:09 +02:00
  • a892a5a744 Update FairMQParts with doxygen comments and non-blocking send Alexey Rybalchenko 2016-04-04 09:43:48 +02:00
  • 82090c356c Fix identity setting for req/rep socket Alexey Rybalchenko 2016-04-07 15:13:51 +02:00
  • e977dfb609 update generic sampler with new serialization api winckler 2016-04-06 12:05:50 +02:00
  • 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 +02:00
  • 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 +02:00
  • 819a21f46a remove obsolete documentation winckler 2016-03-28 23:14:31 +02:00
  • e215049db9 remove alternative serialization API winckler 2016-03-28 22:55:43 +02:00
  • 835c88c6d2 change serialization API so that it takes a FairMQMessage reference winckler 2016-03-28 19:13:49 +02:00
  • 4c50409af5 add serialization API winckler 2016-03-24 15:59:33 +01:00
  • 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 +02:00
  • 732373faa2 Update multi-part features (nanomsg) and various fixes Alexey Rybalchenko 2016-03-21 09:59:00 +01:00
  • 4ca66e33da Fix compiler warnings. Florian Uhlig 2016-03-17 13:19:49 +01:00
  • fa7040fe65 Fix compiler warnings. Florian Uhlig 2016-03-09 15:52:10 +01:00
  • bb36147099 Allocate dynamic size flatbuffers structure on the heap Alexey Rybalchenko 2016-03-10 11:48:12 +01:00
  • 1ad58653e7 Fix return value of multipart send/receive methods Alexey Rybalchenko 2016-03-03 15:35:39 +01:00
  • c564a3f066 Merge branch 'fix-uint' of https://github.com/rbx/FairRoot into rbx-fix-uint Mohammad Al-Turany 2016-03-03 15:35:36 +01:00
  • 10f997f680 Fix return value of multipart send/receive methods Alexey Rybalchenko 2016-03-03 15:35:39 +01:00
  • c42b6ca4ae Include device ID in the zeromq socket identity. Alexey Rybalchenko 2016-03-03 11:23:47 +01:00
  • e1fef82657 FairMQ: Extend Multipart and messaging API Alexey Rybalchenko 2016-02-23 18:00:35 +01:00
  • 82ab7670a9 Add FlatBuffers & MessagePack examples Alexey Rybalchenko 2015-12-04 15:18:46 +01:00
  • f1abb9ecdd Remove compile time transport interface switch Alexey Rybalchenko 2016-01-13 17:21:24 +01:00
  • 0e1a1ad552 Allow to limit number of messages for the Benchmark sampler and sink Alexey Rybalchenko 2016-01-07 17:37:43 +01:00
  • c10a6abeef Fix memory leaks in Tutorial3 Alexey Rybalchenko 2016-01-07 13:39:17 +01:00
  • e4fed2fa1b Fix copy constructor & assignment operator warning in FairMQChannel Alexey Rybalchenko 2016-01-06 13:52:24 +01:00
  • 9a0a8c7516 Add a acknowledgement channel to Tutorial 3... Alexey Rybalchenko 2015-12-02 16:24:47 +01:00
  • d254efb91f Fix compiler warnings. Mostly unused parameters have been removed. Florian Uhlig 2015-12-15 21:56:41 +01:00
  • 2060f0b1d7 FairMQLogger : remove pragma command and use CMake include SYSTEM command instead NicolasWinckler 2015-11-24 12:06:07 +01:00
  • 2afa0652f4 Extend DDS Example to use command interface Alexey Rybalchenko 2015-11-23 11:28:15 +01:00
  • 35c64c67a2 add a command line to enable/disable the color format in the fairmq log console output NicolasWinckler 2015-11-20 15:25:34 +01:00
  • 10d6482716 remove unfinished doc NicolasWinckler 2015-11-19 16:51:49 +01:00
  • 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 +01:00
  • afda64a83d Simplify the handling of send/receive timeouts Alexey Rybalchenko 2015-11-19 15:30:37 +01:00
  • 0894900f52 Add missing link dependencies. Florian Uhlig 2015-11-19 15:51:44 +01:00
  • 89d57db5ea - create 3 test scripts for bin, boost, and root serialization format NicolasWinckler 2015-11-11 12:23:41 +01:00
  • 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 +01:00
  • 1467360f75 access channel map with at NicolasWinckler 2015-11-11 09:41:04 +01:00
  • 383a220333 Update device configuration Alexey Rybalchenko 2015-11-11 11:06:11 +01:00
  • 837490cc38 add FairProgOptionsHelper.h in header list to be installed of fairmq/CMakeLists.txt NicolasWinckler 2015-11-09 13:08:02 +01:00
  • 819a8df952 add function helpers for FairProgOptions which simplify FairProgOptions.cxx NicolasWinckler 2015-11-09 12:18:34 +01:00
  • 13d3729fec enable/disable multipart functionnality for sending header if source policy has the proper signature NicolasWinckler 2015-11-06 12:03:36 +01:00
  • 6ce6887212 formatting, change and clean generic_sampler and SimpleTreeReader NicolasWinckler 2015-11-06 11:07:16 +01:00
  • d0c20d3729 Rename /example to /examples and move MQ examples in it Alexey Rybalchenko 2015-11-09 10:36:24 +01:00
  • 307d698736 Add example for sending multipart messages Alexey Rybalchenko 2015-11-06 13:20:11 +01:00
  • 2e789e4439 Add ParameterMQServer and example of its use Alexey Rybalchenko 2015-10-27 09:32:52 +01:00
  • 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 +01:00
  • 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 +01:00
  • 3a7175f8e8 add lmd sampler-unpacker-sink chain in example/MQ/lmdSampler NicolasWinckler 2015-11-02 13:13:18 +01:00
  • 323033c9eb Add CRTP base class for the policies of the generic device NicolasWinckler 2015-10-14 17:12:19 +02:00