From 169eb0c0e94c696e3ff1faf46a2c2e16862ed399 Mon Sep 17 00:00:00 2001
From: Thomas Schoebel-Theuer <tst@1und1.de>
Date: Wed, 3 Jan 2018 06:47:16 +0100
Subject: [PATCH] main: trigger systemd

---
 kernel/sy_old/mars_main.c  | 27 ++++++++++++++++++++++++++-
 kernel/sy_old/sy_generic.c |  2 +-
 2 files changed, 27 insertions(+), 2 deletions(-)

diff --git a/kernel/sy_old/mars_main.c b/kernel/sy_old/mars_main.c
index 97821b97..b32da32e 100644
--- a/kernel/sy_old/mars_main.c
+++ b/kernel/sy_old/mars_main.c
@@ -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;
 }
 
diff --git a/kernel/sy_old/sy_generic.c b/kernel/sy_old/sy_generic.c
index b87cb3f3..683a1645 100644
--- a/kernel/sy_old/sy_generic.c
+++ b/kernel/sy_old/sy_generic.c
@@ -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);