1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
/* ISC license. */
#include <sys/types.h>
#include <sys/stat.h>
#include <errno.h>
#include <skalibs/bytestr.h>
#include <skalibs/strerr2.h>
#include <skalibs/djbunix.h>
#include <s6/s6-supervise.h>
int s6_supervise_lock_mode (char const *subdir, unsigned int subdirmode, unsigned int controlmode)
{
size_t subdirlen = str_len(subdir) ;
int fdctl, fdctlw, fdlock ;
char control[subdirlen + 9] ;
char lock[subdirlen + 6] ;
byte_copy(control, subdirlen, subdir) ;
byte_copy(control + subdirlen, 9, "/control") ;
byte_copy(lock, subdirlen, subdir) ;
byte_copy(lock + subdirlen, 6, "/lock") ;
if ((mkdir(subdir, (mode_t)subdirmode) == -1) && (errno != EEXIST))
strerr_diefu2sys(111, "mkdir ", subdir) ;
if (mkfifo(control, controlmode) < 0)
{
struct stat st ;
if (errno != EEXIST)
strerr_diefu2sys(111, "mkfifo ", control) ;
if (stat(control, &st) < 0)
strerr_diefu2sys(111, "stat ", control) ;
if (!S_ISFIFO(st.st_mode))
strerr_diefu2x(100, control, " is not a FIFO") ;
}
fdlock = open_create(lock) ;
if (fdlock < 0)
strerr_diefu2sys(111, "open_create ", lock) ;
if (lock_ex(fdlock) < 0)
strerr_diefu2sys(111, "lock ", lock) ;
fdctlw = open_write(control) ;
if (fdctlw >= 0) strerr_dief1x(100, "directory already locked") ;
if (errno != ENXIO)
strerr_diefu2sys(111, "open_write ", control) ;
fdctl = open_read(control) ;
if (fdctl < 0)
strerr_diefu2sys(111, "open_read ", control) ;
fdctlw = open_write(control) ;
if (fdctlw < 0)
strerr_diefu2sys(111, "open_write ", control) ;
fd_close(fdlock) ;
if ((coe(fdctlw) < 0) || (coe(fdctl) < 0))
strerr_diefu2sys(111, "coe ", control) ;
return fdctl ;
/* fdctlw is leaking. That's okay, it's coe. */
}
|
