proxmox-mirrors/proxmox-backup-qemu
1
0
Fork 0
mirror of https://git.proxmox.com/git/proxmox-backup-qemu synced 2025-10-05 03:11:50 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

proxmox_backup_connect: return info about previous backup

Browse Source
This commit is contained in:
Dietmar Maurer 2020-06-29 09:34:18 +02:00
parent 598e872f87
commit fabeaf9cf1
2 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/lib.rs
View File

@ -204,6 +204,11 @@ pub extern "C" fn proxmox_backup_new(
} }
/// Open connection to the backup server (sync) /// Open connection to the backup server (sync)
///
/// Returns:
/// 0 ... Sucecss (no prevbious backup)
/// 1 ... Success (found previous backup)
/// -1 ... Error
#[no_mangle] #[no_mangle]
#[allow(clippy::not_unsafe_ptr_arg_deref)] #[allow(clippy::not_unsafe_ptr_arg_deref)]
pub extern "C" fn proxmox_backup_connect( pub extern "C" fn proxmox_backup_connect(
@ -234,6 +239,11 @@ pub extern "C" fn proxmox_backup_connect(
} }
/// Open connection to the backup server /// Open connection to the backup server
///
/// Returns:
/// 0 ... Sucecss (no prevbious backup)
/// 1 ... Success (found previous backup)
/// -1 ... Error
#[no_mangle] #[no_mangle]
#[allow(clippy::not_unsafe_ptr_arg_deref)] #[allow(clippy::not_unsafe_ptr_arg_deref)]
pub extern "C" fn proxmox_backup_connect_async( pub extern "C" fn proxmox_backup_connect_async(

8
src/worker_task.rs
View File

@ -159,14 +159,18 @@ fn backup_worker_task(
let last_manifest = writer.download_previous_manifest().await; let last_manifest = writer.download_previous_manifest().await;
let mut manifest_guard = manifest.lock().unwrap(); let mut manifest_guard = manifest.lock().unwrap();
let mut result = 0;
*manifest_guard = match last_manifest { *manifest_guard = match last_manifest {
Ok(last_manifest) => Some(Arc::new(last_manifest)), Ok(last_manifest) => {
result = 1;
Some(Arc::new(last_manifest))
},
Err(_) => None Err(_) => None
}; };
let mut client_guard = client.lock().unwrap(); let mut client_guard = client.lock().unwrap();
*client_guard = Some(writer); *client_guard = Some(writer);
Ok(0) Ok(result)
}; };
tokio::spawn(handle_async_command(command_future, abort.listen(), callback_info)); tokio::spawn(handle_async_command(command_future, abort.listen(), callback_info));