#include "ed25519/sha512.h"
#include "discovery.h"
#include "devtools.h"
+#include "graph.h"
#ifndef MSG_NOSIGNAL
#define MSG_NOSIGNAL 0
return finalize_join(mesh, msg, len);
case 1:
- logger(mesh, MESHLINK_DEBUG, "Invitation succesfully accepted.\n");
+ logger(mesh, MESHLINK_DEBUG, "Invitation successfully accepted.\n");
shutdown(mesh->sock, SHUT_RDWR);
mesh->success = true;
break;
pthread_cond_wait(&mesh->cond, &mesh->mutex);
mesh->threadstarted = true;
- mesh->self->last_reachable = time(NULL);
- mesh->self->status.dirty = true;
+
+ // Ensure we are considered reachable
+ graph(mesh);
pthread_mutex_unlock(&mesh->mutex);
return true;
pthread_mutex_lock(&mesh->mutex);
logger(mesh, MESHLINK_DEBUG, "meshlink_stop called\n");
- if(mesh->self) {
- mesh->self->last_unreachable = time(NULL);
- mesh->self->status.dirty = true;
- }
-
// Shut down the main thread
event_loop_stop(&mesh->loop);
exit_outgoings(mesh);
+ // Ensure we are considered unreachable
+ if(mesh->nodes) {
+ graph(mesh);
+ }
+
// Try to write out any changed node config files, ignore errors at this point.
if(mesh->nodes) {
for splay_each(node_t, n, mesh->nodes) {
bool reachable;
pthread_mutex_lock(&mesh->mutex);
- reachable = n->status.reachable;
+ reachable = n->status.reachable && !n->status.blacklisted;
if(last_reachable) {
*last_reachable = n->last_reachable;
// If we changed our own host config file, write it out now
if(mesh->self->status.dirty) {
if(!node_write_config(mesh, mesh->self)) {
- logger(mesh, MESHLINK_ERROR, "Could not write our own host conifg file!\n");
+ logger(mesh, MESHLINK_ERROR, "Could not write our own host config file!\n");
pthread_mutex_unlock(&mesh->mutex);
return NULL;
}
n->mtuprobes = 0;
n->status.udp_confirmed = false;
+ if(n->status.reachable) {
+ n->last_unreachable = mesh->loop.now.tv_sec;
+ }
+
/* Graph updates will suppress status updates for blacklisted nodes, so we need to
* manually call the status callback if necessary.
*/
n->status.blacklisted = false;
if(n->status.reachable) {
+ n->last_reachable = mesh->loop.now.tv_sec;
update_node_status(mesh, n);
}