diff options
| author | ozpv <39195175+ozpv@users.noreply.github.com> | 2026-05-16 03:06:33 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2026-05-16 03:06:33 -0500 |
| commit | 31b83a1daf401e41a1c73484c0aec3016b795e3f (patch) | |
| tree | 85c06870b172d11a0602f21ddb2bf3c25c686997 /src/params.rs | |
| parent | 7901b970d14c86d00a80347471bf8e071d39b83e (diff) | |
latency
Diffstat (limited to 'src/params.rs')
| -rw-r--r-- | src/params.rs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/params.rs b/src/params.rs index b7e6676..00782ba 100644 --- a/src/params.rs +++ b/src/params.rs @@ -218,11 +218,12 @@ impl RetainParamsLocal { } } +/// To save the plugin state (parameter values) using protocol buffers #[derive(Message)] struct PluginState { - #[prost(uint64, tag = "0")] - order: u64, #[prost(uint64, tag = "1")] + order: u64, + #[prost(uint64, tag = "2")] window_size: u64, } @@ -261,7 +262,7 @@ impl PluginStateImpl for RetainPluginMainThread<'_> { fn load(&mut self, input: &mut InputStream) -> Result<(), PluginError> { let mut data = vec![]; - input.read_exact(&mut data)?; + input.read_to_end(&mut data)?; let data = PluginState::decode(&data[..])?; |
