Commit Graph

  • c78541432f add missing link dependency Dennis Klein 2017-05-09 18:20:38 +02:00
  • 04bc7d4bfd add missing include guard Dennis Klein 2017-05-05 18:58:22 +02:00
  • 3dc5fd1d6e expose STL iterator interface for FairMQParts Dennis Klein 2017-05-08 20:37:36 +02:00
  • 0926a9a764 FairMQ: allow accumulation of parts on receive. Alexey Rybalchenko 2017-04-27 14:05:02 +02:00
  • 1fa5c836a6 FairMQ: stop device if binding was unsuccessful (not updated dynamically). Alexey Rybalchenko 2017-04-27 13:06:56 +02:00
  • 459b42add2 FairMQ: MakeTransport to create stand-alone transport for tests. Alexey Rybalchenko 2017-04-26 13:42:41 +02:00
  • 085de240c2 FairMQ: fix missing includes. Alexey Rybalchenko 2017-04-25 15:37:54 +02:00
  • 2a526b8625 shmem: introduce FairMQShmMonitor. Alexey Rybalchenko 2017-04-24 14:53:33 +02:00
  • 7b4a2ae932 shmem: configurable segment name. Alexey Rybalchenko 2017-04-24 13:55:10 +02:00
  • 14f9084a80 shmem: Heartbeats for the monitor. Alexey Rybalchenko 2017-04-12 11:21:43 +02:00
  • a8d40abbd9 FairProgOptions: update ambiguous option name. Alexey Rybalchenko 2017-04-20 11:24:11 +02:00
  • f39b41d68c tweak startup and linger times Dennis Klein 2017-04-20 17:51:10 +02:00
  • bbc8da54b4 clean redundant doxygen comments Dennis Klein 2017-04-20 18:01:03 +02:00
  • 91831ff701 print debug output immediately Dennis Klein 2017-04-20 17:45:48 +02:00
  • a1fe478ce7 fix more -Winconsistent-missing-override warnings Dennis Klein 2017-04-13 17:09:18 +02:00
  • 132ae69953 add startup and linger times for pubsub Dennis Klein 2017-04-13 15:38:30 +02:00
  • 541538e3de only reset sockets if needed Alexey Rybalchenko 2017-04-13 14:08:00 +02:00
  • c51575f88c fix clang++ -Winconsistend-missing-override warnings Alexey Rybalchenko 2017-04-13 14:07:52 +02:00
  • f963a06e25 make connecting channel wait loop more flexible Dennis Klein 2017-04-13 12:51:35 +02:00
  • ee0d2e0c55 add debug output to test devices Alexey Rybalchenko 2017-04-11 16:44:45 +02:00
  • 218af15bbb ensure that FairMQ.Protocols is not run in parallel Dennis Klein 2017-04-12 13:59:04 +02:00
  • d866589be1 Two devices can't share device id Dennis Klein 2017-04-10 17:38:19 +02:00
  • bf2b208749 update docs Dennis Klein 2017-04-06 17:20:48 +02:00
  • 7caf0a6aae Configurable shmem segment size Alexey Rybalchenko 2017-04-06 14:18:30 +02:00
  • ac7017deb5 Re-enable rate limiting in benchmarkSampler Alexey Rybalchenko 2017-04-06 14:10:11 +02:00
  • 5aaf27bf02 Refactor the transport interface Alexey Rybalchenko 2017-04-04 17:14:37 +02:00
  • d7eb692951 remove no longer needed special treatment for logger directory Dennis Klein 2017-04-07 11:29:17 +02:00
  • 9b337ca075 remove redundant include path Dennis Klein 2017-04-07 11:26:06 +02:00
  • d02ae9be2c remove no longer used variable Dennis Klein 2017-04-07 11:25:35 +02:00
  • 1ebbe80539 Add ZeroMQ include path Giulio Eulisse 2017-04-05 14:28:44 +02:00
  • c41cf318bd export FairMQ targets and install headers hierarchically Dennis Klein 2017-04-05 13:51:31 +02:00
  • 608e34f26d Set CMake min. vers. to 3.6.0 and add conrtibutors file Mohammad Al-Turany 2017-04-04 13:44:02 +02:00
  • 365a68010f various fixes Dennis Klein 2017-03-28 14:48:08 +02:00
  • 13c9c09ab9 list fairmq authors centrally instead of in each file Dennis Klein 2017-03-28 14:43:25 +02:00
  • 35b3212f7e cmake cleanups and fixes Dennis Klein 2017-03-28 14:30:31 +02:00
  • 7e34f7042f refactor tests Dennis Klein 2017-03-28 14:19:08 +02:00
  • 55a9d69908 Adding option '--channel-config' to MQProgOptions Matthias Richter 2017-03-30 17:00:04 +02:00
  • 9943be507e Adding helper function to print the raw boost property tree Matthias Richter 2017-03-30 16:56:57 +02:00
  • e184610c06 Adding parser implementation for key-value subopt format Matthias Richter 2017-03-30 16:45:33 +02:00
  • 341464a793 Compatibility with nanomsg<=0.6 Alexey Rybalchenko 2017-03-21 09:48:44 +01:00
  • 3c73c690f7 Transports: use transportType as static member. Alexey Rybalchenko 2017-03-14 11:41:56 +01:00
  • b237b3f9d7 Remove unused code. Alexey Rybalchenko 2017-03-07 10:52:57 +01:00
  • 2293c5e417 FairMQChannel: API to access socket metrics; make fSocket private. Alexey Rybalchenko 2017-03-07 10:52:27 +01:00
  • 2a72d58766 Remove unneeded if when deleting NULL / 0 / nullptr Giulio Eulisse 2017-03-13 11:50:17 +01:00
  • d1cf852c98 Fox Coverity issues Florian Uhlig 2017-02-23 18:44:04 +01:00
  • 91b7a72ac5 get default network interface from the default route Alexey Rybalchenko 2017-03-01 11:25:42 +01:00
  • eaa220e39e better tests output Alexey Rybalchenko 2017-03-01 09:53:19 +01:00
  • 9e477264c8 Better encapsulate Device config: Offer a getter method Sandro Wenzel 2017-03-02 08:54:53 +01:00
  • c78b7e4cfa Fix nanomsg tests Alexey Rybalchenko 2017-02-27 16:40:07 +01:00
  • 07b760218f Fix coverity #157658 Alexey Rybalchenko 2017-02-27 10:36:24 +01:00
  • 7c1f7aa3f2 Fix Tuto3 double delete, cleanup test output, undeclared var in NN socket. Alexey Rybalchenko 2017-02-23 15:59:28 +01:00
  • b43d4c142d refactor and integrate with aliBuild/alienv Dennis Klein 2017-02-21 23:03:22 +01:00
  • c66fd6fe91 Adding multiple transports support & other fixes: Alexey Rybalchenko 2017-01-13 15:53:25 +01:00
  • e53ad151a7 Fix mismatch in FairMQSink parameter type. Alexey Rybalchenko 2017-01-16 13:36:45 +01:00
  • 3e7cb85816 Fix incorrect calculation of transfer rate for multipart. Alexey Rybalchenko 2017-01-12 09:43:10 +01:00
  • 8cf1cbb930 Initialize shared memory only if it is used. Alexey Rybalchenko 2017-01-09 13:37:39 +01:00
  • ac1da4db66 Require std::move when adding existing message to FairMQParts. Alexey Rybalchenko 2017-01-05 14:15:05 +01:00
  • 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