[pbs-devel] [PATCH proxmox-backup] task tracking: fix adding new entry if other PID is tracked

[Samuel Rufinatscha]

Looks good to me!

Reviewed-by: Samuel Rufinatscha <s.rufinatscha at proxmox.com>

On 11/12/25 2:15 PM, Fabian Grünbichler wrote:
> if the tracking file contains an entry for another, still running PID, that
> entry must be preserved, but a new entry for the current PID should still be
> inserted..
> 
> Signed-off-by: Fabian Grünbichler <f.gruenbichler at proxmox.com>
> ---
> found while benchmarking Samuel's datastore lookup caching series..
> 
>   pbs-datastore/src/task_tracking.rs | 4 +++-
>   1 file changed, 3 insertions(+), 1 deletion(-)
> 
> diff --git a/pbs-datastore/src/task_tracking.rs b/pbs-datastore/src/task_tracking.rs
> index 77851cab6..44a4522dc 100644
> --- a/pbs-datastore/src/task_tracking.rs
> +++ b/pbs-datastore/src/task_tracking.rs
> @@ -108,6 +108,7 @@ pub fn update_active_operations(
>           Operation::Write => ActiveOperationStats { read: 0, write: 1 },
>           Operation::Lookup => ActiveOperationStats { read: 0, write: 0 },
>       };
> +    let mut found_entry = false;
>       let mut updated_tasks: Vec<TaskOperations> = match file_read_optional_string(&path)? {
>           Some(data) => serde_json::from_str::<Vec<TaskOperations>>(&data)?
>               .iter_mut()
> @@ -116,6 +117,7 @@ pub fn update_active_operations(
>                       Some(stat) if pid == task.pid && stat.starttime != task.starttime => None,
>                       Some(_) => {
>                           if pid == task.pid {
> +                            found_entry = true;
>                               match operation {
>                                   Operation::Read => task.active_operations.read += count,
>                                   Operation::Write => task.active_operations.write += count,
> @@ -132,7 +134,7 @@ pub fn update_active_operations(
>           None => Vec::new(),
>       };
>   
> -    if updated_tasks.is_empty() {
> +    if !found_entry {
>           updated_tasks.push(TaskOperations {
>               pid,
>               starttime,