8423a57c36df8fd67b445c3ff76ecc9b2afd8db6
[project/fstools.git] / libfstools / overlay.c
1 /*
2  * Copyright (C) 2014 John Crispin <blogic@openwrt.org>
3  *
4  * This program is free software; you can redistribute it and/or modify
5  * it under the terms of the GNU Lesser General Public License version 2.1
6  * as published by the Free Software Foundation
7  *
8  * This program is distributed in the hope that it will be useful,
9  * but WITHOUT ANY WARRANTY; without even the implied warranty of
10  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11  * GNU General Public License for more details.
12  */
13
14 #include <sys/stat.h>
15 #include <sys/types.h>
16 #include <sys/mount.h>
17
18 #include <asm/byteorder.h>
19
20 #include <errno.h>
21 #include <string.h>
22 #include <stdio.h>
23 #include <unistd.h>
24 #include <stdlib.h>
25 #include <glob.h>
26 #include <errno.h>
27 #include <dirent.h>
28 #include <fcntl.h>
29
30 #include "libfstools.h"
31 #include "volume.h"
32
33 #define SWITCH_JFFS2 "/tmp/.switch_jffs2"
34
35 static bool keep_sysupgrade;
36
37 static int
38 handle_rmdir(const char *dir)
39 {
40         struct dirent *dt;
41         struct stat st;
42         DIR *d;
43         int fd;
44
45         d = opendir(dir);
46         if (!d)
47                 return -1;
48
49         fd = dirfd(d);
50
51         while ((dt = readdir(d)) != NULL) {
52                 if (fstatat(fd, dt->d_name, &st, AT_SYMLINK_NOFOLLOW) || S_ISDIR(st.st_mode))
53                         continue;
54
55                 if (keep_sysupgrade && !strcmp(dt->d_name, "sysupgrade.tgz"))
56                         continue;
57
58                 unlinkat(fd, dt->d_name, 0);
59         }
60
61         closedir(d);
62         rmdir(dir);
63
64         return 0;
65 }
66
67 void
68 foreachdir(const char *dir, int (*cb)(const char*))
69 {
70         struct stat s = { 0 };
71         char globdir[256];
72         glob_t gl;
73         int j;
74
75         if (dir[strlen(dir) - 1] == '/')
76                 snprintf(globdir, 256, "%s*", dir);
77         else
78                 snprintf(globdir, 256, "%s/*", dir); /**/
79
80         if (!glob(globdir, GLOB_NOESCAPE | GLOB_MARK | GLOB_ONLYDIR, NULL, &gl))
81                 for (j = 0; j < gl.gl_pathc; j++) {
82                         char *dir = gl.gl_pathv[j];
83                         int len = strlen(gl.gl_pathv[j]);
84
85                         if (len > 1 && dir[len - 1] == '/')
86                                 dir[len - 1] = '\0';
87
88                         if (!lstat(gl.gl_pathv[j], &s) && !S_ISLNK(s.st_mode))
89                                 foreachdir(gl.gl_pathv[j], cb);
90         }
91         cb(dir);
92 }
93
94 void
95 overlay_delete(const char *dir, bool _keep_sysupgrade)
96 {
97         keep_sysupgrade = _keep_sysupgrade;
98         foreachdir(dir, handle_rmdir);
99 }
100
101 static int
102 overlay_mount(struct volume *v, char *fs)
103 {
104         if (mkdir("/tmp/overlay", 0755)) {
105                 ULOG_ERR("failed to mkdir /tmp/overlay: %m\n");
106                 return -1;
107         }
108
109         if (mount(v->blk, "/tmp/overlay", fs, MS_NOATIME, NULL)) {
110                 ULOG_ERR("failed to mount -t %s %s /tmp/overlay: %m\n", fs, v->blk);
111                 return -1;
112         }
113
114         return 0;
115 }
116
117 static int
118 switch2jffs(struct volume *v)
119 {
120         struct stat s;
121         int ret;
122
123         if (!stat(SWITCH_JFFS2, &s)) {
124                 ULOG_ERR("jffs2 switch already running\n");
125                 return -1;
126         }
127
128         creat("/tmp/.switch_jffs2", 0600);
129         ret = mount(v->blk, "/rom/overlay", "jffs2", MS_NOATIME, NULL);
130         unlink("/tmp/.switch_jffs2");
131         if (ret) {
132                 ULOG_ERR("failed - mount -t jffs2 %s /rom/overlay: %m\n", v->blk);
133                 return -1;
134         }
135
136         if (mount("none", "/", NULL, MS_NOATIME | MS_REMOUNT, 0)) {
137                 ULOG_ERR("failed - mount -o remount,ro none: %m\n");
138                 return -1;
139         }
140
141         if (system("cp -a /tmp/root/* /rom/overlay")) {
142                 ULOG_ERR("failed - cp -a /tmp/root/* /rom/overlay: %m\n");
143                 return -1;
144         }
145
146         if (pivot("/rom", "/mnt")) {
147                 ULOG_ERR("failed - pivot /rom /mnt: %m\n");
148                 return -1;
149         }
150
151         if (mount_move("/mnt", "/tmp/root", "")) {
152                 ULOG_ERR("failed - mount -o move /mnt /tmp/root %m\n");
153                 return -1;
154         }
155
156         return fopivot("/overlay", "/rom");
157 }
158
159 int
160 handle_whiteout(const char *dir)
161 {
162         struct stat s;
163         char link[256];
164         ssize_t sz;
165         struct dirent **namelist;
166         int n;
167
168         n = scandir(dir, &namelist, NULL, NULL);
169
170         if (n < 1)
171                 return -1;
172
173         while (n--) {
174                 char file[256];
175
176                 snprintf(file, sizeof(file), "%s%s", dir, namelist[n]->d_name);
177                 if (!lstat(file, &s) && S_ISLNK(s.st_mode)) {
178                         sz = readlink(file, link, sizeof(link) - 1);
179                         if (sz > 0) {
180                                 char *orig;
181
182                                 link[sz] = '\0';
183                                 orig = strstr(&file[1], "/");
184                                 if (orig && !strcmp(link, "(overlay-whiteout)"))
185                                         unlink(orig);
186                         }
187                 }
188                 free(namelist[n]);
189         }
190         free(namelist);
191
192         return 0;
193 }
194
195 static char *overlay_fs_name(int type)
196 {
197         switch (type) {
198                 case FS_EXT4:
199                         return "ext4";
200                 case FS_F2FS:
201                         return "f2fs";
202                 case FS_UBIFS:
203                         return "ubifs";
204                 case FS_JFFS2:
205                 default:
206                         return "jffs2";
207         }
208 }
209
210 int
211 jffs2_switch(struct volume *v)
212 {
213         char *mp, *fs_name;
214         int type;
215
216         if (find_overlay_mount("overlayfs:/tmp/root"))
217                 return -1;
218
219         if (find_filesystem("overlay")) {
220                 ULOG_ERR("overlayfs not supported by kernel\n");
221                 return -1;
222         }
223
224         volume_init(v);
225         mp = find_mount_point(v->blk, 0);
226         if (mp) {
227                 ULOG_ERR("rootfs_data:%s is already mounted as %s\n", v->blk, mp);
228                 return -1;
229         }
230
231         type = volume_identify(v);
232         fs_name = overlay_fs_name(type);
233
234         switch (type) {
235         case FS_NONE:
236                 ULOG_ERR("no jffs2 marker found\n");
237                 /* fall through */
238
239         case FS_DEADCODE:
240                 if (switch2jffs(v))
241                         return -1;
242
243                 ULOG_INFO("performing overlay whiteout\n");
244                 umount2("/tmp/root", MNT_DETACH);
245                 foreachdir("/overlay/", handle_whiteout);
246
247                 /* try hard to be in sync */
248                 ULOG_INFO("syncronizing overlay\n");
249                 system("cp -a /tmp/root/upper/* / 2>/dev/null");
250                 break;
251
252         case FS_EXT4:
253         case FS_F2FS:
254         case FS_UBIFS:
255                 if (overlay_mount(v, fs_name))
256                         return -1;
257                 if (mount_move("/tmp", "", "/overlay") || fopivot("/overlay", "/rom")) {
258                         ULOG_ERR("switching to %s failed\n", fs_name);
259                         return -1;
260                 }
261                 break;
262         }
263
264         sync();
265         fs_state_set("/overlay", FS_STATE_READY);
266         return 0;
267 }
268
269 static int overlay_mount_fs(struct volume *v)
270 {
271         char *fstype = overlay_fs_name(volume_identify(v));
272
273         if (mkdir("/tmp/overlay", 0755)) {
274                 ULOG_ERR("failed to mkdir /tmp/overlay: %m\n");
275                 return -1;
276         }
277
278         if (mount(v->blk, "/tmp/overlay", fstype, MS_NOATIME, NULL)) {
279                 ULOG_ERR("failed to mount -t %s %s /tmp/overlay: %m\n",
280                          fstype, v->blk);
281                 return -1;
282         }
283
284         return 0;
285 }
286
287 enum fs_state fs_state_get(const char *dir)
288 {
289         char *path;
290         char valstr[16];
291         uint32_t val;
292         ssize_t len;
293
294         path = alloca(strlen(dir) + 1 + sizeof("/.fs_state"));
295         sprintf(path, "%s/.fs_state", dir);
296         len = readlink(path, valstr, sizeof(valstr) - 1);
297         if (len < 0)
298                 return FS_STATE_UNKNOWN;
299
300         valstr[len] = 0;
301         val = atoi(valstr);
302
303         if (val > __FS_STATE_LAST)
304                 return FS_STATE_UNKNOWN;
305
306         return val;
307 }
308
309
310 int fs_state_set(const char *dir, enum fs_state state)
311 {
312         char valstr[16];
313         char *path;
314
315         if (fs_state_get(dir) == state)
316                 return 0;
317
318         path = alloca(strlen(dir) + 1 + sizeof("/.fs_state"));
319         sprintf(path, "%s/.fs_state", dir);
320         unlink(path);
321         snprintf(valstr, sizeof(valstr), "%d", state);
322
323         return symlink(valstr, path);
324 }
325
326
327 int mount_overlay(struct volume *v)
328 {
329         char *mp, *fs_name;
330
331         if (!v)
332                 return -1;
333
334         mp = find_mount_point(v->blk, 0);
335         if (mp) {
336                 ULOG_ERR("rootfs_data:%s is already mounted as %s\n", v->blk, mp);
337                 return -1;
338         }
339
340         overlay_mount_fs(v);
341
342         extroot_prefix = "/tmp/overlay";
343         if (!mount_extroot()) {
344                 ULOG_INFO("switched to extroot\n");
345                 return 0;
346         }
347
348         switch(fs_state_get("/tmp/overlay")) {
349         case FS_STATE_UNKNOWN:
350                 fs_state_set("/tmp/overlay", FS_STATE_PENDING);
351                 if (fs_state_get("/tmp/overlay") != FS_STATE_PENDING) {
352                         ULOG_ERR("unable to set filesystem state\n");
353                         break;
354                 }
355         case FS_STATE_PENDING:
356                 ULOG_INFO("overlay filesystem has not been fully initialized yet\n");
357                 overlay_delete("/tmp/overlay", true);
358                 break;
359         case FS_STATE_READY:
360                 break;
361         }
362
363         fs_name = overlay_fs_name(volume_identify(v));
364         ULOG_INFO("switching to %s overlay\n", fs_name);
365         if (mount_move("/tmp", "", "/overlay") || fopivot("/overlay", "/rom")) {
366                 ULOG_ERR("switching to %s failed - fallback to ramoverlay\n", fs_name);
367                 return ramoverlay();
368         }
369
370         return -1;
371 }