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

Commit Graph

  • 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
  • a3d919b763 Use FairMQProgOptions for Sink and BenchmarkSampler Alexey Rybalchenko 2015-06-15 16:50:03 +02:00
  • 7fda980710 Update FairMQStateMachine & introduce FairMQChannels Alexey Rybalchenko 2015-04-29 13:25:42 +02:00
  • a2ebbbe450 move fairmq json parser to fairmq/options winckler 2015-06-15 15:55:11 +02:00
  • f54fbb0f59 Add FairMQProgOptions for configuring MQDevices winckler 2015-05-21 14:32:05 +02:00
  • ccd04fc54b Change code to be able to use ROOT6 Florian Uhlig 2015-05-07 14:29:58 +02:00
  • 7fa785a8f4 add static set log level function and minimum log level variable to FairMQlogger in order to filter output printing. winckler 2015-04-27 13:22:16 +02:00
  • 445ef356d1 - Rename some function members of Generic MQ Devices and propagate the modifications accordingly. winckler 2015-04-03 16:28:58 +02:00
  • 26a1033e9d Rename device property to have a common format and some code cleanup. Alexey Rybalchenko 2015-03-26 15:03:14 +01:00
  • 61f24eb73a Increase maximum number of zeromq sockets and improve output on errors. Alexey Rybalchenko 2015-03-14 17:03:21 +01:00
  • 8a82afe184 Expose BIND and CONNECT states for use with dynamic configuration Alexey Rybalchenko 2015-01-28 14:24:14 +01:00
  • 6d65c4313a Split serializer policies into serializer and deserializer policies, and change serializer method names message() to SerializeMsg() and DeserializeMsg() winckler 2015-02-11 10:32:40 +01:00
  • 6518b7cd41 FairMQSocket: add versions of Send/Receive methods with int flags instead of string, which is more flexible and performant. Int flags are mapped to their ZeroMQ/nanomsg versions behind the transport interface. Methods with string flags are kept for backwards compatibility. Alexey Rybalchenko 2015-01-25 21:40:00 +01:00
  • a9b7e8866c add helper function to find IPs of the node Alexey Rybalchenko 2015-01-23 17:15:43 +01:00
  • bfa26e857d re-organize base/MQ directory, change library name FairMQSampler to BaseMQ, and link tutorial 3,6,7 accordingly. Functions in has_boostSerialization.h are now in baseMQtools.h. New template header files (.h and .tpl) are copied to proper directory in case of FairRoot external installation Remove obsolete files in tutorial3. winckler 2015-01-19 11:52:55 +01:00
  • 3e424354e7 add 1) generic MQ-devices (Sampler, Processor, and FileSink) in fairmq, 2) policy classes in base/MQ and 3) a Tutorial7 in example NicolasWinckler 2014-11-10 16:42:08 +01:00
  • eb33bc8280 add constructor to DeviceOptions Alexey Rybalchenko 2015-01-15 13:26:15 +01:00
  • ce58ee2302 Fix warnings produced with -Weffc++ in fairmq, base/MQ and Tutorial3. Remaining warnings originate from boost::msm and boost::mpl. Also, warnings with missing initializer list entries for DeviceOptions are false positives, since those are PODs. Alexey Rybalchenko 2015-01-02 14:04:33 +01:00
  • a8854d36ac Get rid of warnings which come from include files which doesn't belong to FairRoot. These are for example Boost or ROOT includes. Define in all CMakeLists.txt files such libraries as system libraries. In this case the compiler will not produce any warning. This change reduces the nightly test time on some machines from more then hour to 1 minute. The reason for this long compile time was the enormous amount of warnings produced before. The output of the warnings sum up to roughly 850 MB. Florian Uhlig 2014-12-12 20:07:47 +01:00
  • 65d91b8681 bugfix: incorrect buffer size config Alexey Rybalchenko 2014-11-21 14:47:12 +01:00
  • e4e88ad1db Allow disabling transfer rate logging per input/output (optional, default is on). Alexey Rybalchenko 2014-11-10 17:13:38 +01:00
  • 0cef5692b1 Use boost::program_options for managing command line options of the executables. Existing scripts in example/Tutorial3/macro have been updated to use the new format. Your own executables are not affected, but your scripts which use FairMQ executables have to be updated to the new format. Use the --help option with any FairMQ executable to find out the available options. Alexey Rybalchenko 2014-09-30 11:37:18 +02:00
  • 101bc4c9e7 add flag for non-blocking operations Alexey Rybalchenko 2014-10-21 17:20:29 +02:00
  • 6968f57abc add ROUTER/DEALER/PAIR sockets. Alexey Rybalchenko 2014-10-15 11:24:41 +02:00
  • 9317f06c10 Add REQ-REP zmq/nn sockets to FairMQ together with a little example program. Also includes example of using boost::program_options. Alexey Rybalchenko 2014-10-10 18:36:44 +02:00
  • bd79420f93 Condition check before ending the main thread. Alexey Rybalchenko 2014-08-26 15:35:50 +02:00
  • 7d7e1a1084 fix ID in startAll script and a broken link in documentation. Alexey Rybalchenko 2014-08-26 09:29:55 +02:00
  • 0a610926a1 - Proper process termination: Alexey Rybalchenko 2014-08-12 09:11:51 +02:00
  • 8cd120aef4 - Add multipart support to the interface and enable its use out of tasks. Alexey Rybalchenko 2014-07-25 12:07:47 +02:00
  • 281fcc459c Fix CIDs 10587, 10813, 10911, 10912, 10402, 10403, 10577, 10578, 10579, 10848, 10861, 10865, 10868, 10910. Move classes inheriting from device to a subdirectory. Make sure only protobuf library installed by fairsoft is used. Cleanup FairMQDevice and fix some initialization list warnings. Loop to duplicate input files in Sampler. Add some documentation to FairMQ. Alexey Rybalchenko 2014-07-21 15:15:40 +02:00
  • fe91e5af96 Adding reademe files Radoslaw Karabowicz 2014-07-16 15:41:26 +02:00
  • d14d96ea70 fix CID 10112 Alexey Rybalchenko 2014-07-04 10:36:11 +02:00
  • 699671a0f1 Extend the FairMQ transport interface by allowing the user of the FairMQMessage class to define his own deallocation function. This function will be called when the transport machanism no longer needs the data. Alexey Rybalchenko 2014-06-12 12:47:49 +02:00
  • 865c0e010f Add license file LICENSE with LPGL license text copied from https://www.gnu.org/licenses/lgpl.html. Add license text to most of files of the project. Florian Uhlig 2014-06-03 11:27:00 +02:00
  • c03d4ad6d5 use clang-format for Tutorial3 Alexey Rybalchenko 2014-06-06 11:48:52 +02:00
  • 08e603911d TMessage transport implemented! Alexey Rybalchenko 2014-06-05 11:18:49 +02:00
  • 622e9e9c09 start experimenting with root transport mechanism. enable efficient message copying for zeromq (currently used only in benchmarkSampler). cleanup some code. Alexey Rybalchenko 2014-04-26 23:33:57 +02:00
  • 68d51d8ed5 use clang-format for FairMQ Alexey Rybalchenko 2014-04-10 15:20:48 +02:00
  • e80e6d4269 add support for I/O threads to the interface (only used with ZeroMQ). Alexey Rybalchenko 2014-05-27 19:01:49 +02:00
  • 24d26e802a Using boost::msm inside FairMQStateMachine. Thorsten Kollegger 2014-04-26 10:11:39 +00:00
  • adc7443aa5 Allow easier testing without having to recompile for use of binary/boost/protobuf payload. Alexey Rybalchenko 2014-03-28 12:00:13 +01:00
  • 005321f63c add boost::serialization and template features in tutorial3 and fairmq. Require to modifie base/event/fairtimestamp and fairhit. NicolasWinckler 2014-02-28 16:24:52 +01:00
  • 9a0ed2ca72 Add (optional) Google Protocol Buffers support (example in Tutorial 3). Alexey Rybalchenko 2014-02-24 10:55:26 +01:00
  • f31ae77ecb Logger fix: direct constructor call Alexey Rybalchenko 2014-03-04 15:11:19 +01:00
  • ac8bbf154a simplify logger for shorter calls and readability Alexey Rybalchenko 2014-02-10 15:27:59 +01:00
  • 4b8659a654 - Make FairMQSampler generic. - Remove fairroot dependency from fairmq. NicolasWinckler 2014-01-15 16:52:48 +01:00
  • dfc1dd6a06 - Make FairMQSampler generic. - Remove fairroot dependency from fairmq. NicolasWinckler 2014-01-15 16:52:48 +01:00
  • 23b88e9e91 cosmetic change Alexey Rybalchenko 2014-01-31 14:06:34 +01:00
  • c7b80f3ff9 move zeromq and nanomsg implementation files to separate directories Alexey Rybalchenko 2014-01-28 13:20:53 +01:00
  • dde65d3aeb correct include dir in cmake file Alexey Rybalchenko 2014-01-28 11:55:19 +01:00
  • a97d464d1c typo Alexey Rybalchenko 2014-01-27 16:52:29 +01:00
  • b45f968c67 change argument passing by value/reference Alexey Rybalchenko 2014-01-27 16:51:23 +01:00
  • ee70113120 make nanomsg optional Alexey Rybalchenko 2014-01-27 13:36:22 +01:00
  • 64b9e991c3 add nanomsg implementations + use factory for nanomsg + lots of small stuff Alexey Rybalchenko 2014-01-24 15:54:29 +01:00
  • c041c14373 cmake - use set(INCLUDE_DIRECTORIES) Alexey Rybalchenko 2014-01-22 09:57:59 +01:00
  • f2fe26e715 rename fTask to fProcessorTask for clarity and to resemble fSamplerTask name Alexey Rybalchenko 2014-01-22 09:50:09 +01:00