[pbs-devel] [PATCH proxmox-backup 3/4] bin: proxy: initialize concurrency semaphores for datastores

[Hannes Laimer]

... which have a `concurrency_limit` configured.

Signed-off-by: Hannes Laimer <h.laimer at proxmox.com>
---
 src/bin/proxmox-backup-proxy.rs | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/src/bin/proxmox-backup-proxy.rs b/src/bin/proxmox-backup-proxy.rs
index cfd93f92..1678be66 100644
--- a/src/bin/proxmox-backup-proxy.rs
+++ b/src/bin/proxmox-backup-proxy.rs
@@ -251,6 +251,17 @@ async fn run() -> Result<(), Error> {
     let acceptor = make_tls_acceptor()?;
     let acceptor = Arc::new(Mutex::new(acceptor));
 
+    // create concurrent tasks semaphore
+    let (config, _digest) = pbs_config::datastore::config()?;
+    let all_stores: Vec<DataStoreConfig> = config.convert_to_typed_array("datastore")?;
+    for store in all_stores {
+        let sem_name = format!("/{}_concurrent", store.name);
+        let _ = proxmox_sys::semaphore::PosixSemaphore::unlink(&sem_name);
+        if let Some(c) = store.concurrency_limit {
+            let _ = proxmox_sys::semaphore::PosixSemaphore::create(&sem_name, 0o600, c);
+        }
+    }
+
     // to renew the acceptor we just add a command-socket handler
     command_sock.register_command("reload-certificate".to_string(), {
         let acceptor = Arc::clone(&acceptor);
-- 
2.47.2