Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

data_sink supporting continuous/triggered/multiplexed/snapshot acquisition (polling/callback) #80

Merged
merged 64 commits into from
Jul 3, 2023
Merged

data_sink supporting continuous/triggered/multiplexed/snapshot acquisition (polling/callback) #80

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
64 commits
Select commit Hold shift + click to select a range
ab210da
data_sink with preliminary streaming callback/polling
frankosterfeld May 30, 2023
45a9070
Add data_sink_registry
frankosterfeld Jun 6, 2023
d52b91e
Registry: Query sinks when requesting callback/poller
frankosterfeld Jun 7, 2023
aa41dd9
Fix warnings and hopefully clang/emscripten compilation
frankosterfeld Jun 7, 2023
cb53a7f
Simplify data_sink/data_sink_registry
frankosterfeld Jun 7, 2023
486517d
Remove obsolete comment
frankosterfeld Jun 7, 2023
ec59eee
Lock mutex
frankosterfeld Jun 7, 2023
03aeb73
Let's test with two pollers
frankosterfeld Jun 8, 2023
550e9e7
Make test stricter
frankosterfeld Jun 8, 2023
196e36e
Fix listener handling
frankosterfeld Jun 12, 2023
86f62f5
WIP Add support for Triggered/PostMortem
frankosterfeld Jun 8, 2023
3758bcd
Minor fixes, remove ranges usage
frankosterfeld Jun 13, 2023
a3f3b03
Fix compilation and tests
frankosterfeld Jun 13, 2023
8310359
Continuous callback: Enforce fixed chunk size
frankosterfeld Jun 14, 2023
1128356
Support triggered mode with callbacks
frankosterfeld Jun 14, 2023
238af2c
Unify pollers for T and DataSet<T>
frankosterfeld Jun 14, 2023
3cca5eb
Process blocking listeners last
frankosterfeld Jun 15, 2023
3998933
Refactor listeners
frankosterfeld Jun 15, 2023
b0253e4
Add Multiplexed listener mode
frankosterfeld Jun 16, 2023
c79e6c7
Add snapshot mode
frankosterfeld Jun 17, 2023
1e22db0
Add distinct null_type to denote that there's no callback
frankosterfeld Jun 18, 2023
dcfc755
Tests: Use future more to pass received data
frankosterfeld Jun 18, 2023
c6e9893
Continuous/callback: Optionally pass tags
frankosterfeld Jun 19, 2023
7a858db
Pass tags via span
frankosterfeld Jun 19, 2023
260a428
ASCII art
frankosterfeld Jun 19, 2023
284a58d
Allow querying sinks by name or signal name
frankosterfeld Jun 19, 2023
a6e1c9d
Make sure we can handle all data we receive in a work() call
frankosterfeld Jun 19, 2023
edf1752
Simplify listeners, make tag indices relative
frankosterfeld Jun 19, 2023
2635a67
fix drop count logic
frankosterfeld Jun 21, 2023
2203762
Continuous/polling: Pass tags, too
frankosterfeld Jun 22, 2023
75d9e55
Adapt to tag refactoring
frankosterfeld Jun 22, 2023
61c6199
Fix logic errors for small chunk sizes
frankosterfeld Jun 22, 2023
550e450
Set tags in test source in the intended way
frankosterfeld Jun 22, 2023
9a29152
Run clang-format
frankosterfeld Jun 22, 2023
2a1d12a
continuous/poller: Write tags before data
frankosterfeld Jun 22, 2023
1034cad
Speed up test (most relevant in debug mode)
frankosterfeld Jun 23, 2023
ae69795
No need to recreate history if capacity is sufficient...
frankosterfeld Jun 23, 2023
0ca59e5
Clean up order and naming
frankosterfeld Jun 26, 2023
298f583
try to build with emscripten
frankosterfeld Jun 26, 2023
2dfe377
Delete expired listeners from list
frankosterfeld Jun 26, 2023
040b9ef
Fix some of Ralph's findings
frankosterfeld Jun 26, 2023
b4bd1dc
More docs, make blocking the default
frankosterfeld Jun 26, 2023
7b1784d
Adapt to Ivan's comments
frankosterfeld Jun 27, 2023
c55bf58
Fix ASCII art
frankosterfeld Jun 27, 2023
b9b1c88
apply clang-format
frankosterfeld Jun 27, 2023
3676ecb
Remove TriggerObserverFactory
frankosterfeld Jun 27, 2023
7478c87
Add concepts for callbacks
frankosterfeld Jun 27, 2023
02d4924
Simplify/Unify TagObserver/Predicate
frankosterfeld Jun 27, 2023
09f73aa
Make sample rate configurable via settings
frankosterfeld Jun 27, 2023
c8e43cc
Add signal info handling
frankosterfeld Jun 27, 2023
b77ca5d
Remove dataset_poller's process_one
frankosterfeld Jun 27, 2023
2581d60
remove obsolete TODOs
frankosterfeld Jun 28, 2023
c5bfc27
adapt to rebase
frankosterfeld Jun 28, 2023
af6eb4c
Test sink lookup by signal name
frankosterfeld Jun 28, 2023
f2b1e83
Unify TriggerObserver and TriggerPredicate to TriggerMatcher
frankosterfeld Jun 28, 2023
150304e
Call stop() on destruction
frankosterfeld Jun 28, 2023
3603b6d
Add TODOs
frankosterfeld Jun 28, 2023
3f92af8
cleanup detail
frankosterfeld Jun 28, 2023
df8a52f
Optionally pass sink to streaming callback
frankosterfeld Jun 28, 2023
9fb8158
Basic tests for multiplexed/callback and snapshot/callback
frankosterfeld Jun 28, 2023
8c29984
Make test source not produce single samples
frankosterfeld Jul 1, 2023
7181a19
Fix off-by-one error in continuous/callback chunk-ification
frankosterfeld Jul 1, 2023
5c1d766
don't copy history if none is needed
frankosterfeld Jul 1, 2023
64dfd40
Fix available_samples signature
frankosterfeld Jul 3, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Loading