78 Commits

Author	SHA1	Message	Date
Alexey Rybalchenko	bb1ce794b6	Let single message methods also return int64_t	2020-11-17 14:04:20 +01:00
Alexey Rybalchenko	1b30f3ac14	Update return types in ofi::Socket	2020-09-23 09:29:57 +02: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
Giulio Eulisse	bf909f94dc	ofi: adapt to the new API for FairMQSocket::Events	2020-07-15 13:58:47 +02:00
Alexey Rybalchenko	53a4d17f8b	Alignment part I - Interface and shmem send	2020-05-20 19:34:27 +02:00
Alexey Rybalchenko	d22023bcb5	Implement bulk callbacks for unmanaged regions	2020-05-18 14:32:19 +02:00
Alexey Rybalchenko	c8fc5ad33f	Add bool FairMQTransportFactory::SubscribedToRegionEvents()	2020-05-11 12:02:19 +02:00
Alexey Rybalchenko	9992811822	Implement region events for zmq	2020-05-11 12:02:19 +02:00
Alexey Rybalchenko	e1a113aabe	Add region events subscriptions	2020-04-28 14:09:04 +02:00
Alexey Rybalchenko	a2cff5b7bb	Shmem: simplify message/socket and refactor to use namespaces	2019-12-20 14:04:58 +01:00
Alexey Rybalchenko	cba6d19781	Add config plugin class.	2019-07-10 19:35:18 +02:00
Alexey Rybalchenko	0e35f1cb22	Shmem region: support huge pages via path to hugetlbfs mount	2019-07-05 15:58:28 +02:00
Dennis Klein	3582091b1c	Add experimental static size mode for ofi transport ... Whenever --ofi-size-hint > 0, the ofi transport does not use the control band. Multipart is not supported.	2019-04-29 20:28:40 +02:00
Dennis Klein	195644f132	Add some debug output	2019-03-21 18:03:32 +01:00
Dennis Klein	cc8fd73025	Fix recv logic	2019-03-21 18:03:32 +01:00
Dennis Klein	b45e4da2a9	Implement linger for ofi ... This reduces test runtime significantly for most transports	2019-03-21 18:03:32 +01:00
Dennis Klein	a1b7efa2f4	Unify implementation of multi part and single part message interfaces	2019-03-21 18:03:32 +01:00
Dennis Klein	6ee7e5fbf0	Improve error handling	2019-03-21 18:03:32 +01:00
Dennis Klein	a8f1a4dfdb	Try to reconnect on refused connection	2019-03-13 18:04:49 +01:00
Dennis Klein	fb42b1e2f0	Adapt to new asiofi release	2019-03-13 18:04:49 +01:00
Dennis Klein	3bf5f3bf45	Reformat	2019-03-06 14:23:08 +01:00
Dennis Klein	11a3a41a0f	Add missing memory registration case	2019-03-06 14:23:08 +01:00
Dennis Klein	53a5456d8c	Fix lifetime of memory_region	2019-03-06 14:23:08 +01:00
Dennis Klein	2eb09df1f7	Match consistent style	2019-03-06 14:23:08 +01:00
Dennis Klein	1752e116e3	Fix initialization of inproc queues	2019-03-06 14:23:08 +01:00
Dennis Klein	5eae5ccd31	Fix connection logic	2019-03-06 14:23:08 +01:00
Dennis Klein	ad198edd59	Remove asio strand	2019-03-06 14:23:08 +01:00
Dennis Klein	b3005ecbdc	Fix object lifetime bug	2019-03-06 14:23:08 +01:00
Dennis Klein	ee890a7a46	Implement Reset signal	2019-03-06 14:23:08 +01:00
Dennis Klein	241bf08337	Retry ofi connection	2019-03-06 14:23:08 +01:00
Dennis Klein	02e1511667	Fix issues after rebase	2019-03-06 14:23:08 +01:00
Dennis Klein	a08a34acd5	Do not share ofi context across sockets	2019-03-06 14:23:08 +01:00
Dennis Klein	b31ab1cc48	Implement control band with asiofi	2019-03-06 14:23:08 +01:00
Dennis Klein	672e12f45b	Add semaphore	2019-03-06 14:23:08 +01:00
Dennis Klein	8e7cfacd78	Implement parallel ofi::Socket::Receive	2019-03-06 14:23:08 +01:00
Dennis Klein	46e2420547	Implement parallel ofi::Socket::Send	2019-03-06 14:23:08 +01:00
Dennis Klein	60f1f1000f	Fix after rebase	2019-03-06 14:23:08 +01:00
Dennis Klein	b394feca18	Implement ofi Send/Receive	2019-03-06 14:23:08 +01:00
Dennis Klein	91025cbc88	Deactivate control band monitor socket	2019-03-06 14:23:08 +01:00
Dennis Klein	ba4e6f72c9	Implement connection mgmt	2019-03-06 14:23:08 +01:00
Dennis Klein	1c5d7ca46a	Reach compilable state with asiofi again	2019-03-06 14:23:08 +01:00
Dennis Klein	0ff8eaf84d	Fix package dependencies	2019-03-06 14:23:08 +01:00
Dennis Klein	03912e86f8	Drop protobuf dependencies	2019-03-06 14:23:08 +01:00
Alexey Rybalchenko	36f409dc72	Formatting	2019-02-25 12:19:50 +01:00
Alexey Rybalchenko	ee24144d61	Remove previously deprecated Copy method (since 1yr)	2018-11-28 21:16:29 +01:00
mkrzewic	cc0c525e0d	Set pointer to factory also when receiving multi-part	2018-11-27 14:36:35 +01:00
Alexey Rybalchenko	25fcf13985	Move Bind/Connect/Attach to FairMQChannel	2018-11-13 11:08:48 +01:00
Alexey Rybalchenko	ce4062f3a0	Remove GetSocket interface that exposes transport details	2018-10-17 13:28:50 +02:00
Alexey Rybalchenko	f8824335a5	Add setters/getters for socket options	2018-10-17 13:28:50 +02:00
Alexey Rybalchenko	dfa1b68867	Make factory classes final (optimization potential)	2018-10-17 13:28:50 +02:00