miegl/mud
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Cleanup path after a 1min silence

Browse Source 
Signed-off-by: Adrien Gallouët <adrien@gallouet.fr>
This commit is contained in:
Adrien Gallouët
2020-01-02 15:04:40 +00:00
parent ef41aa28ce
commit a87a277701
1 changed files with 18 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
mud.c
View File

@@ -571,13 +571,6 @@ mud_reset_path(struct mud_path *path)
path->mtu.probe = 0; path->mtu.probe = 0;
} }
static void
mud_remove_path(struct mud_path *path)
{
memset(path, 0, sizeof(struct mud_path));
path->state = MUD_EMPTY;
}
static struct mud_path * static struct mud_path *
mud_get_path(struct mud *mud, struct sockaddr_storage *local_addr, mud_get_path(struct mud *mud, struct sockaddr_storage *local_addr,
struct sockaddr_storage *addr, int create) struct sockaddr_storage *addr, int create)
@@ -1397,6 +1390,23 @@ mud_recv(struct mud *mud, void *data, size_t size)
return MUD_MSG(sent_time) ? 0 : ret; return MUD_MSG(sent_time) ? 0 : ret;
} }
static int
mud_cleanup_path(struct mud *mud, uint64_t now, struct mud_path *path)
{
if (path->state < MUD_DOWN)
return 1;
if (mud->peer.set && path->state > MUD_DOWN)
return 0;
if (mud_timeout(now, path->rx.time, MUD_ONE_MIN)) {
memset(path, 0, sizeof(struct mud_path));
path->state = MUD_EMPTY;
}
return path->state <= MUD_DOWN;
}
static int static int
mud_update(struct mud *mud) mud_update(struct mud *mud)
{ {
@@ -1413,16 +1423,7 @@ mud_update(struct mud *mud)
for (unsigned i = 0; i < mud->count; i++) { for (unsigned i = 0; i < mud->count; i++) {
struct mud_path *path = &mud->paths[i]; struct mud_path *path = &mud->paths[i];
if (path->state < MUD_DOWN) if (mud_cleanup_path(mud, now, path))
continue;
if ((path->state == MUD_DOWN || !mud->peer.set) &&
(mud_timeout(now, path->rx.time, 10 * MUD_ONE_SEC))) {
mud_remove_path(path);
continue;
}
if (path->state <= MUD_DOWN)
continue; continue;
path->ok = 0; path->ok = 0;