Do not delete old store before the sync succeeds

4 files changed, 15 insertions, 10 deletions

diff --git a/src/libs6rc/s6rc_livedir_create.c b/src/libs6rc/s6rc_livedir_create.c
index 0fa4696..7695dfd 100644
--- a/src/libs6rc/s6rc_livedir_create.c
+++ b/src/libs6rc/s6rc_livedir_create.c
@@ -18,17 +18,20 @@ int s6rc_livedir_create (stralloc *sa, char const *live, char const *suffix, cha
 {
   size_t newlen, ddirlen ;
   size_t sabase = sa->len ;
+  mode_t m ;
   int wasnull = !sa->s ;
   if (!s6rc_sanitize_dir(sa, live, &ddirlen)) return 0 ;
   if (!stralloc_cats(sa, ":")) goto err ;
   if (!stralloc_cats(sa, suffix)) goto err ;
   if (!stralloc_cats(sa, ":XXXXXX")) goto err ;
   if (!stralloc_0(sa)) goto err ;
-  if (!mkdtemp(sa->s + sabase)) goto err ;
+  m = umask(0) ;
+  if (!mkdtemp(sa->s + sabase)) { umask(m) ; goto err ; }
   newlen = sa->len-- ;
+  if (!stralloc_catb(sa, "/servicedirs", 13)) { umask(m) ; goto delerr ; }  /* allocates enough for the next strcpys */
+  if (mkdir(sa->s + sabase, 0755) < 0) { umask(m) ; goto delerr ; }
+  umask(m) ;
   if (chmod(sa->s + sabase, 0755) < 0) goto delerr ;
-  if (!stralloc_catb(sa, "/servicedirs", 13)) goto delerr ;  /* allocates enough for the next strcpys */
-  if (mkdir(sa->s + sabase, 0755) < 0) goto delerr ;
   strcpy(sa->s + newlen, "compiled") ;
   if (symlink(compiled, sa->s + sabase) < 0) goto delerr ;
   strcpy(sa->s + newlen, "scandir") ;
diff --git a/src/libs6rc/s6rc_repo_makestores.c b/src/libs6rc/s6rc_repo_makestores.c
index 5568ec5..f61f94c 100644
--- a/src/libs6rc/s6rc_repo_makestores.c
+++ b/src/libs6rc/s6rc_repo_makestores.c
@@ -15,19 +15,17 @@
 
 #include <s6-rc/repo.h>
 
-int s6rc_repo_makestores (char const *repo, char const *const *stores, uint16_t n)
+int s6rc_repo_makestores (char const *repo, char const *const *stores, uint16_t n, char *sold)
 {
   size_t repolen = strlen(repo) ;
   mode_t m = umask(0) ;
   char slink[repolen + 8] ;
   char sdir[repolen + 21] ;
-  char sold[repolen + 16] ;
 
   memcpy(slink, repo, repolen) ;
   memcpy(slink + repolen, "/stores", 8) ;
   memcpy(sdir, slink, repolen + 1) ;
   memcpy(sdir + repolen + 1, ".stores:XXXXXX", 15) ;
-  memcpy(sold, slink, repolen + 1) ;
 
   if (!mkdtemp(sdir))
   {
@@ -54,12 +52,11 @@ int s6rc_repo_makestores (char const *repo, char const *const *stores, uint16_t
     strerr_warnfu2sys("chmod ", sdir) ;
     goto err ;
   }
-  if (!atomic_symlink4(sdir + repolen + 1, slink, sold + repolen + 1, 15))
+  if (!atomic_symlink4(sdir + repolen + 1, slink, sold, 15))
   {
     strerr_warnfu4sys("atomically symlink ", sdir + repolen + 1, " to ", slink) ;
     goto err ;
   }
-  rm_rf(sold) ;
   return 1 ;
 
  err:
diff --git a/src/libs6rc/s6rc_repo_sync.c b/src/libs6rc/s6rc_repo_sync.c
index df462ad..2ec1356 100644
--- a/src/libs6rc/s6rc_repo_sync.c
+++ b/src/libs6rc/s6rc_repo_sync.c
@@ -9,6 +9,7 @@
 #include <errno.h>
 
 #include <skalibs/uint16.h>
+#include <skalibs/stat.h>
 #include <skalibs/direntry.h>
 #include <skalibs/posixplz.h>
 #include <skalibs/strerr.h>
@@ -31,6 +32,7 @@ static inline void cleanup (char const *ato, char const *bun)
 int s6rc_repo_sync (char const *repo, unsigned int verbosity, char const *fdhuser)
 {
   size_t repolen = strlen(repo) ;
+  mode_t m ;
   char store[repolen + 13] ;
   char ato[repolen + 26] ;
   char bun[repolen + 26] ;
@@ -46,14 +48,17 @@ int s6rc_repo_sync (char const *repo, unsigned int verbosity, char const *fdhuse
   memcpy(ato + repolen, "/sources/..atomics:XXXXXX", 26) ;
   memcpy(bun, ato, repolen + 26) ;
   memcpy(bun + repolen + 11, "bundle", 6) ;
+  m = umask(0) ;
   if (!mkdtemp(ato))
   {
     strerr_warnfu2sys("mkdtemp ", ato) ;
+    umask(m) ;
     return 0 ;
   }
   if (chmod(ato, 02755) == -1)
   {
     strerr_warnfu2sys("chmod ", ato) ;
+    umask(m) ;
     return 0 ;
   }
 
@@ -61,8 +66,10 @@ int s6rc_repo_sync (char const *repo, unsigned int verbosity, char const *fdhuse
   {
     strerr_warnfu2sys("mkdtemp ", bun) ;
     rmdir(ato) ;
+    umask(m) ;
     return 0 ;
   }
+  umask(m) ;
   if (chmod(bun, 02755) == -1)
   {
     strerr_warnfu2sys("chmod ", bun) ;
diff --git a/src/libs6rc/s6rc_repo_syncset_tmp.c b/src/libs6rc/s6rc_repo_syncset_tmp.c
index d9bb358..b555bc2 100644
--- a/src/libs6rc/s6rc_repo_syncset_tmp.c
+++ b/src/libs6rc/s6rc_repo_syncset_tmp.c
@@ -1,7 +1,5 @@
 /* ISC license. */
 
-#include <skalibs/nonposix.h>  /* mkdtemp */
-
 #include <string.h>
 #include <stdint.h>
 #include <unistd.h>