Dennis Klein
c47fc6f9fe
feat: Move ZMsg to fair::mq::zmq
...
Implement move semantics.
2023-06-13 21:24:40 +02:00
Dennis Klein
c3fdc8c08c
fix(zeromq): Leaking monitor socket messages
2022-08-12 01:50:14 +02:00
Giulio Eulisse
fa0bf96eb2
Skip error message only for tcp
2022-02-28 19:13:00 +01:00
Alexey Rybalchenko
bfd08bb33f
Don't use to-be-deprecated names
2022-01-24 06:40:24 +01:00
Alexey Rybalchenko
f15f669853
use [[maybe_unused]] for values used in assertions
2022-01-24 06:40:24 +01:00
Alexey Rybalchenko
d630fbb1e4
consolidate UnmanagedRegion options
2021-12-16 16:27:07 +01:00
Alexey Rybalchenko
953c4a75c8
refactor: deduplicate more zmq/shmem code
2021-12-06 09:45:39 +01:00
Dennis Klein
fda8126a43
feat: Add new GetNumberOfConnectedPeers() API
2021-10-19 10:22:19 +02:00
Dennis Klein
7329cb4428
refactor: Deduplicate GetConstant()
...
* Deprecate its old name in the Socket classes
2021-10-19 10:22:19 +02:00
Dennis Klein
e84a16da88
fix: warning readability-braces-around-statements
2021-10-19 10:22:19 +02:00
Alexey Rybalchenko
153dcfab94
Apply modernize-use-override
2021-09-27 12:04:07 +02:00
Alexey Rybalchenko
ad824b4de1
Define copy/move ctors and assignment ops
...
Delete special member functions where they are not used.
(as part of applying suggestions from cppcoreguidelines-special-member-functions)
These classes don't need to be copyable/movable:
# copy/move not used:
zmq:: TransportFactory, Socket, Message, UnmanagedRegion, Poller, Context
shm:: TransportFactory, Socket, Message, UnmanagedRegion, Poller
ofi:: TransportFactory, Socket, Message, Context
shm:: ZMsg, Region, Monitor, TerminalConfig, Manager
plugins:: Config, Control, TerminalConfig
fairmq::StateQueue, StateMachine, ProgOptions, PluginServices, PluginManager, Plugin, Device, StateSubscription
TestData, BadDevice, TestDevice (test suite heplers)
# used via ptr interface:
fairmq::UnmanagedRegion, TransportFactory, Socket, Poller, Message
These classes need to be movable/copyable:
MyClass (test suite helper), fairmq::Channel, fairmq::Parts
2021-09-27 12:04:07 +02:00
Alexey Rybalchenko
f33c597f34
Apply readability-avoid-const-params-in-decls
2021-09-27 12:04:07 +02:00
Dennis Klein
4e8f247a0d
fix: First round of using new non-namespaced typenames
2021-09-07 20:53:16 +02:00
Alexey Rybalchenko
4fdf9d340b
Fix stack-use-after-scope
2021-06-24 14:11:43 +02:00
Alexey Rybalchenko
882edbbdb8
Apply modernize-pass-by-value
2021-05-28 13:14:51 +02:00
Alexey Rybalchenko
c847a7ca02
Apply readability-container-size-empty
2021-05-28 13:14:51 +02:00
Alexey Rybalchenko
9444de5868
Apply readability-redundant-member-init
2021-05-28 13:14:51 +02:00
Alexey Rybalchenko
acf63d3c1b
Apply modernize-use-default-member-init
2021-05-28 13:14:51 +02:00
Alexey Rybalchenko
ccbd622130
Apply cppcoreguidelines-init-variables
2021-05-28 13:14:51 +02:00
Alexey Rybalchenko
857aa84fa3
add mlock/zero options to unmanaged region
2021-05-07 21:33:15 +02:00
Alexey Rybalchenko
c6a6a5f21b
Check transport type of msg and corresponding region
2021-05-07 21:33:15 +02:00
Alexey Rybalchenko
9defa71622
Add GetType() to UnmanagedRegion
2021-05-07 21:33:15 +02:00
Giulio Eulisse
6dfea32aee
Improve Events API
...
If the call is interrupted by a signal, this will throw, which we clearly do not want. Simplifying the API to let the user decide what to do on error is probably the best option.
2021-05-04 22:54:19 +02:00
Alexey Rybalchenko
4a09154a91
17-ify namespaces
2021-01-25 13:46:40 +01:00
Alexey Rybalchenko
d9a5e82160
Cleanup tools includes
2021-01-25 13:46:40 +01:00
Alexey Rybalchenko
751c53171c
Replace tools::make_unique with std::make_unique
2021-01-25 13:46:40 +01:00
Alexey Rybalchenko
6815c9c172
zmq: implement alignment
2021-01-13 12:36:32 +01:00
Alexey Rybalchenko
be94ceb7a7
zmq: simplify SetUsedSize implementation
2021-01-13 12:36:32 +01:00
Alexey Rybalchenko
afadbb53e4
zmq: correct accounting for msg size > 2GB
2021-01-13 12:36:32 +01:00
Alexey Rybalchenko
29f45fa77d
Rename TransferResult to TransferCode
2021-01-13 12:36:32 +01:00
Alexey Rybalchenko
bb1ce794b6
Let single message methods also return int64_t
2020-11-17 14:04:20 +01:00
Alexey Rybalchenko
6932f88c84
Adjust transfer methods behaviour when interrupted
...
A transer is attempted even if the transport has been interrupted
(with a timeout). When the timeout is reached, transfer methods will
return TransferResult::interrupted (-3).
2020-09-16 15:43:58 +02:00
Alexey Rybalchenko
266843cda5
Shm: initial multiple segments support
2020-09-08 16:56:35 +02:00
Alexey Rybalchenko
73109fe6d3
Shm: configurable allocation strategy
2020-09-08 16:56:35 +02:00
Alexey Rybalchenko
690e8a0370
Retry on EINTR in blocking zmq calls
2020-08-28 18:22:03 +02:00
Giulio Eulisse
e8cc104344
Add API to extract ZMQ_EVENTS from socket backend
2020-07-15 12:09:54 +02:00
Alexey Rybalchenko
afe2dcaa02
BenchmarkSampler: add memset option
2020-06-29 14:44:49 +02:00
Alexey Rybalchenko
aeab9e5407
Socket.h: refactor to reduce duplicate code
2020-06-29 14:44:49 +02:00
Alexey Rybalchenko
3364da9541
Add linger setting for unmanaged region
2020-06-29 14:44:49 +02:00
Alexey Rybalchenko
79ca436b74
Zmq: let GetData of an empty message return nullptr
2020-06-05 18:16:13 +02:00
Giulio Eulisse
dd47b34e06
Add ability to retrieve ZMQ_FD
2020-06-03 19:44:00 +02:00
Alexey Rybalchenko
53a4d17f8b
Alignment part I - Interface and shmem send
2020-05-20 19:34:27 +02:00
Alexey Rybalchenko
b56e32eb11
Replace exit()s with exceptions
2020-05-18 14:32:19 +02:00
Alexey Rybalchenko
4b516de81a
Minor formatting
2020-05-18 14:32:19 +02:00
Alexey Rybalchenko
361fb0cba5
Zmq: refactor to use namespaces
2020-05-18 14:32:19 +02:00
Alexey Rybalchenko
df574c6466
Zmq: header only
2020-05-18 14:32:19 +02:00
Alexey Rybalchenko
dbdabd23a4
Zmq: remove global (static) state, refactor
2020-05-18 14:32:19 +02:00
Alexey Rybalchenko
7a67719a3c
Remove useless members
2020-05-18 14:32:19 +02:00
Alexey Rybalchenko
d22023bcb5
Implement bulk callbacks for unmanaged regions
2020-05-18 14:32:19 +02:00
