Merge pull request #40 from rok4/develop

Release 1.4.0

Author: Dolite

.github/workflows/pr-auto-labeler.yml

@@ -1,6 +1,6 @@
 name: "🏷 PR Labeler"
 on:
-  - pull_request
+  - pull_request_target
 
 permissions:
   contents: read

CHANGELOG.md

@@ -1,3 +1,12 @@
+## 1.4.0
+
+### [Added]
+
+* Stockage objet (S3, Swift et Ceph) 
+    * Possibilité de définir un nombre de tentatives pour les lectures (1 par défaut) : variable d'environnement `ROK4_OBJECT_READ_ATTEMPTS` 
+    * Possibilité de définir un nombre de tentatives pour les écritures (1 par défaut) : variable d'environnement `ROK4_OBJECT_WRITE_ATTEMPTS` 
+    * Possibilité de définir un temps d'attente, en secondes, entre les tentatives (5 par défaut) : variable d'environnement `ROK4_OBJECT_ATTEMPTS_WAIT`
+
 ## 1.3.1
 
 ### [Fixed]
@@ -22,7 +31,7 @@
 
 ### [Fixed]
 
-* `Cache` : les modifications dans le cache quand il n'est pas par thread (index des dalles, TMS et styles) se font en xxclusion mutuelle (mutex lock et unlock)
+* `Cache` : les modifications dans le cache quand il n'est pas par thread (index des dalles, TMS et styles) se font en exclusion mutuelle (mutex lock et unlock)
 
 ## 1.2.3
 

README.md

@@ -46,6 +46,10 @@ Leur définition est contrôlée à l'usage.
     - `ROK4_TMS_NO_CACHE` : ne pas utiliser le système de cache pour le chargement des TMS (on recharge le TMS depuis le fichier / objet à chaque chargement de couche). Toute valeur désactivera le cache
     - `ROK4_STYLES_DIRECTORY` : dossier (fichier ou objet) contenant les styles. Le style `normal` sera chargé depuis le fichier/objet `<ROK4_STYLES_DIRECTORY>/normal.json`
     - `ROK4_STYLES_NO_CACHE` : ne pas utiliser le système de cache pour le chargement des styles (on recharge le style depuis le fichier / objet à chaque chargement de couche). Toute valeur désactivera le cache.
+* Pour le stockage objet (non obligatoire, possibilité de surcharger via des appels)
+    - `ROK4_OBJECT_READ_ATTEMPTS` : nombre de tentatives pour les lectures
+    - `ROK4_OBJECT_WRITE_ATTEMPTS` : nombre de tentatives pour les écritures
+    - `ROK4_OBJECT_ATTEMPTS_WAIT` : temps d'attente en secondes entre les tentatives
 * Pour le stockage S3
     - `ROK4_S3_URL`
     - `ROK4_S3_KEY`

include/rok4/storage/Context.h

@@ -55,6 +55,10 @@
 #include <string.h>
 #include <sstream>
 
+#define ROK4_OBJECT_READ_ATTEMPTS "ROK4_OBJECT_READ_ATTEMPTS"
+#define ROK4_OBJECT_WRITE_ATTEMPTS "ROK4_OBJECT_WRITE_ATTEMPTS"
+#define ROK4_OBJECT_ATTEMPTS_WAIT "ROK4_OBJECT_ATTEMPTS_WAIT"
+
 /**
  * \author Institut national de l'information géographique et forestière
  * \~french \brief Gestion des informations liées au format de canal
@@ -138,26 +142,68 @@ class Context {
     bool connected;
 
     /**
-     * \~french \brief Nombre de tentatives pour en lecture ou écriture
-     * \~english \brief Attempts number to read or write
+     * \~french \brief Nombre de tentatives pour en lecture
+     * \~english \brief Attempts number to read
+     */
+    int read_attempts;
+
+    /**
+     * \~french \brief Nombre de tentatives pour en écriture
+     * \~english \brief Attempts number to write
      */
-    int attempts;
+    int write_attempts;
+
+    /**
+     * \~french \brief Temps d'attente en secondes entre 2 tentatives
+     * \~english \brief Waiting time, in seconds between two attempts
+     */
+    int waiting_time;
 
     /**
      * \~french \brief Crée un objet Context
      * \~english \brief Create a Context object
      */
-    Context () : connected(false), attempts(1) {  }
+    Context ();
 
 public:
 
     /**
-     * \~french \brief Modifie le nombre de tentative
-     * \~english \brief Change attempts number
+     * \~french \brief Modifie le temps d'attente entre deux tentatives
+     * \param[in] t Temps en secondes
+     * \~english \brief Change waiting time between two attempts
+     * \param[in] t Time, in seconds
+     */
+    void setWaitingTime (int t) {
+        if (t < 0) t = 0;
+        waiting_time = t;
+    }
+
+    /**
+     * \~french \brief Modifie le nombre de tentative pour la lecture
+     * \~english \brief Change attempts number for readings
+     */
+    void setReadAttempts (int a) {
+        if (a < 1) a = 1;
+        read_attempts = a;
+    }
+
+    /**
+     * \~french \brief Modifie le nombre de tentative pour l'écriture
+     * \~english \brief Change attempts number for writtings
+     */
+    void setWriteAttempts (int a) {
+        if (a < 1) a = 1;
+        write_attempts = a;
+    }
+
+    /**
+     * \~french \brief Modifie le nombre de tentative pour l'écriture et la lecture
+     * \~english \brief Change attempts number for writtings and readings
      */
     void setAttempts (int a) {
         if (a < 1) a = 1;
-        attempts = a;
+        read_attempts = a;
+        write_attempts = a;
     }
 
     /**

src/storage/Context.cpp

@@ -110,3 +110,21 @@ void split_path(std::string path, ContextType::eContextType& type, std::string&
 }
 
 }
+
+Context::Context () : connected(false) {
+
+    char* e = getenv (ROK4_OBJECT_READ_ATTEMPTS);
+    if (e == NULL || sscanf ( e, "%d", &read_attempts ) != 1 ) {
+        read_attempts = 1;
+    }
+
+    e = getenv (ROK4_OBJECT_WRITE_ATTEMPTS);
+    if (e == NULL || sscanf ( e, "%d", &write_attempts ) != 1 ) {
+        write_attempts = 1;
+    }
+
+    e = getenv (ROK4_OBJECT_ATTEMPTS_WAIT);
+    if (e == NULL || sscanf ( e, "%d", &waiting_time ) != 1 ) {
+        waiting_time = 5;
+    }
+}