lin-epics-modules/StreamGenerator
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

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
Conversation 0 Commits 35 Files Changed 17
+1942 -346
wall_e commented 2025-11-14 14:11:01 +01:00
Owner
Copy Link
Copy Source
No description provided.
wall_e added 35 commits 2025-11-14 14:11:01 +01:00
POC for each interface type b810509156
progress with parsing and kafka c2ca5f699c
adds external dependency versions 2d5a43c09a
can send ess streaming data types flatbuffer messages via kafka 2d065a0db9
adds information on how to build dependencies for the project 09ba30025a
very inefficient, but can receive udp monitor events and count them and send them as kafka events 4c1741bd4b
can receive both monitor and detector udp events and send them to different kafka topics 750436732c
reorganises and cleans up some parts of the code d7bf3977fc
removes old python variant b9e5f40c21
adds a POC preset based count 1e853487aa
adds elapsed time and time based preset 7bacc716cc
adds remaining missing PVs a336ca74c9
moves more options to ioc function e65725609c
working on correcting the ordering of the messages 81bd3bef7f
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 60aa1652c3
can send kafka messages again and can set the broker and topics in the start command 2c47f338c2
can stop count and clear channels ecc6e98f4c
adds a simple rate calculation 1ce7f93e95
check for udp packets being missed 056b0a5f8a
slow rate updates 70c04af034
no pointers, just bytes buffers of fixed size e5cb019143
not 100% this rate calculation is right, but might be better than before? 617dd3153b
comments on time overflow 2ccf37ce33
in the process of switching to a more batch processing approach. so far, seems like it can keep up 5f95e82a3c
finished converting the processing to a batch-wise variant e53a2a4f40
use local mirrors 2f50a21e83
use ssh variant... 318357127e
adds comment on cloning with depdencies 9d5ed11dac
adds additional key that can be set 18da14f6d6
adds PV for number of missed udp packets 6faf23601e
adds a udp config that works with the correlation unit 8f8b78a9bf
returns elapsed time as a double 77ed74a203
shows queue usage as a percentage ba07a8af9b
does removing all logic in the udp receive thread help to improve the packet receive frequency? c530de3566
change counts to 64 bit integer, improve broken packet check, correct order of updating status 9d93238db4
wall_e merged commit 9bfaabdd99 into main 2025-11-14 14:11:18 +01:00
wall_e deleted branch less_logic_in_udp_thread 2025-11-14 14:11:18 +01:00
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
No items
No labels
Milestone
No items
No Milestone
Projects
Clear projects
No projects
Assignees
Clear assignees
mathis_s (mathis_s) mueller_r4 (mueller_r4) plank_a (plank_a) ponsin_h (ponsin_h) schlienger_s (schlienger_s) soederqvist_a (soederqvist_a) wall_e (wall_e)
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: lin-epics-modules/StreamGenerator#1