rmdir(dirname);
}
-static bool sync_path(const char *pathname) {
+bool sync_path(const char *pathname) {
assert(pathname);
int fd = open(pathname, O_RDONLY);
return true;
}
- if(mkdir(mesh->confbase, 0700) && errno != EEXIST) {
- logger(mesh, MESHLINK_DEBUG, "Could not create directory %s: %s\n", mesh->confbase, strerror(errno));
- return false;
- }
-
char path[PATH_MAX];
// Create "current" sub-directory in the confbase
assert(conf_subdir);
if(!confbase) {
- return false;
+ return true;
}
struct stat st;
return confbase_exists;
}
-/// Lock the main configuration file.
+/// Lock the main configuration file. Creates confbase if necessary.
bool main_config_lock(meshlink_handle_t *mesh) {
if(!mesh->confbase) {
return true;
}
+ if(mkdir(mesh->confbase, 0700) && errno != EEXIST) {
+ logger(NULL, MESHLINK_ERROR, "Cannot create configuration directory %s: %s", mesh->confbase, strerror(errno));
+ meshlink_close(mesh);
+ meshlink_errno = MESHLINK_ESTORAGE;
+ return NULL;
+ }
+
char path[PATH_MAX];
- make_main_path(mesh, "current", path, sizeof(path));
+ snprintf(path, sizeof(path), "%s" SLASH "meshlink.lock", mesh->confbase);
- mesh->conffile = fopen(path, "r");
+ mesh->lockfile = fopen(path, "w+");
- if(!mesh->conffile) {
+ if(!mesh->lockfile) {
logger(NULL, MESHLINK_ERROR, "Cannot not open %s: %s\n", path, strerror(errno));
meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
#ifdef FD_CLOEXEC
- fcntl(fileno(mesh->conffile), F_SETFD, FD_CLOEXEC);
+ fcntl(fileno(mesh->lockfile), F_SETFD, FD_CLOEXEC);
#endif
#ifdef HAVE_MINGW
// TODO: use _locking()?
#else
- if(flock(fileno(mesh->conffile), LOCK_EX | LOCK_NB) != 0) {
+ if(flock(fileno(mesh->lockfile), LOCK_EX | LOCK_NB) != 0) {
logger(NULL, MESHLINK_ERROR, "Cannot lock %s: %s\n", path, strerror(errno));
- fclose(mesh->conffile);
- mesh->conffile = NULL;
+ fclose(mesh->lockfile);
+ mesh->lockfile = NULL;
meshlink_errno = MESHLINK_EBUSY;
return false;
}
/// Unlock the main configuration file.
void main_config_unlock(meshlink_handle_t *mesh) {
- if(mesh->conffile) {
- fclose(mesh->conffile);
- mesh->conffile = NULL;
+ if(mesh->lockfile) {
+ fclose(mesh->lockfile);
+ mesh->lockfile = NULL;
}
}
if(chacha_poly1305_encrypt_iv96(ctx, seqbuf, config->buf, config->len, buf, &len)) {
success = fwrite(seqbuf, sizeof(seqbuf), 1, f) == 1 && fwrite(buf, len, 1, f) == 1;
+
+ if(!success) {
+ logger(mesh, MESHLINK_ERROR, "Cannot write config file: %s", strerror(errno));
+ }
+
+ meshlink_errno = MESHLINK_ESTORAGE;
} else {
logger(mesh, MESHLINK_ERROR, "Cannot encrypt config file\n");
meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
+ if(fflush(f)) {
+ logger(mesh, MESHLINK_ERROR, "Failed to flush file: %s", strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
+ return false;
+ }
+
if(fsync(fileno(f))) {
logger(mesh, MESHLINK_ERROR, "Failed to sync file: %s\n", strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
if(!f) {
logger(mesh, MESHLINK_ERROR, "Failed to open `%s': %s", tmp_path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
return false;
}
- if(fsync(fileno(f))) {
- logger(mesh, MESHLINK_ERROR, "Failed to sync `%s': %s", tmp_path, strerror(errno));
- fclose(f);
- return false;
- }
-
if(fclose(f)) {
logger(mesh, MESHLINK_ERROR, "Failed to close `%s': %s", tmp_path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
if(rename(tmp_path, path)) {
logger(mesh, MESHLINK_ERROR, "Failed to rename `%s' to `%s': %s", tmp_path, path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
if(!f) {
logger(mesh, MESHLINK_ERROR, "Failed to open `%s': %s", tmp_path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
return false;
}
- if(fsync(fileno(f))) {
- logger(mesh, MESHLINK_ERROR, "Failed to sync `%s': %s", tmp_path, strerror(errno));
- fclose(f);
- return false;
- }
-
if(rename(tmp_path, path)) {
logger(mesh, MESHLINK_ERROR, "Failed to rename `%s' to `%s': %s", tmp_path, path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
fclose(f);
return false;
}
if(fclose(f)) {
logger(mesh, MESHLINK_ERROR, "Failed to close `%s': %s", tmp_path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
fclose(f);
- unlink(used_path);
+ if(unlink(used_path)) {
+ logger(mesh, MESHLINK_ERROR, "Failed to unlink `%s': %s", path, strerror(errno));
+ return false;
+ }
+
+ snprintf(path, sizeof(path), "%s" SLASH "%s" SLASH "invitations", mesh->confbase, conf_subdir);
+
+ if(!sync_path(path)) {
+ logger(mesh, MESHLINK_ERROR, "Failed to sync `%s': %s", path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
+ return false;
+ }
+
return true;
}
if(!f) {
logger(mesh, MESHLINK_ERROR, "Failed to open `%s': %s", path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
return false;
}
- if(fsync(fileno(f))) {
- logger(mesh, MESHLINK_ERROR, "Failed to sync `%s': %s", path, strerror(errno));
- fclose(f);
+ if(fclose(f)) {
+ logger(mesh, MESHLINK_ERROR, "Failed to close `%s': %s", path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
return false;
}
- if(fclose(f)) {
- logger(mesh, MESHLINK_ERROR, "Failed to close `%s': %s", path, strerror(errno));
+ snprintf(path, sizeof(path), "%s" SLASH "%s" SLASH "invitations", mesh->confbase, conf_subdir);
+
+ if(!sync_path(path)) {
+ logger(mesh, MESHLINK_ERROR, "Failed to sync `%s': %s", path, strerror(errno));
+ meshlink_errno = MESHLINK_ESTORAGE;
return false;
}