3 files changed, 16 insertions, 4 deletions

diff --git a/ecp/src/ecp/core.c b/ecp/src/ecp/core.c
index 1e24d0b..77017df 100644
--- a/ecp/src/ecp/core.c
+++ b/ecp/src/ecp/core.c
@@ -190,7 +190,7 @@ static int conn_table_insert(ECPConnection *conn) {
 
         for (i=0; i<ECP_MAX_CONN_KEY; i++) {
             if (conn->key[i].valid) {
-                rv = ecp_ht_insert(sock->conn_table.keys, &conn->key[i].public, conn);
+                rv = ecp_ht_insert_uniq(sock->conn_table.keys, &conn->key[i].public, conn);
                 if (rv) {
                     int j;
 
@@ -209,7 +209,7 @@ static int conn_table_insert(ECPConnection *conn) {
     } else {
         for (i=0; i<ECP_MAX_NODE_KEY; i++) {
             if (conn->rkey[i].valid) {
-                rv = ecp_ht_insert(sock->conn_table.keys, &conn->rkey[i].public, conn);
+                rv = ecp_ht_insert_uniq(sock->conn_table.keys, &conn->rkey[i].public, conn);
                 if (rv) {
                     int j;
 
@@ -726,7 +726,7 @@ static int conn_dhkey_new(ECPConnection *conn, unsigned char idx, ECPDHKey *key)
     if (ecp_conn_is_outb(conn) && _ecp_conn_is_reg(conn)) {
         int rv;
 
-        rv = ecp_ht_insert(sock->conn_table.keys, &conn->key[idx].public, conn);
+        rv = ecp_ht_insert_uniq(sock->conn_table.keys, &conn->key[idx].public, conn);
         if (rv) return rv;
     }
 #endif
@@ -824,7 +824,7 @@ static int conn_dhkey_set_pub(ECPConnection *conn, unsigned char idx, ecp_ecdh_p
     if (ecp_conn_is_inb(conn) && _ecp_conn_is_reg(conn)) {
         int rv;
 
-        rv = ecp_ht_insert(sock->conn_table.keys, &key->public, conn);
+        rv = ecp_ht_insert_uniq(sock->conn_table.keys, &key->public, conn);
         if (rv) return rv;
     }
 #endif
diff --git a/ecp/src/ecp/ht.h b/ecp/src/ecp/ht.h
index 805fbda..9b0ac30 100644
--- a/ecp/src/ecp/ht.h
+++ b/ecp/src/ecp/ht.h
@@ -3,6 +3,7 @@ ecp_ht_table_t *ecp_ht_create_addrs(void);
 
 void ecp_ht_destroy(ecp_ht_table_t *h);
 int ecp_ht_insert(ecp_ht_table_t *h, void *k, void *v);
+int ecp_ht_insert_uniq(ecp_ht_table_t *h, void *k, void *v);
 void *ecp_ht_remove(ecp_ht_table_t *h, void *k);
 void *ecp_ht_remove_kv(ecp_ht_table_t *h, void *k, void *v);
 void *ecp_ht_search(ecp_ht_table_t *h, void *k);
diff --git a/ecp/src/ecp/htable/htable.c b/ecp/src/ecp/htable/htable.c
index c22d2ab..85a9339 100644
--- a/ecp/src/ecp/htable/htable.c
+++ b/ecp/src/ecp/htable/htable.c
@@ -25,6 +25,17 @@ int ecp_ht_insert(ecp_ht_table_t *h, void *k, void *v) {
     return ECP_OK;
 }
 
+int ecp_ht_insert_uniq(ecp_ht_table_t *h, void *k, void *v) {
+    int rv;
+    void *p;
+
+    p = hashtable_search(h, k);
+    if (p) return ECP_ERR_DUP;
+    rv = hashtable_insert(h, k, v);
+    if (rv == 0) return ECP_ERR;
+    return ECP_OK;
+}
+
 void *ecp_ht_remove(ecp_ht_table_t *h, void *k) {
     return hashtable_remove(h, k);
 }