less_logic_in_udp_thread #1

Merged
wall_e merged 35 commits from less_logic_in_udp_thread into main 2025-11-14 14:11:18 +01:00

35 Commits

Author SHA1 Message Date
9d93238db4 change counts to 64 bit integer, improve broken packet check, correct order of updating status 2025-11-14 14:07:54 +01:00
c530de3566 does removing all logic in the udp receive thread help to improve the packet receive frequency? 2025-11-07 16:14:05 +01:00
ba07a8af9b shows queue usage as a percentage 2025-11-07 14:28:01 +01:00
77ed74a203 returns elapsed time as a double 2025-11-07 14:05:37 +01:00
8f8b78a9bf adds a udp config that works with the correlation unit 2025-11-07 13:20:15 +01:00
6faf23601e adds PV for number of missed udp packets 2025-11-07 09:00:53 +01:00
18da14f6d6 adds additional key that can be set 2025-11-06 16:48:31 +01:00
9d5ed11dac adds comment on cloning with depdencies 2025-11-06 15:38:33 +01:00
318357127e use ssh variant... 2025-11-06 15:36:40 +01:00
2f50a21e83 use local mirrors 2025-11-06 15:34:32 +01:00
e53a2a4f40 finished converting the processing to a batch-wise variant 2025-11-06 15:30:25 +01:00
5f95e82a3c in the process of switching to a more batch processing approach. so far, seems like it can keep up 2025-11-06 11:58:19 +01:00
2ccf37ce33 comments on time overflow 2025-11-05 10:13:08 +01:00
617dd3153b not 100% this rate calculation is right, but might be better than before? 2025-11-05 09:57:05 +01:00
e5cb019143 no pointers, just bytes buffers of fixed size 2025-11-05 09:25:01 +01:00
70c04af034 slow rate updates 2025-11-05 08:00:17 +01:00
056b0a5f8a check for udp packets being missed 2025-11-04 17:01:18 +01:00
1ce7f93e95 adds a simple rate calculation 2025-11-04 16:19:28 +01:00
ecc6e98f4c can stop count and clear channels 2025-11-04 15:31:28 +01:00
2c47f338c2 can send kafka messages again and can set the broker and topics in the start command 2025-11-04 13:56:44 +01:00
60aa1652c3 again at the point that I can do preset based counts, but now with the priority queue built in so that the events are sorted 2025-11-04 10:24:25 +01:00
81bd3bef7f working on correcting the ordering of the messages 2025-11-03 17:31:16 +01:00
e65725609c moves more options to ioc function 2025-11-03 13:29:01 +01:00
a336ca74c9 adds remaining missing PVs 2025-11-03 09:26:50 +01:00
7bacc716cc adds elapsed time and time based preset 2025-10-31 19:10:59 +01:00
1e853487aa adds a POC preset based count 2025-10-31 13:23:55 +01:00
b9e5f40c21 removes old python variant 2025-10-31 10:18:57 +01:00
d7bf3977fc reorganises and cleans up some parts of the code 2025-10-31 10:16:54 +01:00
750436732c can receive both monitor and detector udp events and send them to different kafka topics 2025-10-30 16:48:33 +01:00
4c1741bd4b very inefficient, but can receive udp monitor events and count them and send them as kafka events 2025-10-30 15:07:21 +01:00
09ba30025a adds information on how to build dependencies for the project 2025-10-30 14:02:42 +01:00
2d065a0db9 can send ess streaming data types flatbuffer messages via kafka 2025-10-30 13:53:00 +01:00
2d5a43c09a adds external dependency versions 2025-10-30 11:55:10 +01:00
c2ca5f699c progress with parsing and kafka 2025-10-30 11:51:16 +01:00
b810509156 POC for each interface type 2025-10-29 12:07:02 +01:00