X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;ds=sidebyside;f=src%2Fprotocol_edge.c;h=40172b9d92d20ba267b813c00aa1bb3cfcff15ec;hb=fe4cf1f57aa26458d1c2a9c44a06f9e49fe8d615;hp=c18319e0efdcdc776d30bcae971a17ad9837b037;hpb=ea294dac41365a08a77b64c62c0ba630292d7a07;p=meshlink diff --git a/src/protocol_edge.c b/src/protocol_edge.c index c18319e0..40172b9d 100644 --- a/src/protocol_edge.c +++ b/src/protocol_edge.c @@ -88,8 +88,9 @@ bool add_edge_h(meshlink_handle_t *mesh, connection_t *c, const char *request) { return false; } - if(seen_request(mesh, request)) + if(seen_request(mesh, request)) { return true; + } /* Lookup nodes */ @@ -137,8 +138,9 @@ bool add_edge_h(meshlink_handle_t *mesh, connection_t *c, const char *request) { edge_del(mesh, e); graph(mesh); } - } else + } else { return true; + } } else if(from == mesh->self) { logger(mesh, MESHLINK_WARNING, "Got %s from %s for ourself which does not exist", "ADD_EDGE", c->name); @@ -193,8 +195,9 @@ bool del_edge_h(meshlink_handle_t *mesh, connection_t *c, const char *request) { return false; } - if(seen_request(mesh, request)) + if(seen_request(mesh, request)) { return true; + } /* Lookup nodes */ @@ -247,6 +250,7 @@ bool del_edge_h(meshlink_handle_t *mesh, connection_t *c, const char *request) { if(!to->status.reachable) { e = lookup_edge(to, mesh->self); + if(e) { send_del_edge(mesh, mesh->everyone, e); edge_del(mesh, e);