synchronized updateCache

vatesfr · Sep 9, 2022 · f5b4889 · f5b4889
1 parent eca6244
commit f5b4889
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/@xen-orchestra/backups/RemoteAdapter.js b/@xen-orchestra/backups/RemoteAdapter.js
@@ -233,7 +233,7 @@ class RemoteAdapter {
       )
     )) {
       // detached async action, will not reject
-      this.#updateCache(dir + '/cache.json.gz', backups => {
+      this._updateCache(dir + '/cache.json.gz', backups => {
         for (const filename of filenames) {
           delete backups[filename]
         }
@@ -490,7 +490,9 @@ class RemoteAdapter {
     }
   }
 
-  async #updateCache(path, fn) {
+  _updateCache = synchronized.withKey()(this._updateCache)
+  // eslint-disable-next-line no-dupe-class-members
+  async _updateCache(path, fn) {
     const cache = await this.#readCache(path)
     if (cache !== undefined) {
       fn(cache)
@@ -612,7 +614,7 @@ class RemoteAdapter {
     })
 
     // will not throw
-    this.#updateCache(this.#getVmBackupsCache(vmUuid), backups => {
+    this._updateCache(this.#getVmBackupsCache(vmUuid), backups => {
       backups[path] = {
         ...metadata,