Commit Graph

  • 3d8175bfd6 base/MQ and Lmd example cleanup Alexey Rybalchenko 2017-06-29 09:56:31 +02:00
  • 6f18cf23da Merge channels from config to device, instead of replace Alexey Rybalchenko 2017-06-30 10:19:59 +02:00
  • a26925cbf5 FairMQ: Fix various errors from CI Dennis Klein 2017-06-30 16:29:52 +02:00
  • ad0f050c99 FairMQ: Implement PluginServices - Config Dennis Klein 2017-06-29 22:53:44 +02:00
  • 739460b2fe FairMQ: Implement PluginServices - Control Dennis Klein 2017-06-26 15:30:08 +02:00
  • 9b61b924b2 FairMQ: Integration of Plugins through PluginServices Dennis Klein 2017-06-26 15:08:26 +02:00
  • 60d929b0bd FairMQ: Add plugin mechanism (Plugin and PluginManager classes) Dennis Klein 2017-04-12 13:30:32 +02:00
  • ac69607250 make FairProgOptions calls thread safe Alexey Rybalchenko 2017-06-26 12:29:19 +02:00
  • b47cc8b29c add callback on state change Alexey Rybalchenko 2017-06-22 10:44:17 +02:00
  • b311b0c6da FairMQLogger: undefine DEBUG if it has been previously defined Alexey Rybalchenko 2017-06-23 12:29:59 +02:00
  • 035d5fb353 Provide accessors for device members that are part of publiv API Alexey Rybalchenko 2017-06-22 19:52:30 +02:00
  • 92cae6f9a4 FairMQProxy: remove outdated code Alexey Rybalchenko 2017-06-21 12:17:01 +02:00
  • a60fac80d9 FairMQProgOptions: add a method to check key existence Alexey Rybalchenko 2017-06-21 12:16:20 +02:00
  • 4bc54ad32b add --print-channels to print registered channels of the device Alexey Rybalchenko 2017-06-20 15:58:43 +02:00
  • 1d38a2350f add --print-options to print available options in short format Alexey Rybalchenko 2017-06-07 16:27:40 +02:00
  • cae3fd6aa3 Catch any exception type in the main of runFairMQDevice.h Alexey Rybalchenko 2017-06-22 14:45:39 +02:00
  • 25a75c1f82 add channel, poller and testing docs Dennis Klein 2017-05-24 17:07:07 +02:00
  • 5e2926e0da FairMQShmMonitor docs Alexey Rybalchenko 2017-05-24 18:02:02 +02:00
  • f05ed326a6 Update FairMQShmMonitor Alexey Rybalchenko 2017-05-24 14:09:37 +02:00
  • 764514a35a Test devices without config & two in a process Alexey Rybalchenko 2017-05-26 10:39:33 +02:00
  • f4e5a74f23 Always have access to FairMQProgOptions from device. Alexey Rybalchenko 2017-05-17 08:48:11 +02:00
  • 7bb6a2eed9 add default subchannel index Dennis Klein 2017-05-23 16:16:44 +02:00
  • 8bc21675af Refactor TransportFactory to RAII Dennis Klein 2017-05-23 16:13:43 +02:00
  • 733794657c update docs Dennis Klein 2017-05-22 17:46:50 +02:00
  • 89423eb737 enable shmem tests Dennis Klein 2017-05-22 19:59:29 +02:00
  • 8b93b4f8ed do not call nn_term() Dennis Klein 2017-05-22 19:54:06 +02:00
  • d2c78479f0 Refactor FairMQTools Dennis Klein 2017-05-18 16:53:02 +02:00
  • 9215c81362 Deprecate old TransportFactory factory Dennis Klein 2017-05-22 17:06:01 +02:00
  • 9288a2c3d5 Add tests for poller. Alexey Rybalchenko 2017-05-19 09:41:45 +02:00
  • 6b221d950c Add NewPoller() wrapper. Alexey Rybalchenko 2017-05-19 09:41:13 +02:00
  • 3be2f297f3 generate id if no device id available Dennis Klein 2017-05-16 18:26:24 +02:00
  • eb614b6005 do not copy strings Dennis Klein 2017-05-16 17:24:43 +02:00
  • b5dab60a82 add more single and multithreaded unit tests Dennis Klein 2017-05-13 17:30:49 +02:00
  • 3205e0c378 refactor to more idiomatic RAII Dennis Klein 2017-05-14 17:10:57 +02:00
  • 87252edbe0 move New*Message apis to TransportFactory Dennis Klein 2017-05-13 17:29:39 +02:00
  • 97ca52aa0e move TransportFactory factory into FairMQTransportFactory namespace Dennis Klein 2017-05-17 16:08:45 +02:00
  • f522dc1717 add FairMQParts Send/Receive apis Dennis Klein 2017-05-13 16:54:56 +02:00
  • 8b85dd2191 support inproc addresses Dennis Klein 2017-05-13 16:49:36 +02:00
  • 3cb80de773 add channel name setter Dennis Klein 2017-05-13 16:47:21 +02:00
  • 463a49d79c update CONTRIBUTORS Dennis Klein 2017-05-14 13:23:17 +02:00
  • 2d4282c62d Fix CID 169527 Uncaught Exception Dennis Klein 2017-05-17 18:45:44 +02:00
  • a9ac1fa91c Fix CID 169522 Unchecked return value Dennis Klein 2017-05-17 18:45:15 +02:00
  • ec786dce03 Fix CID 169525 Data race condition Dennis Klein 2017-05-17 18:44:51 +02:00
  • 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