Commit Graph

194 Commits

Author SHA1 Message Date
babic_a d49df10e69 Working on the loop logic 2020-05-11 11:48:17 +02:00
babic_a cd25fe50b8 Rewrite logic to be function oriented 2020-05-11 11:39:18 +02:00
babic_a 5beb8a3c35 Transition to local variables instead of pointers 2020-05-11 11:23:11 +02:00
babic_a 4b64e56ccb Remove unused import from sf_buffer 2020-05-11 11:17:01 +02:00
babic_a b9f912b4a1 First iteration of code merge 2020-05-11 11:16:39 +02:00
Dmitry Ozerov dd3d5a80c4 correctly fill number of requested pulses in output file, stop in receiver before buffer is filled, if number of pulses is less then buffer 2020-05-10 00:01:41 +02:00
Dmitry Ozerov 85c0fff417 Merge branch 'master' of https://github.com/paulscherrerinstitute/sf_daq_buffer 2020-05-09 23:27:58 +02:00
Dmitry Ozerov 8c33c9cc98 wait that receiver thread is finished, is_good_fame check added, poor man current pulse_id script 2020-05-09 23:25:46 +02:00
babic_a 4912bbe38d Adjust settings to new config 2020-05-08 14:25:01 +02:00
babic_a e097e38365 Remove DEBUG_OUTPUT as its not very useful 2020-05-08 13:59:36 +02:00
babic_a ed2bcab1ba Wait forever until the writer gets all the packets 2020-05-08 11:49:56 +02:00
babic_a 30a267bfdd Revert back 2020-05-08 11:41:41 +02:00
babic_a fd33f72a09 Invert bind and connect among replay and writer 2020-05-08 11:39:36 +02:00
babic_a 6ff82c4b09 Fix current pulse_id increase 2020-05-08 11:33:39 +02:00
babic_a ea909d1e7e Merge remote-tracking branch 'origin/master' 2020-05-07 17:00:29 +02:00
babic_a da4108832d Pass start_pulse_id to recv thread and check pulses 2020-05-07 17:00:23 +02:00
Dmitry Ozerov 65aefd1a90 add base directory path to buffer 2020-05-07 16:41:27 +02:00
babic_a 77feefd681 Comment out SWMR code
We will keep it for a bit longer for reference.
2020-05-07 09:57:19 +02:00
Dmitry Ozerov 40b8d91c6d sf_stream sending to streamvis/live analysis 2020-05-06 22:47:05 +02:00
babic_a f0c50d89af Remove printouts 2020-05-06 16:05:11 +02:00
babic_a 90e6b06208 Debug output 2020-05-06 12:06:07 +02:00
babic_a b2d14fbb64 Remove recv code and put in a module 2020-05-06 10:00:09 +02:00
Dmitry Ozerov 8fb9fe4e3c intermediate ersion of sf_stream to read directly from sf_buffer 2020-05-04 19:08:50 +02:00
babic_a 6f766746d6 Thread fine-tuning 2020-05-04 18:37:41 +02:00
babic_a a8eacb3587 Yield at the end of the write loop 2020-05-04 18:11:50 +02:00
babic_a 16847f48b8 Changed all IPCs to /tmp folder 2020-05-04 15:27:50 +02:00
babic_a 1324e7b3e8 Adjusted sf_replay to new buffer format 2020-05-04 15:20:23 +02:00
babic_a a5c2d939bf Adjust sending part of sf_replay to new way of writing 2020-05-04 15:03:35 +02:00
babic_a 17d469d75e Fix start parameters for sf_buffer 2020-05-04 14:40:49 +02:00
babic_a d1d0cbdb94 Add n_corrupted_frames to sf_buffer metric 2020-05-04 14:12:01 +02:00
babic_a 261d4751e5 Rename buffer writer 2020-05-04 12:50:33 +02:00
babic_a b811dab937 Make buffer even simpler 2020-05-04 12:49:11 +02:00
babic_a c443fc8d96 Changed usage to better suit the current case 2020-05-04 12:47:14 +02:00
babic_a 48c320ffb8 Cast source_id to the correct type 2020-05-04 12:45:10 +02:00
babic_a 145cb82bbf Add source_id to the packet 2020-05-04 12:35:24 +02:00
babic_a aeb998cd4d Make sf_buffer code more compact 2020-05-04 12:32:32 +02:00
babic_a a2e609c47b Update UDP Module interface 2020-05-04 10:13:26 +02:00
babic_a bf62169fb9 Change sf_buffer to new fast queue 2020-05-04 09:56:22 +02:00
babic_a 5fc22620d9 Merge remote-tracking branch 'origin/master' into compression 2020-05-04 09:25:57 +02:00
babic_a e7ffad0592 SF buffer should bind 2020-05-04 09:18:44 +02:00
babic_a 487efb3f01 Extend sf_buffer with streaming capabilities 2020-05-04 09:16:49 +02:00
babic_a 5f8b889887 added stream for live analysis to test 2020-05-04 09:08:24 +02:00
babic_a 5221d53f36 in case of missing completely frame, don't raise exception 2020-05-04 09:07:27 +02:00
Dmitry Ozerov b484b45b88 working version of sf_stream (sends to streamvis assembled frame) 2020-05-01 14:20:16 +02:00
babic_a 8cf8d3e7d2 Close file at end 2020-05-01 13:56:08 +02:00
babic_a 7418cd3613 Improve interface for caching data from file 2020-05-01 13:09:09 +02:00
babic_a b71a2af0ed Made interface more simple for sf_live 2020-05-01 13:05:37 +02:00
babic_a 0810b67f5a Remove useless imports 2020-05-01 12:52:50 +02:00
babic_a 2f95c599ba Adjust interface for LiveH5Reader 2020-05-01 12:52:22 +02:00
babic_a c1f31b3c0f Merge remote-tracking branch 'origin/master' into compression 2020-05-01 12:41:55 +02:00