1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-16 00:00:02 +01:00
Commit graph

2651 commits

Author SHA1 Message Date
Dennis Potter
2a1dc60d16 Changed configuration section of 2018-08-05 11:07:45 +02:00
Dennis Potter
71134a4c81 Node now already posts Work Receives if it accepts the connections.
Before, it waited until it is really connected. That caused problems,
because the send side will start immediately sending if it is connected.
Especially at high rates (>100k) this was a problem.
2018-08-04 17:34:52 +02:00
Dennis Potter
69c8f0adaa Added flag to enable/disable warning about missed steps 2018-08-04 17:27:06 +02:00
Dennis Potter
117913287d Added configurable setvbuf to output of file node 2018-08-04 15:20:21 +02:00
Dennis Potter
cdadbe8bcc Changed precision of offset to nanoseconds for csv. Fixes #189 2018-08-02 16:25:07 +02:00
Dennis Potter
2b52366627 Added pthread_testcancel() to path. Fixes #186 2018-08-02 16:24:05 +02:00
Dennis Potter
027555c34d Added flag in config to enable/disable connection fallback. Closes #188 2018-08-02 10:41:37 +02:00
Dennis Potter
aefe40dc35 Removed IMM mode. Replaced hard coded integers by constants 2018-08-01 18:26:42 +02:00
Sonja Kolen
a74644cea9 csv and villas.human formats: remove dynamic memory allocation 2018-08-01 16:45:54 +02:00
Sonja Kolen
9e5852233c Merge branch 'develop' of git.rwth-aachen.de:acs/public/villas/VILLASnode into develop 2018-08-01 14:42:40 +02:00
Sonja Kolen
796d3226be villas.human format: determine type of value (double or int) of received sample by checking for a dot in the value string 2018-08-01 14:42:30 +02:00
Sonja Kolen
f7a61e3f97 csv format: determine type of value (double or int) in received sample by checking for a dot in the value string 2018-08-01 14:40:50 +02:00
Sonja Kolen
89f4e9b768 json_format: fixed a bug, int values are now saved in the data.i field instead of data.f 2018-08-01 14:36:31 +02:00
f6c91f4ac9 file: fix assertion raised in file_destroy() when node was never started (closes #186) 2018-07-26 16:38:26 +02:00
Dennis Potter
b96a55237b Added pthread_testcancel() in ib_read()
As discussed in issue #186 and on IM. This function check every 2048th
cycle if the thread should be canceled.

This also removed the need for 'kill -9' in the integration test.
2018-07-26 15:46:41 +02:00
Dennis Potter
45ddebf5d1 Performance improvement for UDP
Before this commit, the Infiniband node recreated the address handle for
the remote node during every cycle. Now, it only creates it directly
after it got ah_attr.
2018-07-25 18:51:28 +02:00
Dennis Potter
49a92ffeaf Made in and out section optional for file node
This is discussed in the comment section of commit
d0f4513122
2018-07-25 18:13:01 +02:00
Dennis Potter
dfd694bdc2 Some small changes in default settings and warning 2018-07-25 16:22:34 +02:00
Dennis Potter
6b93b8839e Changed debug flag in node.c from LOG_NODES to LOG_NODE
Fixes #184.
2018-07-24 10:42:35 +02:00
Dennis Potter
f14ae5a9ef Moved call to memory_init() from api to super_node
Fixes #180.
2018-07-24 10:40:21 +02:00
Dennis Potter
eb80945699 Added missing curly bracket 2018-07-24 10:35:51 +02:00
Dennis Potter
df5ec2bcdf Added support for node type dependend memory types 2018-07-23 22:46:03 +02:00
Dennis Potter
dfa098f450 Merge branch 'develop' of git.rwth-aachen.de:acs/public/villas/VILLASnode into develop 2018-07-23 22:44:14 +02:00
Dennis Potter
427d715279 Fixed two minor bugs in Infiniband node 2018-07-23 16:52:38 +02:00
d0f4513122 file: implement in/out config sections 2018-07-23 16:07:47 +02:00
Dennis Potter
6296d4217e Added a few corrections for sample size
* Meta data was not included in the calculation which determines if
  sample should be send inline. This caused errors
* Meta data was not substracted from sample->length on receive side
2018-07-21 13:11:46 +02:00
Dennis Potter
64282b7134 Changed sequence type to uint64_t 2018-07-21 13:01:42 +02:00
Dennis Potter
591f9f73bd Added meta data in transfer
ib_write() and ib_read() now point to the sequence, ts_origin, and format
members of struct sample in a separate scatter/gather element each.

ib_read() measures the time with time_now() (from villas/timing.h) and
sets all flags at receive side.
2018-07-21 12:52:25 +02:00
Dennis Potter
2c3ddfd0c2 Merge branch 'ib-rearrange-qp' into develop
Closes #152. As described in #182, we will not rearrange the Queue Pairs
for connected mode. As soon as we test many-to-one connections for the
unrealiable connection, we will look again at this issue.
2018-07-21 12:14:25 +02:00
Dennis Potter
8704683bf2 Replaced send WC stack by queue 2018-07-21 12:07:43 +02:00
Dennis Potter
0e6d962c1a Merge branch 'ib-rearrange-qp' of git.rwth-aachen.de:acs/public/villas/VILLASnode into ib-rearrange-qp 2018-07-20 23:42:34 +02:00
Dennis Potter
a5068e28ea Replace sleep by a better check
Prior to this commit, we called rdma_disconnect() and waited for a fixed
amount of time. This check was kind of arbitrary. Now, we keep polling
the receive Completion Queue until ib->conn.available_recv_wrs is zero
and all receive samples are thus given back to the framework.
2018-07-20 23:40:43 +02:00
Dennis Potter
8029c47113 Fixed bug which arrised in afb8b57156 2018-07-20 23:34:52 +02:00
Dennis Potter
be87846a5a Fixed way of iterating scatter/gather list 2018-07-20 22:55:33 +02:00
Dennis Potter
afb8b57156 Removed option to manually add QP type
The QP type is dependend on the port space of the RDMA CM ID. If the
RDMA CM ID is set to TCP, the QP has to be set to a RC. If it is set to
UDP, it has to be set to UD.
2018-07-19 20:42:20 +02:00
Dennis Potter
3acc3df7c4 ib_read() now works for UDP
Node is now able to send data in RDMA_PS_UDP mode. Right now it creates
a new rdma_cm_id for every connection request. We could/should do this
differently
2018-07-19 20:33:41 +02:00
Dennis Potter
2b323c3781 Fixed a bug at the send side of UDP 2018-07-19 18:47:27 +02:00
Dennis Potter
cfa93292b0 Added support for RDMA_PS_UDP at send side 2018-07-19 18:32:06 +02:00
Dennis Potter
a2ee85bd52 Check if cfg actually exists before trying to parse logging 2018-07-19 15:25:46 +02:00
Dennis Potter
84f85e137d Added STATE_CONNECTED as valid state for node_read() & node_write() 2018-07-19 14:55:07 +02:00
Dennis Potter
bf8a86ff7d Fixed typo COMMAND 2018-07-19 14:52:39 +02:00
Sonja Kolen
aaf20934fd memory: Added a fallback to use mmap without hugepages in case mmap with hugepages fails; in case the fallback is used, a warning is provided to the user 2018-07-18 16:58:07 +02:00
Sonja Kolen
5a23e64f5e added check of memory allocation failure; added check of hash table insert failure; provide warning to the user in both cases 2018-07-18 15:15:08 +02:00
1e46313d49 fix defines for websocket support 2018-07-18 08:13:47 +02:00
583e3b730f utils: seperated print_{copyright,version}(), box and color parts of utils 2018-07-18 08:13:13 +02:00
Sonja Kolen
d66268b2f8 fixed indents 2018-07-17 11:38:17 +02:00
Sonja Kolen
6c99e45264 Multiple samples can be received in a single MQTT message (Fixes #178) 2018-07-17 11:20:38 +02:00
Dennis Potter
2bee7d24dd Added rdma_event_str()
This replaces the manual translation of enumerations in the switch
statements.
2018-07-17 11:10:05 +02:00
c58a127ca5 whitespace cleanup 2018-07-17 10:52:51 +02:00
280c20de94 websocket: fix format selection in client connections 2018-07-17 10:52:51 +02:00