ipcpd: Check for duplicate RO in flat addr policy

1 files changed, 11 insertions, 0 deletions

diff --git a/src/ipcpd/normal/pol/flat.c b/src/ipcpd/normal/pol/flat.c
index 8a0570f8..82c7db93 100644
--- a/src/ipcpd/normal/pol/flat.c
+++ b/src/ipcpd/normal/pol/flat.c
@@ -238,12 +238,22 @@ uint64_t flat_address(void)
                 }
 
                 pthread_mutex_lock(&flat.lock);
+
+                if (ro_exists(ro_name)) {
+                        pthread_mutex_unlock(&flat.lock);
+                        free(ro_name);
+                        free(buf);
+                        continue;
+                }
+
+
                 if (ro_create(ro_name, &attr, buf, sizeof(*msg))) {
                         pthread_mutex_unlock(&flat.lock);
                         free(ro_name);
                         free(buf);
                         return INVALID_ADDR;
                 }
+
                 free(ro_name);
 
                 while (flat.addr_in_use == false) {
@@ -253,6 +263,7 @@ uint64_t flat_address(void)
                         if (ret == -ETIMEDOUT)
                                 break;
                 }
+
                 pthread_mutex_unlock(&flat.lock);
         }