Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2026-06-17 09:17:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Commit Graph

  • 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
  • 559c7babca add doc for the generic devices NicolasWinckler 2015-10-13 16:32:08 +02:00
  • fe91aa1634 add typedef for policies in host class, and make the sampler task container optional. NicolasWinckler 2015-10-13 16:05:49 +02:00
  • 946f1c9d00 add doc for the tutorial7 and the generic device NicolasWinckler 2015-10-12 14:25:46 +02:00
  • daba1771fa Fix return values of nanomsg send/receive calls Alexey Rybalchenko 2015-11-03 13:16:07 +01:00
  • 4be6ba6e66 Check return values of Receive calls in the examples Alexey Rybalchenko 2015-11-03 13:15:13 +01:00
  • 6dc4dc84b3 Add proper return value in set timeout Alexey Rybalchenko 2015-11-03 13:14:16 +01:00
  • ada23500be Return if an unknown exception has been cought in Channel Alexey Rybalchenko 2015-11-03 09:45:00 +01:00
  • 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 +01:00
  • 7ee479084c Add missing return statement Giulio Eulisse 2015-11-02 16:56:28 +01:00
  • 6000e86e74 Remove redundant io-threads cmd option from Sink Alexey Rybalchenko 2015-11-02 09:27:12 +01:00
  • 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 +02:00
  • 8f59db1283 Add methods to set timeout on blocking Send/Receive Alexey Rybalchenko 2015-10-15 16:43:30 +02:00
  • 91d3f013c0 Fix setting of ZeroMQ I/O Threads (setting was not propagated before) Alexey Rybalchenko 2015-10-08 12:05:50 +02:00
  • 023d88d0ef Add FairMQ Example 6 - Working with multiple channels Alexey Rybalchenko 2015-10-07 15:50:10 +02:00
  • 0b11ad9274 Fix the type mismatch in the multi-channel poller Alexey Rybalchenko 2015-10-07 15:49:25 +02:00
  • 19afacb504 FairMQ Examples cleanup Alexey Rybalchenko 2015-09-29 11:07:27 +02:00
  • 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 +02:00
  • 54e1777c00 Small adjustments for the new logger. Alexey Rybalchenko 2015-09-11 15:38:16 +02:00
  • 5136c88d3a Simplify Tutorial3 structure. Alexey Rybalchenko 2015-09-09 16:57:04 +02:00
  • 8b71e4d20b Use FairMQDevice::CatchSignals for Tutorial7 Alexey Rybalchenko 2015-09-08 16:16:05 +02:00
  • dc6fb4698c Fix bug in nanomsg implementation of poller check. Alexey Rybalchenko 2015-09-08 14:34:05 +02:00
  • 35ff6c8fc8 Fix a bug in nanomsg implementation when sending empty messages. Alexey Rybalchenko 2015-09-08 12:07:12 +02:00
  • f13bb5995d Add FairMQ tests (PUB-SUB, PUSH-PULL, REQ-REP). Alexey Rybalchenko 2015-09-04 17:04:52 +02:00
  • fbf7dbf2ba Add orthogonal OK/ERROR states. Alexey Rybalchenko 2015-08-24 17:35:30 +02:00
  • a7ab33a10e Add new Send/Receive methods with smart pointers and no flag checks. Alexey Rybalchenko 2015-08-17 14:45:31 +02:00
  • 105e734808 Add DDS and Copy+Push examples. Alexey Rybalchenko 2015-08-18 09:35:31 +02:00
  • 96cd2afac7 fix missing header issue in fairmq/logger winckler 2015-09-24 11:01:49 +02:00
  • 5212dd4ce1 move back the empty deleter in the logger.cxx winckler 2015-09-23 14:27:28 +02:00
  • a0388c084e remove boost and tutorial7 -Wshadow warnings and install null deleter file in FairRoot installation winckler 2015-09-22 10:09:52 +02:00
  • ca7a76110d add an other fairmq logger implementation in case boost version < 1.56 for backward compability winckler 2015-09-21 12:07:47 +02:00
  • 74f7c5873a Fix the logger installation Alexey Rybalchenko 2015-09-11 14:22:44 +02:00
  • e0ca1f62b3 - Replace the fairmq logger with one based on Boost.Log - Adapt FairProgOptions to the new logger winckler 2015-09-07 18:51:50 +02:00
  • bea05ea6c1 Add missing include statement. Florian Uhlig 2015-09-09 15:38:46 +02:00
  • 1302e77a16 Several FairMQ fixes and improvements: Alexey Rybalchenko 2015-07-03 22:57:36 +02:00
  • d1bba61939 - FairMQ options: a) move the XML parser into the FairMQ/options/FairMQParser.h b) add a routine in FairMQProgOption to check whether the necessary XML or JSON input files are there, and send an error message if not there winckler 2015-07-02 12:13:56 +02:00
  • 6ed9cc3da1 Fixed a typo in example config Alexey Rybalchenko 2015-06-30 16:47:43 +02:00
  • b855f77060 - fix coverity issues - clean code and typo in comments winckler 2015-06-26 12:17:54 +02:00
  • 4db91a52eb Fix Coverity issues Alexey Rybalchenko 2015-06-26 10:52:05 +02:00
  • 2656d8098c Add first two simple FairMQ examples Alexey Rybalchenko 2015-06-22 12:23:21 +02:00
  • 5f20a28b04 Correct mistake in channel validation Alexey Rybalchenko 2015-06-19 14:40:56 +02:00
  • 252acf41c8 Add WaitForInitialValidation() Alexey Rybalchenko 2015-06-19 12:02:51 +02:00
  • e5313d03fe Fix uncaught exceptions Alexey Rybalchenko 2015-06-19 09:56:01 +02:00
  • d6a413534a Thread safe initialization of the channels Alexey Rybalchenko 2015-06-18 15:10:01 +02:00
  • 295d9bba57 add WaitForEndOfStateForMs(state, duration) Alexey Rybalchenko 2015-06-17 15:27:19 +02:00
  • 6cd1e53b13 Add missing license information Mohammad Al-Turany 2015-06-16 15:31:23 +02:00