xref: /unit/src/nxt_fs.c (revision 2216:231b36f0062c)
1 /*
2  * Copyright (C) NGINX, Inc.
3  */
4 
5 #include <nxt_main.h>
6 
7 
8 static nxt_int_t nxt_fs_mkdir(const u_char *dir, mode_t mode);
9 
10 
11 nxt_int_t
nxt_fs_mkdir_all(const u_char * dir,mode_t mode)12 nxt_fs_mkdir_all(const u_char *dir, mode_t mode)
13 {
14     char    *start, *end, *dst;
15     size_t  dirlen;
16     char    path[PATH_MAX];
17 
18     dirlen = nxt_strlen(dir);
19 
20     nxt_assert(dirlen < PATH_MAX && dirlen > 1 && dir[0] == '/');
21 
22     dst = path;
23     start = end = (char *) dir;
24 
25     while (*start != '\0') {
26         if (*start == '/') {
27             *dst++ = *start++;
28         }
29 
30         end = strchr(start, '/');
31         if (end == NULL) {
32             end = ((char *)dir + dirlen);
33         }
34 
35         dst = nxt_cpymem(dst, start, end - start);
36         *dst = '\0';
37 
38         if (nxt_slow_path(nxt_fs_mkdir((u_char *) path, mode) != NXT_OK
39                           && nxt_errno != EEXIST))
40         {
41             return NXT_ERROR;
42         }
43 
44         start = end;
45     }
46 
47     return NXT_OK;
48 }
49 
50 
51 nxt_int_t
nxt_fs_mkdir_parent(const u_char * path,mode_t mode)52 nxt_fs_mkdir_parent(const u_char *path, mode_t mode)
53 {
54     char       *ptr, *dir;
55     nxt_int_t  ret;
56 
57     dir = nxt_strdup(path);
58     if (nxt_slow_path(dir == NULL)) {
59         return NXT_ERROR;
60     }
61 
62     ret = NXT_OK;
63 
64     ptr = strrchr(dir, '/');
65     if (nxt_fast_path(ptr != NULL)) {
66         *ptr = '\0';
67         ret = nxt_fs_mkdir((const u_char *) dir, mode);
68     }
69 
70     nxt_free(dir);
71 
72     return ret;
73 }
74 
75 
76 static nxt_int_t
nxt_fs_mkdir(const u_char * dir,mode_t mode)77 nxt_fs_mkdir(const u_char *dir, mode_t mode)
78 {
79     if (nxt_fast_path(mkdir((const char *) dir, mode) == 0)) {
80         return NXT_OK;
81     }
82 
83     return NXT_ERROR;
84 }
85