RepoMirrors/mars
1
0
Fork 0
mirror of https://github.com/schoebel/mars synced 2025-03-11 07:47:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

main: trigger systemd

Browse Source
This commit is contained in:
Thomas Schoebel-Theuer 2018-01-03 06:47:16 +01:00
parent 988457b65b
commit 169eb0c0e9
2 changed files with 27 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
kernel/sy_old/mars_main.c
View File

@ -1891,6 +1891,7 @@ int run_bone(struct mars_peerinfo *peer, struct mars_dent *remote_dent)
bool update_mtime = true;
bool update_ctime = true;
bool run_trigger = false;
bool run_systemd_trigger = false;
if (!strncmp(remote_dent->d_name, ".tmp", 4)) {
goto done;
@ -1961,6 +1962,11 @@ int run_bone(struct mars_peerinfo *peer, struct mars_dent *remote_dent)
__kuid_val(remote_dent->new_stat.uid));
MARS_DBG("create symlink '%s' -> '%s' status = %d\n", remote_dent->d_path, remote_dent->new_link, status);
run_trigger = true;
if (!status &&
(!strncmp(remote_dent->d_name, "primary", 7) ||
!strncmp(remote_dent->d_name, "systemd", 7)))
run_systemd_trigger = true;
}
} else if (S_ISREG(remote_dent->new_stat.mode) && _is_peer_logfile(remote_dent->d_name, my_id())) {
const char *parent_path = backskip_replace(remote_dent->d_path, '/', false, "");
@ -1986,6 +1992,8 @@ int run_bone(struct mars_peerinfo *peer, struct mars_dent *remote_dent)
done:
if (status >= 0) {
status = run_trigger ? 1 : 0;
if (run_systemd_trigger)
status |= 2;
}
return status;
}
@ -1997,6 +2005,7 @@ int run_bones(struct mars_peerinfo *peer)
struct list_head *tmp;
unsigned long flags;
bool run_trigger = false;
bool run_systemd_trigger = false;
int status = 0;
traced_lock(&peer->lock, flags);
@ -2013,8 +2022,11 @@ int run_bones(struct mars_peerinfo *peer)
}
MARS_IO("path = '%s'\n", remote_dent->d_path);
status = run_bone(peer, remote_dent);
if (status > 0)
if (status > 0) {
run_trigger = true;
if (status & 2)
run_systemd_trigger = true;
}
//MARS_DBG("path = '%s' worker status = %d\n", remote_dent->d_path, status);
}
@ -2023,6 +2035,19 @@ int run_bones(struct mars_peerinfo *peer)
if (run_trigger) {
mars_trigger();
}
if (run_systemd_trigger) {
struct file *f;
const int flags = O_RDWR | O_CREAT;
const int prot = 0600;
mm_segment_t oldfs;
oldfs = get_fs();
set_fs(get_ds());
f = filp_open("/mars/userspace/systemd-trigger", flags, prot);
set_fs(oldfs);
if (f && !IS_ERR(f))
filp_close(f, NULL);
}
return status;
}

2
kernel/sy_old/sy_generic.c
View File

@ -908,7 +908,7 @@ int ordered_symlink(const char *oldpath, const char *newpath, const struct times
struct kstat stat;
struct timespec now;
const char *marker_path;
int status = 0;
int status = 1;
if (!stamp) {
get_lamport(&now);