xref: /dflybsd-src/usr.sbin/makefs/hammer2/hammer2_ioctl.c (revision 6b47f3ea0add18fe433924e96d23c8a42f668f93)
1a63188c8STomohiro Kusumi /*
2a63188c8STomohiro Kusumi  * SPDX-License-Identifier: BSD-3-Clause
3a63188c8STomohiro Kusumi  *
4a63188c8STomohiro Kusumi  * Copyright (c) 2023 Tomohiro Kusumi <tkusumi@netbsd.org>
5a63188c8STomohiro Kusumi  * Copyright (c) 2011-2023 The DragonFly Project.  All rights reserved.
6a63188c8STomohiro Kusumi  *
7a63188c8STomohiro Kusumi  * This code is derived from software contributed to The DragonFly Project
8a63188c8STomohiro Kusumi  * by Matthew Dillon <dillon@dragonflybsd.org>
9a63188c8STomohiro Kusumi  *
10a63188c8STomohiro Kusumi  * Redistribution and use in source and binary forms, with or without
11a63188c8STomohiro Kusumi  * modification, are permitted provided that the following conditions
12a63188c8STomohiro Kusumi  * are met:
13a63188c8STomohiro Kusumi  *
14a63188c8STomohiro Kusumi  * 1. Redistributions of source code must retain the above copyright
15a63188c8STomohiro Kusumi  *    notice, this list of conditions and the following disclaimer.
16a63188c8STomohiro Kusumi  * 2. Redistributions in binary form must reproduce the above copyright
17a63188c8STomohiro Kusumi  *    notice, this list of conditions and the following disclaimer in
18a63188c8STomohiro Kusumi  *    the documentation and/or other materials provided with the
19a63188c8STomohiro Kusumi  *    distribution.
20a63188c8STomohiro Kusumi  * 3. Neither the name of The DragonFly Project nor the names of its
21a63188c8STomohiro Kusumi  *    contributors may be used to endorse or promote products derived
22a63188c8STomohiro Kusumi  *    from this software without specific, prior written permission.
23a63188c8STomohiro Kusumi  *
24a63188c8STomohiro Kusumi  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
25a63188c8STomohiro Kusumi  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
26a63188c8STomohiro Kusumi  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
27a63188c8STomohiro Kusumi  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE
28a63188c8STomohiro Kusumi  * COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
29a63188c8STomohiro Kusumi  * INCIDENTAL, SPECIAL, EXEMPLARY OR CONSEQUENTIAL DAMAGES (INCLUDING,
30a63188c8STomohiro Kusumi  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
31a63188c8STomohiro Kusumi  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
32a63188c8STomohiro Kusumi  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
33a63188c8STomohiro Kusumi  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
34a63188c8STomohiro Kusumi  * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
35a63188c8STomohiro Kusumi  * SUCH DAMAGE.
36a63188c8STomohiro Kusumi  */
37a63188c8STomohiro Kusumi /*
38a63188c8STomohiro Kusumi  * Ioctl Functions.
39a63188c8STomohiro Kusumi  *
40a63188c8STomohiro Kusumi  * WARNING! The ioctl functions which manipulate the connection state need
41a63188c8STomohiro Kusumi  *	    to be able to run without deadlock on the volume's chain lock.
42a63188c8STomohiro Kusumi  *	    Most of these functions use a separate lock.
43a63188c8STomohiro Kusumi  */
44afa5234bSTomohiro Kusumi #include <sys/diskslice.h>
45a63188c8STomohiro Kusumi 
46a63188c8STomohiro Kusumi #include "hammer2.h"
47afa5234bSTomohiro Kusumi #include "makefs.h"
48a63188c8STomohiro Kusumi 
49a63188c8STomohiro Kusumi #if 0
50a63188c8STomohiro Kusumi #include <sys/kern_syscall.h>
51a63188c8STomohiro Kusumi 
52a63188c8STomohiro Kusumi static int hammer2_ioctl_version_get(hammer2_inode_t *ip, void *data);
53a63188c8STomohiro Kusumi static int hammer2_ioctl_recluster(hammer2_inode_t *ip, void *data);
54a63188c8STomohiro Kusumi static int hammer2_ioctl_remote_scan(hammer2_inode_t *ip, void *data);
55a63188c8STomohiro Kusumi static int hammer2_ioctl_remote_add(hammer2_inode_t *ip, void *data);
56a63188c8STomohiro Kusumi static int hammer2_ioctl_remote_del(hammer2_inode_t *ip, void *data);
57a63188c8STomohiro Kusumi static int hammer2_ioctl_remote_rep(hammer2_inode_t *ip, void *data);
58a63188c8STomohiro Kusumi static int hammer2_ioctl_socket_get(hammer2_inode_t *ip, void *data);
59a63188c8STomohiro Kusumi static int hammer2_ioctl_socket_set(hammer2_inode_t *ip, void *data);
60a63188c8STomohiro Kusumi static int hammer2_ioctl_pfs_get(hammer2_inode_t *ip, void *data);
61a63188c8STomohiro Kusumi static int hammer2_ioctl_pfs_lookup(hammer2_inode_t *ip, void *data);
62a63188c8STomohiro Kusumi static int hammer2_ioctl_pfs_create(hammer2_inode_t *ip, void *data);
63a63188c8STomohiro Kusumi static int hammer2_ioctl_pfs_snapshot(hammer2_inode_t *ip, void *data);
64a63188c8STomohiro Kusumi static int hammer2_ioctl_pfs_delete(hammer2_inode_t *ip, void *data);
65a63188c8STomohiro Kusumi static int hammer2_ioctl_inode_get(hammer2_inode_t *ip, void *data);
66a63188c8STomohiro Kusumi static int hammer2_ioctl_inode_set(hammer2_inode_t *ip, void *data);
67a63188c8STomohiro Kusumi static int hammer2_ioctl_debug_dump(hammer2_inode_t *ip, u_int flags);
68a63188c8STomohiro Kusumi static int hammer2_ioctl_emerg_mode(hammer2_inode_t *ip, u_int mode);
69a63188c8STomohiro Kusumi static int hammer2_ioctl_growfs(hammer2_inode_t *ip, void *data,
70a63188c8STomohiro Kusumi 			struct ucred *cred);
71a63188c8STomohiro Kusumi //static int hammer2_ioctl_inode_comp_set(hammer2_inode_t *ip, void *data);
72a63188c8STomohiro Kusumi //static int hammer2_ioctl_inode_comp_rec_set(hammer2_inode_t *ip, void *data);
73a63188c8STomohiro Kusumi //static int hammer2_ioctl_inode_comp_rec_set2(hammer2_inode_t *ip, void *data);
74a63188c8STomohiro Kusumi static int hammer2_ioctl_bulkfree_scan(hammer2_inode_t *ip, void *data);
75a63188c8STomohiro Kusumi static int hammer2_ioctl_destroy(hammer2_inode_t *ip, void *data);
76a63188c8STomohiro Kusumi static int hammer2_ioctl_volume_list(hammer2_inode_t *ip, void *data);
77a63188c8STomohiro Kusumi 
78a63188c8STomohiro Kusumi int
79a63188c8STomohiro Kusumi hammer2_ioctl(hammer2_inode_t *ip, u_long com, void *data, int fflag,
80a63188c8STomohiro Kusumi 	      struct ucred *cred)
81a63188c8STomohiro Kusumi {
82a63188c8STomohiro Kusumi 	int error;
83a63188c8STomohiro Kusumi 
84a63188c8STomohiro Kusumi 	/*
85a63188c8STomohiro Kusumi 	 * Standard root cred checks, will be selectively ignored below
86a63188c8STomohiro Kusumi 	 * for ioctls that do not require root creds.
87a63188c8STomohiro Kusumi 	 */
88*6b47f3eaSTomohiro Kusumi 	error = caps_priv_check(cred, SYSCAP_NOVFS_IOCTL);
89a63188c8STomohiro Kusumi 
90a63188c8STomohiro Kusumi 	switch(com) {
91a63188c8STomohiro Kusumi 	case HAMMER2IOC_VERSION_GET:
92a63188c8STomohiro Kusumi 		error = hammer2_ioctl_version_get(ip, data);
93a63188c8STomohiro Kusumi 		break;
94a63188c8STomohiro Kusumi 	case HAMMER2IOC_RECLUSTER:
95a63188c8STomohiro Kusumi 		if (error == 0)
96a63188c8STomohiro Kusumi 			error = hammer2_ioctl_recluster(ip, data);
97a63188c8STomohiro Kusumi 		break;
98a63188c8STomohiro Kusumi 	case HAMMER2IOC_REMOTE_SCAN:
99a63188c8STomohiro Kusumi 		if (error == 0)
100a63188c8STomohiro Kusumi 			error = hammer2_ioctl_remote_scan(ip, data);
101a63188c8STomohiro Kusumi 		break;
102a63188c8STomohiro Kusumi 	case HAMMER2IOC_REMOTE_ADD:
103a63188c8STomohiro Kusumi 		if (error == 0)
104a63188c8STomohiro Kusumi 			error = hammer2_ioctl_remote_add(ip, data);
105a63188c8STomohiro Kusumi 		break;
106a63188c8STomohiro Kusumi 	case HAMMER2IOC_REMOTE_DEL:
107a63188c8STomohiro Kusumi 		if (error == 0)
108a63188c8STomohiro Kusumi 			error = hammer2_ioctl_remote_del(ip, data);
109a63188c8STomohiro Kusumi 		break;
110a63188c8STomohiro Kusumi 	case HAMMER2IOC_REMOTE_REP:
111a63188c8STomohiro Kusumi 		if (error == 0)
112a63188c8STomohiro Kusumi 			error = hammer2_ioctl_remote_rep(ip, data);
113a63188c8STomohiro Kusumi 		break;
114a63188c8STomohiro Kusumi 	case HAMMER2IOC_SOCKET_GET:
115a63188c8STomohiro Kusumi 		if (error == 0)
116a63188c8STomohiro Kusumi 			error = hammer2_ioctl_socket_get(ip, data);
117a63188c8STomohiro Kusumi 		break;
118a63188c8STomohiro Kusumi 	case HAMMER2IOC_SOCKET_SET:
119a63188c8STomohiro Kusumi 		if (error == 0)
120a63188c8STomohiro Kusumi 			error = hammer2_ioctl_socket_set(ip, data);
121a63188c8STomohiro Kusumi 		break;
122a63188c8STomohiro Kusumi 	case HAMMER2IOC_PFS_GET:
123a63188c8STomohiro Kusumi 		if (error == 0)
124a63188c8STomohiro Kusumi 			error = hammer2_ioctl_pfs_get(ip, data);
125a63188c8STomohiro Kusumi 		break;
126a63188c8STomohiro Kusumi 	case HAMMER2IOC_PFS_LOOKUP:
127a63188c8STomohiro Kusumi 		if (error == 0)
128a63188c8STomohiro Kusumi 			error = hammer2_ioctl_pfs_lookup(ip, data);
129a63188c8STomohiro Kusumi 		break;
130a63188c8STomohiro Kusumi 	case HAMMER2IOC_PFS_CREATE:
131a63188c8STomohiro Kusumi 		if (error == 0)
132a63188c8STomohiro Kusumi 			error = hammer2_ioctl_pfs_create(ip, data);
133a63188c8STomohiro Kusumi 		break;
134a63188c8STomohiro Kusumi 	case HAMMER2IOC_PFS_DELETE:
135a63188c8STomohiro Kusumi 		if (error == 0)
136a63188c8STomohiro Kusumi 			error = hammer2_ioctl_pfs_delete(ip, data);
137a63188c8STomohiro Kusumi 		break;
138a63188c8STomohiro Kusumi 	case HAMMER2IOC_PFS_SNAPSHOT:
139a63188c8STomohiro Kusumi 		if (error == 0)
140a63188c8STomohiro Kusumi 			error = hammer2_ioctl_pfs_snapshot(ip, data);
141a63188c8STomohiro Kusumi 		break;
142a63188c8STomohiro Kusumi 	case HAMMER2IOC_INODE_GET:
143a63188c8STomohiro Kusumi 		error = hammer2_ioctl_inode_get(ip, data);
144a63188c8STomohiro Kusumi 		break;
145a63188c8STomohiro Kusumi 	case HAMMER2IOC_INODE_SET:
146a63188c8STomohiro Kusumi 		if (error == 0)
147a63188c8STomohiro Kusumi 			error = hammer2_ioctl_inode_set(ip, data);
148a63188c8STomohiro Kusumi 		break;
149a63188c8STomohiro Kusumi 	case HAMMER2IOC_BULKFREE_SCAN:
150a63188c8STomohiro Kusumi 		error = hammer2_ioctl_bulkfree_scan(ip, data);
151a63188c8STomohiro Kusumi 		break;
152a63188c8STomohiro Kusumi 	case HAMMER2IOC_BULKFREE_ASYNC:
153a63188c8STomohiro Kusumi 		error = hammer2_ioctl_bulkfree_scan(ip, NULL);
154a63188c8STomohiro Kusumi 		break;
155a63188c8STomohiro Kusumi 	case HAMMER2IOC_DESTROY:
156a63188c8STomohiro Kusumi 		if (error == 0)
157a63188c8STomohiro Kusumi 			error = hammer2_ioctl_destroy(ip, data);
158a63188c8STomohiro Kusumi 		break;
159a63188c8STomohiro Kusumi 	case HAMMER2IOC_DEBUG_DUMP:
160a63188c8STomohiro Kusumi 		error = hammer2_ioctl_debug_dump(ip, *(u_int *)data);
161a63188c8STomohiro Kusumi 		break;
162a63188c8STomohiro Kusumi 	case HAMMER2IOC_EMERG_MODE:
163a63188c8STomohiro Kusumi 		if (error == 0)
164a63188c8STomohiro Kusumi 			error = hammer2_ioctl_emerg_mode(ip, *(u_int *)data);
165a63188c8STomohiro Kusumi 		break;
166a63188c8STomohiro Kusumi 	case HAMMER2IOC_GROWFS:
167a63188c8STomohiro Kusumi 		if (error == 0)
168a63188c8STomohiro Kusumi 			error = hammer2_ioctl_growfs(ip, data, cred);
169a63188c8STomohiro Kusumi 		break;
170a63188c8STomohiro Kusumi 	case HAMMER2IOC_VOLUME_LIST:
171a63188c8STomohiro Kusumi 		if (error == 0)
172a63188c8STomohiro Kusumi 			error = hammer2_ioctl_volume_list(ip, data);
173a63188c8STomohiro Kusumi 		break;
174a63188c8STomohiro Kusumi 	default:
175a63188c8STomohiro Kusumi 		error = EOPNOTSUPP;
176a63188c8STomohiro Kusumi 		break;
177a63188c8STomohiro Kusumi 	}
178a63188c8STomohiro Kusumi 	return (error);
179a63188c8STomohiro Kusumi }
180f72350acSTomohiro Kusumi #endif
181a63188c8STomohiro Kusumi 
182a63188c8STomohiro Kusumi /*
183a63188c8STomohiro Kusumi  * Retrieve version and basic info
184a63188c8STomohiro Kusumi  */
185f72350acSTomohiro Kusumi int
hammer2_ioctl_version_get(hammer2_inode_t * ip,void * data)186a63188c8STomohiro Kusumi hammer2_ioctl_version_get(hammer2_inode_t *ip, void *data)
187a63188c8STomohiro Kusumi {
188a63188c8STomohiro Kusumi 	hammer2_ioc_version_t *version = data;
189a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
190a63188c8STomohiro Kusumi 
191a63188c8STomohiro Kusumi 	hmp = ip->pmp->pfs_hmps[0];
192a63188c8STomohiro Kusumi 	if (hmp)
193a63188c8STomohiro Kusumi 		version->version = hmp->voldata.version;
194a63188c8STomohiro Kusumi 	else
195a63188c8STomohiro Kusumi 		version->version = -1;
196a63188c8STomohiro Kusumi 	return 0;
197a63188c8STomohiro Kusumi }
198a63188c8STomohiro Kusumi 
199f72350acSTomohiro Kusumi #if 0
200a63188c8STomohiro Kusumi static int
201a63188c8STomohiro Kusumi hammer2_ioctl_recluster(hammer2_inode_t *ip, void *data)
202a63188c8STomohiro Kusumi {
203a63188c8STomohiro Kusumi 	hammer2_ioc_recluster_t *recl = data;
204a63188c8STomohiro Kusumi 	struct vnode *vproot;
205a63188c8STomohiro Kusumi 	struct file *fp;
206a63188c8STomohiro Kusumi 	hammer2_cluster_t *cluster;
207a63188c8STomohiro Kusumi 	int error;
208a63188c8STomohiro Kusumi 
209a63188c8STomohiro Kusumi 	fp = holdfp(curthread, recl->fd, -1);
210a63188c8STomohiro Kusumi 	if (fp) {
211a63188c8STomohiro Kusumi 		error = VFS_ROOT(ip->pmp->mp, &vproot);
212a63188c8STomohiro Kusumi 		if (error == 0) {
213a63188c8STomohiro Kusumi 			cluster = &ip->pmp->iroot->cluster;
214a63188c8STomohiro Kusumi 			kprintf("reconnect to cluster: nc=%d focus=%p\n",
215a63188c8STomohiro Kusumi 				cluster->nchains, cluster->focus);
216a63188c8STomohiro Kusumi 			if (cluster->nchains != 1 || cluster->focus == NULL) {
217a63188c8STomohiro Kusumi 				kprintf("not a local device mount\n");
218a63188c8STomohiro Kusumi 				error = EINVAL;
219a63188c8STomohiro Kusumi 			} else {
220a63188c8STomohiro Kusumi 				hammer2_cluster_reconnect(cluster->focus->hmp,
221a63188c8STomohiro Kusumi 							  fp);
222a63188c8STomohiro Kusumi 				kprintf("ok\n");
223a63188c8STomohiro Kusumi 				error = 0;
224a63188c8STomohiro Kusumi 			}
225a63188c8STomohiro Kusumi 			vput(vproot);
226a63188c8STomohiro Kusumi 		}
227a63188c8STomohiro Kusumi 	} else {
228a63188c8STomohiro Kusumi 		error = EINVAL;
229a63188c8STomohiro Kusumi 	}
230a63188c8STomohiro Kusumi 	return error;
231a63188c8STomohiro Kusumi }
232a63188c8STomohiro Kusumi 
233a63188c8STomohiro Kusumi /*
234a63188c8STomohiro Kusumi  * Retrieve information about a remote
235a63188c8STomohiro Kusumi  */
236a63188c8STomohiro Kusumi static int
237a63188c8STomohiro Kusumi hammer2_ioctl_remote_scan(hammer2_inode_t *ip, void *data)
238a63188c8STomohiro Kusumi {
239a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
240a63188c8STomohiro Kusumi 	hammer2_ioc_remote_t *remote = data;
241a63188c8STomohiro Kusumi 	int copyid = remote->copyid;
242a63188c8STomohiro Kusumi 
243a63188c8STomohiro Kusumi 	hmp = ip->pmp->pfs_hmps[0];
244a63188c8STomohiro Kusumi 	if (hmp == NULL)
245a63188c8STomohiro Kusumi 		return (EINVAL);
246a63188c8STomohiro Kusumi 
247a63188c8STomohiro Kusumi 	if (copyid < 0 || copyid >= HAMMER2_COPYID_COUNT)
248a63188c8STomohiro Kusumi 		return (EINVAL);
249a63188c8STomohiro Kusumi 
250a63188c8STomohiro Kusumi 	hammer2_voldata_lock(hmp);
251a63188c8STomohiro Kusumi 	remote->copy1 = hmp->voldata.copyinfo[copyid];
252a63188c8STomohiro Kusumi 	hammer2_voldata_unlock(hmp);
253a63188c8STomohiro Kusumi 
254a63188c8STomohiro Kusumi 	/*
255a63188c8STomohiro Kusumi 	 * Adjust nextid (GET only)
256a63188c8STomohiro Kusumi 	 */
257a63188c8STomohiro Kusumi 	while (++copyid < HAMMER2_COPYID_COUNT &&
258a63188c8STomohiro Kusumi 	       hmp->voldata.copyinfo[copyid].copyid == 0) {
259a63188c8STomohiro Kusumi 		;
260a63188c8STomohiro Kusumi 	}
261a63188c8STomohiro Kusumi 	if (copyid == HAMMER2_COPYID_COUNT)
262a63188c8STomohiro Kusumi 		remote->nextid = -1;
263a63188c8STomohiro Kusumi 	else
264a63188c8STomohiro Kusumi 		remote->nextid = copyid;
265a63188c8STomohiro Kusumi 
266a63188c8STomohiro Kusumi 	return(0);
267a63188c8STomohiro Kusumi }
268a63188c8STomohiro Kusumi 
269a63188c8STomohiro Kusumi /*
270a63188c8STomohiro Kusumi  * Add new remote entry
271a63188c8STomohiro Kusumi  */
272a63188c8STomohiro Kusumi static int
273a63188c8STomohiro Kusumi hammer2_ioctl_remote_add(hammer2_inode_t *ip, void *data)
274a63188c8STomohiro Kusumi {
275a63188c8STomohiro Kusumi 	hammer2_ioc_remote_t *remote = data;
276a63188c8STomohiro Kusumi 	hammer2_pfs_t *pmp = ip->pmp;
277a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
278a63188c8STomohiro Kusumi 	int copyid = remote->copyid;
279a63188c8STomohiro Kusumi 	int error = 0;
280a63188c8STomohiro Kusumi 
281a63188c8STomohiro Kusumi 	hmp = pmp->pfs_hmps[0];
282a63188c8STomohiro Kusumi 	if (hmp == NULL)
283a63188c8STomohiro Kusumi 		return (EINVAL);
284a63188c8STomohiro Kusumi 	if (copyid >= HAMMER2_COPYID_COUNT)
285a63188c8STomohiro Kusumi 		return (EINVAL);
286a63188c8STomohiro Kusumi 
287a63188c8STomohiro Kusumi 	hammer2_voldata_lock(hmp);
288a63188c8STomohiro Kusumi 	if (copyid < 0) {
289a63188c8STomohiro Kusumi 		for (copyid = 1; copyid < HAMMER2_COPYID_COUNT; ++copyid) {
290a63188c8STomohiro Kusumi 			if (hmp->voldata.copyinfo[copyid].copyid == 0)
291a63188c8STomohiro Kusumi 				break;
292a63188c8STomohiro Kusumi 		}
293a63188c8STomohiro Kusumi 		if (copyid == HAMMER2_COPYID_COUNT) {
294a63188c8STomohiro Kusumi 			error = ENOSPC;
295a63188c8STomohiro Kusumi 			goto failed;
296a63188c8STomohiro Kusumi 		}
297a63188c8STomohiro Kusumi 	}
298a63188c8STomohiro Kusumi 	hammer2_voldata_modify(hmp);
299a63188c8STomohiro Kusumi 	remote->copy1.copyid = copyid;
300a63188c8STomohiro Kusumi 	hmp->voldata.copyinfo[copyid] = remote->copy1;
301a63188c8STomohiro Kusumi 	hammer2_volconf_update(hmp, copyid);
302a63188c8STomohiro Kusumi failed:
303a63188c8STomohiro Kusumi 	hammer2_voldata_unlock(hmp);
304a63188c8STomohiro Kusumi 	return (error);
305a63188c8STomohiro Kusumi }
306a63188c8STomohiro Kusumi 
307a63188c8STomohiro Kusumi /*
308a63188c8STomohiro Kusumi  * Delete existing remote entry
309a63188c8STomohiro Kusumi  */
310a63188c8STomohiro Kusumi static int
311a63188c8STomohiro Kusumi hammer2_ioctl_remote_del(hammer2_inode_t *ip, void *data)
312a63188c8STomohiro Kusumi {
313a63188c8STomohiro Kusumi 	hammer2_ioc_remote_t *remote = data;
314a63188c8STomohiro Kusumi 	hammer2_pfs_t *pmp = ip->pmp;
315a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
316a63188c8STomohiro Kusumi 	int copyid = remote->copyid;
317a63188c8STomohiro Kusumi 	int error = 0;
318a63188c8STomohiro Kusumi 
319a63188c8STomohiro Kusumi 	hmp = pmp->pfs_hmps[0];
320a63188c8STomohiro Kusumi 	if (hmp == NULL)
321a63188c8STomohiro Kusumi 		return (EINVAL);
322a63188c8STomohiro Kusumi 	if (copyid >= HAMMER2_COPYID_COUNT)
323a63188c8STomohiro Kusumi 		return (EINVAL);
324a63188c8STomohiro Kusumi 	remote->copy1.path[sizeof(remote->copy1.path) - 1] = 0;
325a63188c8STomohiro Kusumi 	hammer2_voldata_lock(hmp);
326a63188c8STomohiro Kusumi 	if (copyid < 0) {
327a63188c8STomohiro Kusumi 		for (copyid = 1; copyid < HAMMER2_COPYID_COUNT; ++copyid) {
328a63188c8STomohiro Kusumi 			if (hmp->voldata.copyinfo[copyid].copyid == 0)
329a63188c8STomohiro Kusumi 				continue;
330a63188c8STomohiro Kusumi 			if (strcmp(remote->copy1.path,
331a63188c8STomohiro Kusumi 			    hmp->voldata.copyinfo[copyid].path) == 0) {
332a63188c8STomohiro Kusumi 				break;
333a63188c8STomohiro Kusumi 			}
334a63188c8STomohiro Kusumi 		}
335a63188c8STomohiro Kusumi 		if (copyid == HAMMER2_COPYID_COUNT) {
336a63188c8STomohiro Kusumi 			error = ENOENT;
337a63188c8STomohiro Kusumi 			goto failed;
338a63188c8STomohiro Kusumi 		}
339a63188c8STomohiro Kusumi 	}
340a63188c8STomohiro Kusumi 	hammer2_voldata_modify(hmp);
341a63188c8STomohiro Kusumi 	hmp->voldata.copyinfo[copyid].copyid = 0;
342a63188c8STomohiro Kusumi 	hammer2_volconf_update(hmp, copyid);
343a63188c8STomohiro Kusumi failed:
344a63188c8STomohiro Kusumi 	hammer2_voldata_unlock(hmp);
345a63188c8STomohiro Kusumi 	return (error);
346a63188c8STomohiro Kusumi }
347a63188c8STomohiro Kusumi 
348a63188c8STomohiro Kusumi /*
349a63188c8STomohiro Kusumi  * Replace existing remote entry
350a63188c8STomohiro Kusumi  */
351a63188c8STomohiro Kusumi static int
352a63188c8STomohiro Kusumi hammer2_ioctl_remote_rep(hammer2_inode_t *ip, void *data)
353a63188c8STomohiro Kusumi {
354a63188c8STomohiro Kusumi 	hammer2_ioc_remote_t *remote = data;
355a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
356a63188c8STomohiro Kusumi 	int copyid = remote->copyid;
357a63188c8STomohiro Kusumi 
358a63188c8STomohiro Kusumi 	hmp = ip->pmp->pfs_hmps[0];
359a63188c8STomohiro Kusumi 	if (hmp == NULL)
360a63188c8STomohiro Kusumi 		return (EINVAL);
361a63188c8STomohiro Kusumi 	if (copyid < 0 || copyid >= HAMMER2_COPYID_COUNT)
362a63188c8STomohiro Kusumi 		return (EINVAL);
363a63188c8STomohiro Kusumi 
364a63188c8STomohiro Kusumi 	hammer2_voldata_lock(hmp);
365a63188c8STomohiro Kusumi 	hammer2_voldata_modify(hmp);
366a63188c8STomohiro Kusumi 	/*hammer2_volconf_update(hmp, copyid);*/
367a63188c8STomohiro Kusumi 	hammer2_voldata_unlock(hmp);
368a63188c8STomohiro Kusumi 
369a63188c8STomohiro Kusumi 	return(0);
370a63188c8STomohiro Kusumi }
371a63188c8STomohiro Kusumi 
372a63188c8STomohiro Kusumi /*
373a63188c8STomohiro Kusumi  * Retrieve communications socket
374a63188c8STomohiro Kusumi  */
375a63188c8STomohiro Kusumi static int
376a63188c8STomohiro Kusumi hammer2_ioctl_socket_get(hammer2_inode_t *ip, void *data)
377a63188c8STomohiro Kusumi {
378a63188c8STomohiro Kusumi 	return (EOPNOTSUPP);
379a63188c8STomohiro Kusumi }
380a63188c8STomohiro Kusumi 
381a63188c8STomohiro Kusumi /*
382a63188c8STomohiro Kusumi  * Set communications socket for connection
383a63188c8STomohiro Kusumi  */
384a63188c8STomohiro Kusumi static int
385a63188c8STomohiro Kusumi hammer2_ioctl_socket_set(hammer2_inode_t *ip, void *data)
386a63188c8STomohiro Kusumi {
387a63188c8STomohiro Kusumi 	hammer2_ioc_remote_t *remote = data;
388a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
389a63188c8STomohiro Kusumi 	int copyid = remote->copyid;
390a63188c8STomohiro Kusumi 
391a63188c8STomohiro Kusumi 	hmp = ip->pmp->pfs_hmps[0];
392a63188c8STomohiro Kusumi 	if (hmp == NULL)
393a63188c8STomohiro Kusumi 		return (EINVAL);
394a63188c8STomohiro Kusumi 	if (copyid < 0 || copyid >= HAMMER2_COPYID_COUNT)
395a63188c8STomohiro Kusumi 		return (EINVAL);
396a63188c8STomohiro Kusumi 
397a63188c8STomohiro Kusumi 	hammer2_voldata_lock(hmp);
398a63188c8STomohiro Kusumi 	hammer2_voldata_unlock(hmp);
399a63188c8STomohiro Kusumi 
400a63188c8STomohiro Kusumi 	return(0);
401a63188c8STomohiro Kusumi }
4023999233bSTomohiro Kusumi #endif
403a63188c8STomohiro Kusumi 
404a63188c8STomohiro Kusumi /*
405a63188c8STomohiro Kusumi  * Used to scan and retrieve PFS information.  PFS's are directories under
406a63188c8STomohiro Kusumi  * the super-root.
407a63188c8STomohiro Kusumi  *
408a63188c8STomohiro Kusumi  * To scan PFSs pass name_key=0.  The function will scan for the next
409a63188c8STomohiro Kusumi  * PFS and set all fields, as well as set name_next to the next key.
410a63188c8STomohiro Kusumi  * When no PFSs remain, name_next is set to (hammer2_key_t)-1.
411a63188c8STomohiro Kusumi  *
412a63188c8STomohiro Kusumi  * To retrieve a particular PFS by key, specify the key but note that
413a63188c8STomohiro Kusumi  * the ioctl will return the lowest key >= specified_key, so the caller
414a63188c8STomohiro Kusumi  * must verify the key.
415a63188c8STomohiro Kusumi  *
416a63188c8STomohiro Kusumi  * To retrieve the PFS associated with the file descriptor, pass
417a63188c8STomohiro Kusumi  * name_key set to (hammer2_key_t)-1.
418a63188c8STomohiro Kusumi  */
4193999233bSTomohiro Kusumi int
hammer2_ioctl_pfs_get(hammer2_inode_t * ip,void * data)420a63188c8STomohiro Kusumi hammer2_ioctl_pfs_get(hammer2_inode_t *ip, void *data)
421a63188c8STomohiro Kusumi {
422a63188c8STomohiro Kusumi 	const hammer2_inode_data_t *ripdata;
423a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
424a63188c8STomohiro Kusumi 	hammer2_ioc_pfs_t *pfs;
425a63188c8STomohiro Kusumi 	hammer2_chain_t *parent;
426a63188c8STomohiro Kusumi 	hammer2_chain_t *chain;
427a63188c8STomohiro Kusumi 	hammer2_key_t key_next;
428a63188c8STomohiro Kusumi 	hammer2_key_t save_key;
429a63188c8STomohiro Kusumi 	int error;
430a63188c8STomohiro Kusumi 
431a63188c8STomohiro Kusumi 	hmp = ip->pmp->pfs_hmps[0];
432a63188c8STomohiro Kusumi 	if (hmp == NULL)
433a63188c8STomohiro Kusumi 		return (EINVAL);
434a63188c8STomohiro Kusumi 
435a63188c8STomohiro Kusumi 	pfs = data;
436a63188c8STomohiro Kusumi 	save_key = pfs->name_key;
437a63188c8STomohiro Kusumi 	error = 0;
438a63188c8STomohiro Kusumi 
439a63188c8STomohiro Kusumi 	/*
440a63188c8STomohiro Kusumi 	 * Setup
441a63188c8STomohiro Kusumi 	 */
442a63188c8STomohiro Kusumi 	if (save_key == (hammer2_key_t)-1) {
443a63188c8STomohiro Kusumi 		hammer2_inode_lock(ip->pmp->iroot, 0);
444a63188c8STomohiro Kusumi 		parent = NULL;
445a63188c8STomohiro Kusumi 		chain = hammer2_inode_chain(ip->pmp->iroot, 0,
446a63188c8STomohiro Kusumi 					    HAMMER2_RESOLVE_ALWAYS |
447a63188c8STomohiro Kusumi 					    HAMMER2_RESOLVE_SHARED);
448a63188c8STomohiro Kusumi 	} else {
449a63188c8STomohiro Kusumi 		hammer2_inode_lock(hmp->spmp->iroot, 0);
450a63188c8STomohiro Kusumi 		parent = hammer2_inode_chain(hmp->spmp->iroot, 0,
451a63188c8STomohiro Kusumi 					    HAMMER2_RESOLVE_ALWAYS |
452a63188c8STomohiro Kusumi 					    HAMMER2_RESOLVE_SHARED);
453a63188c8STomohiro Kusumi 		chain = hammer2_chain_lookup(&parent, &key_next,
454a63188c8STomohiro Kusumi 					    pfs->name_key, HAMMER2_KEY_MAX,
455a63188c8STomohiro Kusumi 					    &error,
456a63188c8STomohiro Kusumi 					    HAMMER2_LOOKUP_SHARED);
457a63188c8STomohiro Kusumi 	}
458a63188c8STomohiro Kusumi 
459a63188c8STomohiro Kusumi 	/*
460a63188c8STomohiro Kusumi 	 * Locate next PFS
461a63188c8STomohiro Kusumi 	 */
462a63188c8STomohiro Kusumi 	while (chain) {
463a63188c8STomohiro Kusumi 		if (chain->bref.type == HAMMER2_BREF_TYPE_INODE)
464a63188c8STomohiro Kusumi 			break;
465a63188c8STomohiro Kusumi 		if (parent == NULL) {
466a63188c8STomohiro Kusumi 			hammer2_chain_unlock(chain);
467a63188c8STomohiro Kusumi 			hammer2_chain_drop(chain);
468a63188c8STomohiro Kusumi 			chain = NULL;
469a63188c8STomohiro Kusumi 			break;
470a63188c8STomohiro Kusumi 		}
471a63188c8STomohiro Kusumi 		chain = hammer2_chain_next(&parent, chain, &key_next,
472a63188c8STomohiro Kusumi 					    key_next, HAMMER2_KEY_MAX,
473a63188c8STomohiro Kusumi 					    &error,
474a63188c8STomohiro Kusumi 					    HAMMER2_LOOKUP_SHARED);
475a63188c8STomohiro Kusumi 	}
476a63188c8STomohiro Kusumi 	error = hammer2_error_to_errno(error);
477a63188c8STomohiro Kusumi 
478a63188c8STomohiro Kusumi 	/*
479a63188c8STomohiro Kusumi 	 * Load the data being returned by the ioctl.
480a63188c8STomohiro Kusumi 	 */
481a63188c8STomohiro Kusumi 	if (chain && chain->error == 0) {
482a63188c8STomohiro Kusumi 		ripdata = &chain->data->ipdata;
483a63188c8STomohiro Kusumi 		pfs->name_key = ripdata->meta.name_key;
484a63188c8STomohiro Kusumi 		pfs->pfs_type = ripdata->meta.pfs_type;
485a63188c8STomohiro Kusumi 		pfs->pfs_subtype = ripdata->meta.pfs_subtype;
486a63188c8STomohiro Kusumi 		pfs->pfs_clid = ripdata->meta.pfs_clid;
487a63188c8STomohiro Kusumi 		pfs->pfs_fsid = ripdata->meta.pfs_fsid;
488a63188c8STomohiro Kusumi 		KKASSERT(ripdata->meta.name_len < sizeof(pfs->name));
489a63188c8STomohiro Kusumi 		bcopy(ripdata->filename, pfs->name, ripdata->meta.name_len);
490a63188c8STomohiro Kusumi 		pfs->name[ripdata->meta.name_len] = 0;
491a63188c8STomohiro Kusumi 		ripdata = NULL;	/* safety */
492a63188c8STomohiro Kusumi 
493a63188c8STomohiro Kusumi 		/*
494a63188c8STomohiro Kusumi 		 * Calculate name_next, if any.  We are only accessing
495a63188c8STomohiro Kusumi 		 * chain->bref so we can ignore chain->error (if the key
496a63188c8STomohiro Kusumi 		 * is used later it will error then).
497a63188c8STomohiro Kusumi 		 */
498a63188c8STomohiro Kusumi 		if (parent == NULL) {
499a63188c8STomohiro Kusumi 			pfs->name_next = (hammer2_key_t)-1;
500a63188c8STomohiro Kusumi 		} else {
501a63188c8STomohiro Kusumi 			chain = hammer2_chain_next(&parent, chain, &key_next,
502a63188c8STomohiro Kusumi 						    key_next, HAMMER2_KEY_MAX,
503a63188c8STomohiro Kusumi 						    &error,
504a63188c8STomohiro Kusumi 						    HAMMER2_LOOKUP_SHARED);
505a63188c8STomohiro Kusumi 			if (chain)
506a63188c8STomohiro Kusumi 				pfs->name_next = chain->bref.key;
507a63188c8STomohiro Kusumi 			else
508a63188c8STomohiro Kusumi 				pfs->name_next = (hammer2_key_t)-1;
509a63188c8STomohiro Kusumi 		}
510a63188c8STomohiro Kusumi 	} else {
511a63188c8STomohiro Kusumi 		pfs->name_next = (hammer2_key_t)-1;
512a63188c8STomohiro Kusumi 		error = ENOENT;
513a63188c8STomohiro Kusumi 	}
514a63188c8STomohiro Kusumi 
515a63188c8STomohiro Kusumi 	/*
516a63188c8STomohiro Kusumi 	 * Cleanup
517a63188c8STomohiro Kusumi 	 */
518a63188c8STomohiro Kusumi 	if (chain) {
519a63188c8STomohiro Kusumi 		hammer2_chain_unlock(chain);
520a63188c8STomohiro Kusumi 		hammer2_chain_drop(chain);
521a63188c8STomohiro Kusumi 	}
522a63188c8STomohiro Kusumi 	if (parent) {
523a63188c8STomohiro Kusumi 		hammer2_chain_unlock(parent);
524a63188c8STomohiro Kusumi 		hammer2_chain_drop(parent);
525a63188c8STomohiro Kusumi 	}
526a63188c8STomohiro Kusumi 	if (save_key == (hammer2_key_t)-1) {
527a63188c8STomohiro Kusumi 		hammer2_inode_unlock(ip->pmp->iroot);
528a63188c8STomohiro Kusumi 	} else {
529a63188c8STomohiro Kusumi 		hammer2_inode_unlock(hmp->spmp->iroot);
530a63188c8STomohiro Kusumi 	}
531a63188c8STomohiro Kusumi 
532a63188c8STomohiro Kusumi 	return (error);
533a63188c8STomohiro Kusumi }
534a63188c8STomohiro Kusumi 
535a63188c8STomohiro Kusumi /*
536a63188c8STomohiro Kusumi  * Find a specific PFS by name
537a63188c8STomohiro Kusumi  */
5383999233bSTomohiro Kusumi int
hammer2_ioctl_pfs_lookup(hammer2_inode_t * ip,void * data)539a63188c8STomohiro Kusumi hammer2_ioctl_pfs_lookup(hammer2_inode_t *ip, void *data)
540a63188c8STomohiro Kusumi {
541a63188c8STomohiro Kusumi 	const hammer2_inode_data_t *ripdata;
542a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
543a63188c8STomohiro Kusumi 	hammer2_ioc_pfs_t *pfs;
544a63188c8STomohiro Kusumi 	hammer2_chain_t *parent;
545a63188c8STomohiro Kusumi 	hammer2_chain_t *chain;
546a63188c8STomohiro Kusumi 	hammer2_key_t key_next;
547a63188c8STomohiro Kusumi 	hammer2_key_t lhc;
548a63188c8STomohiro Kusumi 	int error;
549a63188c8STomohiro Kusumi 	size_t len;
550a63188c8STomohiro Kusumi 
551a63188c8STomohiro Kusumi 	hmp = ip->pmp->pfs_hmps[0];
552a63188c8STomohiro Kusumi 	if (hmp == NULL)
553a63188c8STomohiro Kusumi 		return (EINVAL);
554a63188c8STomohiro Kusumi 
555a63188c8STomohiro Kusumi 	pfs = data;
556a63188c8STomohiro Kusumi 	error = 0;
557a63188c8STomohiro Kusumi 
558a63188c8STomohiro Kusumi 	hammer2_inode_lock(hmp->spmp->iroot, HAMMER2_RESOLVE_SHARED);
559a63188c8STomohiro Kusumi 	parent = hammer2_inode_chain(hmp->spmp->iroot, 0,
560a63188c8STomohiro Kusumi 				     HAMMER2_RESOLVE_ALWAYS |
561a63188c8STomohiro Kusumi 				     HAMMER2_RESOLVE_SHARED);
562a63188c8STomohiro Kusumi 
563a63188c8STomohiro Kusumi 	pfs->name[sizeof(pfs->name) - 1] = 0;
564a63188c8STomohiro Kusumi 	len = strlen(pfs->name);
565a63188c8STomohiro Kusumi 	lhc = hammer2_dirhash(pfs->name, len);
566a63188c8STomohiro Kusumi 
567a63188c8STomohiro Kusumi 	chain = hammer2_chain_lookup(&parent, &key_next,
568a63188c8STomohiro Kusumi 					 lhc, lhc + HAMMER2_DIRHASH_LOMASK,
569a63188c8STomohiro Kusumi 					 &error, HAMMER2_LOOKUP_SHARED);
570a63188c8STomohiro Kusumi 	while (chain) {
571a63188c8STomohiro Kusumi 		if (hammer2_chain_dirent_test(chain, pfs->name, len))
572a63188c8STomohiro Kusumi 			break;
573a63188c8STomohiro Kusumi 		chain = hammer2_chain_next(&parent, chain, &key_next,
574a63188c8STomohiro Kusumi 					   key_next,
575a63188c8STomohiro Kusumi 					   lhc + HAMMER2_DIRHASH_LOMASK,
576a63188c8STomohiro Kusumi 					   &error, HAMMER2_LOOKUP_SHARED);
577a63188c8STomohiro Kusumi 	}
578a63188c8STomohiro Kusumi 	error = hammer2_error_to_errno(error);
579a63188c8STomohiro Kusumi 
580a63188c8STomohiro Kusumi 	/*
581a63188c8STomohiro Kusumi 	 * Load the data being returned by the ioctl.
582a63188c8STomohiro Kusumi 	 */
583a63188c8STomohiro Kusumi 	if (chain && chain->error == 0) {
584a63188c8STomohiro Kusumi 		KKASSERT(chain->bref.type == HAMMER2_BREF_TYPE_INODE);
585a63188c8STomohiro Kusumi 		ripdata = &chain->data->ipdata;
586a63188c8STomohiro Kusumi 		pfs->name_key = ripdata->meta.name_key;
587a63188c8STomohiro Kusumi 		pfs->pfs_type = ripdata->meta.pfs_type;
588a63188c8STomohiro Kusumi 		pfs->pfs_subtype = ripdata->meta.pfs_subtype;
589a63188c8STomohiro Kusumi 		pfs->pfs_clid = ripdata->meta.pfs_clid;
590a63188c8STomohiro Kusumi 		pfs->pfs_fsid = ripdata->meta.pfs_fsid;
591a63188c8STomohiro Kusumi 		ripdata = NULL;
592a63188c8STomohiro Kusumi 
593a63188c8STomohiro Kusumi 		hammer2_chain_unlock(chain);
594a63188c8STomohiro Kusumi 		hammer2_chain_drop(chain);
595a63188c8STomohiro Kusumi 	} else if (error == 0) {
596a63188c8STomohiro Kusumi 		error = ENOENT;
597a63188c8STomohiro Kusumi 	}
598a63188c8STomohiro Kusumi 	if (parent) {
599a63188c8STomohiro Kusumi 		hammer2_chain_unlock(parent);
600a63188c8STomohiro Kusumi 		hammer2_chain_drop(parent);
601a63188c8STomohiro Kusumi 	}
602a63188c8STomohiro Kusumi 	hammer2_inode_unlock(hmp->spmp->iroot);
603a63188c8STomohiro Kusumi 
604a63188c8STomohiro Kusumi 	return (error);
605a63188c8STomohiro Kusumi }
606a63188c8STomohiro Kusumi 
607a63188c8STomohiro Kusumi /*
608a63188c8STomohiro Kusumi  * Create a new PFS under the super-root
609a63188c8STomohiro Kusumi  */
6103999233bSTomohiro Kusumi int
hammer2_ioctl_pfs_create(hammer2_inode_t * ip,void * data)611a63188c8STomohiro Kusumi hammer2_ioctl_pfs_create(hammer2_inode_t *ip, void *data)
612a63188c8STomohiro Kusumi {
613a63188c8STomohiro Kusumi 	hammer2_inode_data_t *nipdata;
614a63188c8STomohiro Kusumi 	hammer2_chain_t *nchain;
615a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
616a63188c8STomohiro Kusumi 	hammer2_dev_t *force_local;
617a63188c8STomohiro Kusumi 	hammer2_ioc_pfs_t *pfs;
618a63188c8STomohiro Kusumi 	hammer2_inode_t *nip;
619a63188c8STomohiro Kusumi 	hammer2_tid_t mtid;
620a63188c8STomohiro Kusumi 	int error;
621a63188c8STomohiro Kusumi 
622a63188c8STomohiro Kusumi 	hmp = ip->pmp->pfs_hmps[0];	/* XXX */
623a63188c8STomohiro Kusumi 	if (hmp == NULL)
624a63188c8STomohiro Kusumi 		return (EINVAL);
625a63188c8STomohiro Kusumi 
626a63188c8STomohiro Kusumi 	pfs = data;
627a63188c8STomohiro Kusumi 	nip = NULL;
628a63188c8STomohiro Kusumi 
629a63188c8STomohiro Kusumi 	if (pfs->name[0] == 0)
630a63188c8STomohiro Kusumi 		return(EINVAL);
631a63188c8STomohiro Kusumi 	pfs->name[sizeof(pfs->name) - 1] = 0;	/* ensure 0-termination */
632a63188c8STomohiro Kusumi 
633a63188c8STomohiro Kusumi 	if (hammer2_ioctl_pfs_lookup(ip, pfs) == 0)
634a63188c8STomohiro Kusumi 		return(EEXIST);
635a63188c8STomohiro Kusumi 
636a63188c8STomohiro Kusumi 	hammer2_trans_init(hmp->spmp, HAMMER2_TRANS_ISFLUSH);
637a63188c8STomohiro Kusumi 	mtid = hammer2_trans_sub(hmp->spmp);
638a63188c8STomohiro Kusumi 	nip = hammer2_inode_create_pfs(hmp->spmp, pfs->name, strlen(pfs->name),
639a63188c8STomohiro Kusumi 				       &error);
640a63188c8STomohiro Kusumi 	if (error == 0) {
641a63188c8STomohiro Kusumi 		atomic_set_int(&nip->flags, HAMMER2_INODE_NOSIDEQ);
642a63188c8STomohiro Kusumi 		hammer2_inode_modify(nip);
643a63188c8STomohiro Kusumi 		nchain = hammer2_inode_chain(nip, 0, HAMMER2_RESOLVE_ALWAYS);
644a63188c8STomohiro Kusumi 		error = hammer2_chain_modify(nchain, mtid, 0, 0);
645a63188c8STomohiro Kusumi 		KKASSERT(error == 0);
646a63188c8STomohiro Kusumi 		nipdata = &nchain->data->ipdata;
647a63188c8STomohiro Kusumi 
648a63188c8STomohiro Kusumi 		nip->meta.pfs_type = pfs->pfs_type;
649a63188c8STomohiro Kusumi 		nip->meta.pfs_subtype = pfs->pfs_subtype;
650a63188c8STomohiro Kusumi 		nip->meta.pfs_clid = pfs->pfs_clid;
651a63188c8STomohiro Kusumi 		nip->meta.pfs_fsid = pfs->pfs_fsid;
652a63188c8STomohiro Kusumi 		nip->meta.op_flags |= HAMMER2_OPFLAG_PFSROOT;
653a63188c8STomohiro Kusumi 
654a63188c8STomohiro Kusumi 		/*
655a63188c8STomohiro Kusumi 		 * Set default compression and check algorithm.  This
656a63188c8STomohiro Kusumi 		 * can be changed later.
657a63188c8STomohiro Kusumi 		 *
658a63188c8STomohiro Kusumi 		 * Do not allow compression on PFS's with the special name
659a63188c8STomohiro Kusumi 		 * "boot", the boot loader can't decompress (yet).
660a63188c8STomohiro Kusumi 		 */
661a63188c8STomohiro Kusumi 		nip->meta.comp_algo =
662a071436bSTomohiro Kusumi 			HAMMER2_ENC_ALGO(HAMMER2_COMP_DEFAULT);
663a63188c8STomohiro Kusumi 		nip->meta.check_algo =
6649046282cSTomohiro Kusumi 			HAMMER2_ENC_ALGO(HAMMER2_CHECK_DEFAULT);
665a63188c8STomohiro Kusumi 
666a63188c8STomohiro Kusumi 		if (strcasecmp(pfs->name, "boot") == 0) {
667a63188c8STomohiro Kusumi 			nip->meta.comp_algo =
668a63188c8STomohiro Kusumi 				HAMMER2_ENC_ALGO(HAMMER2_COMP_AUTOZERO);
669a63188c8STomohiro Kusumi 		}
670a63188c8STomohiro Kusumi 
671a63188c8STomohiro Kusumi 		/*
672a63188c8STomohiro Kusumi 		 * Super-root isn't mounted, fsync it
673a63188c8STomohiro Kusumi 		 */
674a63188c8STomohiro Kusumi 		hammer2_chain_unlock(nchain);
675a63188c8STomohiro Kusumi 		hammer2_inode_ref(nip);
676a63188c8STomohiro Kusumi 		hammer2_inode_unlock(nip);
677a63188c8STomohiro Kusumi 		hammer2_inode_chain_sync(nip);
678a63188c8STomohiro Kusumi 		hammer2_inode_chain_flush(nip, HAMMER2_XOP_INODE_STOP |
679a63188c8STomohiro Kusumi 					       HAMMER2_XOP_FSSYNC);
680a63188c8STomohiro Kusumi 		hammer2_inode_drop(nip);
681a63188c8STomohiro Kusumi 		/* nip is dead */
682a63188c8STomohiro Kusumi 
683a63188c8STomohiro Kusumi 		/*
684a63188c8STomohiro Kusumi 		 * We still have a ref on the chain, relock and associate
685a63188c8STomohiro Kusumi 		 * with an appropriate PFS.
686a63188c8STomohiro Kusumi 		 */
687a63188c8STomohiro Kusumi 		force_local = (hmp->hflags & HMNT2_LOCAL) ? hmp : NULL;
688a63188c8STomohiro Kusumi 
689a63188c8STomohiro Kusumi 		hammer2_chain_lock(nchain, HAMMER2_RESOLVE_ALWAYS);
690a63188c8STomohiro Kusumi 		nipdata = &nchain->data->ipdata;
691a63188c8STomohiro Kusumi 		kprintf("ADD LOCAL PFS (IOCTL): %s\n", nipdata->filename);
692a63188c8STomohiro Kusumi 		hammer2_pfsalloc(nchain, nipdata, force_local);
693a63188c8STomohiro Kusumi 
694a63188c8STomohiro Kusumi 		hammer2_chain_unlock(nchain);
695a63188c8STomohiro Kusumi 		hammer2_chain_drop(nchain);
696a63188c8STomohiro Kusumi 	}
697a63188c8STomohiro Kusumi 	hammer2_trans_done(hmp->spmp, HAMMER2_TRANS_ISFLUSH |
698a63188c8STomohiro Kusumi 				      HAMMER2_TRANS_SIDEQ);
699a63188c8STomohiro Kusumi 
700a63188c8STomohiro Kusumi 	return (error);
701a63188c8STomohiro Kusumi }
702a63188c8STomohiro Kusumi 
703a63188c8STomohiro Kusumi /*
704a63188c8STomohiro Kusumi  * Destroy an existing PFS under the super-root
705a63188c8STomohiro Kusumi  */
7063999233bSTomohiro Kusumi int
hammer2_ioctl_pfs_delete(hammer2_inode_t * ip,void * data)707a63188c8STomohiro Kusumi hammer2_ioctl_pfs_delete(hammer2_inode_t *ip, void *data)
708a63188c8STomohiro Kusumi {
709a63188c8STomohiro Kusumi 	hammer2_ioc_pfs_t *pfs = data;
710a63188c8STomohiro Kusumi 	hammer2_dev_t	*hmp;
711a63188c8STomohiro Kusumi 	hammer2_pfs_t	*spmp;
712a63188c8STomohiro Kusumi 	hammer2_pfs_t	*pmp;
713a63188c8STomohiro Kusumi 	hammer2_xop_unlink_t *xop;
714a63188c8STomohiro Kusumi 	hammer2_inode_t *dip;
715a63188c8STomohiro Kusumi 	int error;
716a63188c8STomohiro Kusumi 	int i;
717a63188c8STomohiro Kusumi 
718a63188c8STomohiro Kusumi 	/*
719a63188c8STomohiro Kusumi 	 * The PFS should be probed, so we should be able to
720a63188c8STomohiro Kusumi 	 * locate it.  We only delete the PFS from the
721a63188c8STomohiro Kusumi 	 * specific H2 block device (hmp), not all of
722a63188c8STomohiro Kusumi 	 * them.  We must remove the PFS from the cluster
723a63188c8STomohiro Kusumi 	 * before we can destroy it.
724a63188c8STomohiro Kusumi 	 */
725a63188c8STomohiro Kusumi 	hmp = ip->pmp->pfs_hmps[0];
726a63188c8STomohiro Kusumi 	if (hmp == NULL)
727a63188c8STomohiro Kusumi 		return (EINVAL);
728a63188c8STomohiro Kusumi 
729a63188c8STomohiro Kusumi 	pfs->name[sizeof(pfs->name) - 1] = 0;	/* ensure termination */
730a63188c8STomohiro Kusumi 
731a63188c8STomohiro Kusumi 	lockmgr(&hammer2_mntlk, LK_EXCLUSIVE);
732a63188c8STomohiro Kusumi 
733a63188c8STomohiro Kusumi 	TAILQ_FOREACH(pmp, &hammer2_pfslist, mntentry) {
734a63188c8STomohiro Kusumi 		for (i = 0; i < HAMMER2_MAXCLUSTER; ++i) {
735a63188c8STomohiro Kusumi 			if (pmp->pfs_hmps[i] != hmp)
736a63188c8STomohiro Kusumi 				continue;
737a63188c8STomohiro Kusumi 			if (pmp->pfs_names[i] &&
738a63188c8STomohiro Kusumi 			    strcmp(pmp->pfs_names[i], pfs->name) == 0) {
739a63188c8STomohiro Kusumi 				break;
740a63188c8STomohiro Kusumi 			}
741a63188c8STomohiro Kusumi 		}
742a63188c8STomohiro Kusumi 		if (i != HAMMER2_MAXCLUSTER)
743a63188c8STomohiro Kusumi 			break;
744a63188c8STomohiro Kusumi 	}
745a63188c8STomohiro Kusumi 
746a63188c8STomohiro Kusumi 	if (pmp == NULL) {
747a63188c8STomohiro Kusumi 		lockmgr(&hammer2_mntlk, LK_RELEASE);
748a63188c8STomohiro Kusumi 		return ENOENT;
749a63188c8STomohiro Kusumi 	}
750a63188c8STomohiro Kusumi 	if (pmp->mp) {
751a63188c8STomohiro Kusumi 		lockmgr(&hammer2_mntlk, LK_RELEASE);
752a63188c8STomohiro Kusumi 		return EBUSY;
753a63188c8STomohiro Kusumi 	}
754a63188c8STomohiro Kusumi 
755a63188c8STomohiro Kusumi 	/*
756a63188c8STomohiro Kusumi 	 * Ok, we found the pmp and we have the index.  Permanently remove
757a63188c8STomohiro Kusumi 	 * the PFS from the cluster
758a63188c8STomohiro Kusumi 	 */
759a63188c8STomohiro Kusumi 	kprintf("FOUND PFS %s CLINDEX %d\n", pfs->name, i);
760a63188c8STomohiro Kusumi 	hammer2_pfsdealloc(pmp, i, 1);
761a63188c8STomohiro Kusumi 
762a63188c8STomohiro Kusumi 	lockmgr(&hammer2_mntlk, LK_RELEASE);
763a63188c8STomohiro Kusumi 
764a63188c8STomohiro Kusumi 	/*
765a63188c8STomohiro Kusumi 	 * Now destroy the PFS under its device using the per-device
766a63188c8STomohiro Kusumi 	 * super-root.
767a63188c8STomohiro Kusumi 	 */
768a63188c8STomohiro Kusumi 	spmp = hmp->spmp;
769a63188c8STomohiro Kusumi 	dip = spmp->iroot;
770a63188c8STomohiro Kusumi 	hammer2_trans_init(spmp, 0);
771a63188c8STomohiro Kusumi 	hammer2_inode_lock(dip, 0);
772a63188c8STomohiro Kusumi 
773a63188c8STomohiro Kusumi 	xop = hammer2_xop_alloc(dip, HAMMER2_XOP_MODIFYING);
774a63188c8STomohiro Kusumi 	hammer2_xop_setname(&xop->head, pfs->name, strlen(pfs->name));
775a63188c8STomohiro Kusumi 	xop->isdir = 2;
776a63188c8STomohiro Kusumi 	xop->dopermanent = H2DOPERM_PERMANENT | H2DOPERM_FORCE;
777a63188c8STomohiro Kusumi 	hammer2_xop_start(&xop->head, &hammer2_unlink_desc);
778a63188c8STomohiro Kusumi 
779a63188c8STomohiro Kusumi 	error = hammer2_xop_collect(&xop->head, 0);
780a63188c8STomohiro Kusumi 
781a63188c8STomohiro Kusumi 	hammer2_inode_unlock(dip);
782a63188c8STomohiro Kusumi 
783a63188c8STomohiro Kusumi #if 0
784a63188c8STomohiro Kusumi 	if (error == 0) {
785a63188c8STomohiro Kusumi 	        ip = hammer2_inode_get(dip->pmp, &xop->head, -1, -1);
786a63188c8STomohiro Kusumi 	        hammer2_xop_retire(&xop->head, HAMMER2_XOPMASK_VOP);
787a63188c8STomohiro Kusumi 	        if (ip) {
788a63188c8STomohiro Kusumi 	                hammer2_inode_unlink_finisher(ip, NULL);
789a63188c8STomohiro Kusumi 	                hammer2_inode_unlock(ip);
790a63188c8STomohiro Kusumi 	        }
791a63188c8STomohiro Kusumi 	} else {
792a63188c8STomohiro Kusumi 	        hammer2_xop_retire(&xop->head, HAMMER2_XOPMASK_VOP);
793a63188c8STomohiro Kusumi 	}
794a63188c8STomohiro Kusumi #endif
795a63188c8STomohiro Kusumi 	hammer2_xop_retire(&xop->head, HAMMER2_XOPMASK_VOP);
796a63188c8STomohiro Kusumi 
797a63188c8STomohiro Kusumi 	hammer2_trans_done(spmp, HAMMER2_TRANS_SIDEQ);
798a63188c8STomohiro Kusumi 
799a63188c8STomohiro Kusumi 	return (hammer2_error_to_errno(error));
800a63188c8STomohiro Kusumi }
801a63188c8STomohiro Kusumi 
8023999233bSTomohiro Kusumi int
hammer2_ioctl_pfs_snapshot(hammer2_inode_t * ip,void * data)803a63188c8STomohiro Kusumi hammer2_ioctl_pfs_snapshot(hammer2_inode_t *ip, void *data)
804a63188c8STomohiro Kusumi {
805a63188c8STomohiro Kusumi 	hammer2_ioc_pfs_t *pfs = data;
806a63188c8STomohiro Kusumi 	hammer2_dev_t	*hmp;
807a63188c8STomohiro Kusumi 	hammer2_pfs_t	*pmp;
808a63188c8STomohiro Kusumi 	hammer2_chain_t	*chain;
809a63188c8STomohiro Kusumi 	hammer2_inode_t *nip;
810a63188c8STomohiro Kusumi 	hammer2_tid_t	mtid;
811a63188c8STomohiro Kusumi 	size_t name_len;
812a63188c8STomohiro Kusumi 	int error;
813a63188c8STomohiro Kusumi #if 0
814a63188c8STomohiro Kusumi 	uuid_t opfs_clid;
815a63188c8STomohiro Kusumi #endif
816a63188c8STomohiro Kusumi 
817a63188c8STomohiro Kusumi 	if (pfs->name[0] == 0)
818a63188c8STomohiro Kusumi 		return(EINVAL);
819a63188c8STomohiro Kusumi 	if (pfs->name[sizeof(pfs->name)-1] != 0)
820a63188c8STomohiro Kusumi 		return(EINVAL);
821a63188c8STomohiro Kusumi 
822a63188c8STomohiro Kusumi 	pmp = ip->pmp;
823a63188c8STomohiro Kusumi 	ip = pmp->iroot;
824a63188c8STomohiro Kusumi 
825a63188c8STomohiro Kusumi 	hmp = pmp->pfs_hmps[0];
826a63188c8STomohiro Kusumi 	if (hmp == NULL)
827a63188c8STomohiro Kusumi 		return (EINVAL);
828a63188c8STomohiro Kusumi 
829a63188c8STomohiro Kusumi 	lockmgr(&hmp->bulklk, LK_EXCLUSIVE);
830a63188c8STomohiro Kusumi 
831a63188c8STomohiro Kusumi 	/*
832a63188c8STomohiro Kusumi 	 * NOSYNC is for debugging.  We skip the filesystem sync and use
833a63188c8STomohiro Kusumi 	 * a normal transaction (which is less likely to stall).  used for
834a63188c8STomohiro Kusumi 	 * testing filesystem consistency.
835a63188c8STomohiro Kusumi 	 *
836a63188c8STomohiro Kusumi 	 * In normal mode we sync the filesystem and use a flush transaction.
837a63188c8STomohiro Kusumi 	 */
838a63188c8STomohiro Kusumi 	if (pfs->pfs_flags & HAMMER2_PFSFLAGS_NOSYNC) {
839a63188c8STomohiro Kusumi 		hammer2_trans_init(pmp, 0);
840a63188c8STomohiro Kusumi 	} else {
841a63188c8STomohiro Kusumi 		hammer2_vfs_sync(pmp->mp, MNT_WAIT);
842a63188c8STomohiro Kusumi 		hammer2_trans_init(pmp, HAMMER2_TRANS_ISFLUSH);
843a63188c8STomohiro Kusumi 	}
844a63188c8STomohiro Kusumi 	mtid = hammer2_trans_sub(pmp);
845a63188c8STomohiro Kusumi 	hammer2_inode_lock(ip, 0);
846a63188c8STomohiro Kusumi 	hammer2_inode_modify(ip);
847a63188c8STomohiro Kusumi 	ip->meta.pfs_lsnap_tid = mtid;
848a63188c8STomohiro Kusumi 
849a63188c8STomohiro Kusumi 	/* XXX cluster it! */
850a63188c8STomohiro Kusumi 	chain = hammer2_inode_chain(ip, 0, HAMMER2_RESOLVE_ALWAYS);
851a63188c8STomohiro Kusumi 
852a63188c8STomohiro Kusumi 	name_len = strlen(pfs->name);
853a63188c8STomohiro Kusumi 	hmp = chain->hmp;
854a63188c8STomohiro Kusumi 
855a63188c8STomohiro Kusumi 	/*
856a63188c8STomohiro Kusumi 	 * Create the snapshot directory under the super-root
857a63188c8STomohiro Kusumi 	 *
858a63188c8STomohiro Kusumi 	 * Set PFS type, generate a unique filesystem id, and generate
859a63188c8STomohiro Kusumi 	 * a cluster id.  Use the same clid when snapshotting a PFS root,
860a63188c8STomohiro Kusumi 	 * which theoretically allows the snapshot to be used as part of
861a63188c8STomohiro Kusumi 	 * the same cluster (perhaps as a cache).
862a63188c8STomohiro Kusumi 	 *
863a63188c8STomohiro Kusumi 	 * Note that pfs_lsnap_tid must be set in the snapshot as well,
864a63188c8STomohiro Kusumi 	 * ensuring that any nocrc/nocomp file data modifications force
865a63188c8STomohiro Kusumi 	 * a copy-on-write.
866a63188c8STomohiro Kusumi 	 *
867a63188c8STomohiro Kusumi 	 * Copy the (flushed) blockref array.  Theoretically we could use
868a63188c8STomohiro Kusumi 	 * chain_duplicate() but it becomes difficult to disentangle
869a63188c8STomohiro Kusumi 	 * the shared core so for now just brute-force it.
870a63188c8STomohiro Kusumi 	 */
871a63188c8STomohiro Kusumi 	hammer2_chain_unlock(chain);
872a63188c8STomohiro Kusumi 	nip = hammer2_inode_create_pfs(hmp->spmp, pfs->name, name_len, &error);
873a63188c8STomohiro Kusumi 	hammer2_chain_lock(chain, HAMMER2_RESOLVE_ALWAYS);
874a63188c8STomohiro Kusumi 
875a63188c8STomohiro Kusumi 	if (nip) {
876a63188c8STomohiro Kusumi 		hammer2_dev_t *force_local;
877a63188c8STomohiro Kusumi 		hammer2_chain_t *nchain;
878a63188c8STomohiro Kusumi 		hammer2_inode_data_t *wipdata;
879a63188c8STomohiro Kusumi 		hammer2_tid_t starting_inum;
880a63188c8STomohiro Kusumi 
881a63188c8STomohiro Kusumi 		atomic_set_int(&nip->flags, HAMMER2_INODE_NOSIDEQ);
882a63188c8STomohiro Kusumi 		hammer2_inode_modify(nip);
883a63188c8STomohiro Kusumi 		nchain = hammer2_inode_chain(nip, 0, HAMMER2_RESOLVE_ALWAYS);
884a63188c8STomohiro Kusumi 		error = hammer2_chain_modify(nchain, mtid, 0, 0);
885a63188c8STomohiro Kusumi 		KKASSERT(error == 0);
886a63188c8STomohiro Kusumi 		wipdata = &nchain->data->ipdata;
887a63188c8STomohiro Kusumi 
888a63188c8STomohiro Kusumi 		starting_inum = ip->pmp->inode_tid + 1;
889a63188c8STomohiro Kusumi 		nip->meta.pfs_inum = starting_inum;
890a63188c8STomohiro Kusumi 		nip->meta.pfs_type = HAMMER2_PFSTYPE_MASTER;
891a63188c8STomohiro Kusumi 		nip->meta.pfs_subtype = HAMMER2_PFSSUBTYPE_SNAPSHOT;
892a63188c8STomohiro Kusumi 		nip->meta.op_flags |= HAMMER2_OPFLAG_PFSROOT;
893a63188c8STomohiro Kusumi 		nip->meta.pfs_lsnap_tid = mtid;
894a63188c8STomohiro Kusumi 		nchain->bref.embed.stats = chain->bref.embed.stats;
895a63188c8STomohiro Kusumi 
8963999233bSTomohiro Kusumi 		uuid_create(&nip->meta.pfs_fsid, NULL);
897a63188c8STomohiro Kusumi 
898a63188c8STomohiro Kusumi #if 0
899a63188c8STomohiro Kusumi 		/*
900a63188c8STomohiro Kusumi 		 * Give the snapshot its own private cluster id.  As a
901a63188c8STomohiro Kusumi 		 * snapshot no further synchronization with the original
902a63188c8STomohiro Kusumi 		 * cluster will be done.
903a63188c8STomohiro Kusumi 		 */
904a63188c8STomohiro Kusumi 		if (chain->flags & HAMMER2_CHAIN_PFSBOUNDARY)
905a63188c8STomohiro Kusumi 			nip->meta.pfs_clid = opfs_clid;
906a63188c8STomohiro Kusumi 		else
9073999233bSTomohiro Kusumi 			uuid_create(&nip->meta.pfs_clid, NULL);
908a63188c8STomohiro Kusumi #endif
9093999233bSTomohiro Kusumi 		uuid_create(&nip->meta.pfs_clid, NULL);
910a63188c8STomohiro Kusumi 		nchain->bref.flags |= HAMMER2_BREF_FLAG_PFSROOT;
911a63188c8STomohiro Kusumi 
912a63188c8STomohiro Kusumi 		/* XXX hack blockset copy */
913a63188c8STomohiro Kusumi 		/* XXX doesn't work with real cluster */
914a63188c8STomohiro Kusumi 		wipdata->meta = nip->meta;
915*6b47f3eaSTomohiro Kusumi 		hammer2_spin_ex(&pmp->blockset_spin);
916a63188c8STomohiro Kusumi 		wipdata->u.blockset = pmp->pfs_iroot_blocksets[0];
917*6b47f3eaSTomohiro Kusumi 		hammer2_spin_unex(&pmp->blockset_spin);
918a63188c8STomohiro Kusumi 
919a63188c8STomohiro Kusumi 		KKASSERT(wipdata == &nchain->data->ipdata);
920a63188c8STomohiro Kusumi 
921a63188c8STomohiro Kusumi 		hammer2_chain_unlock(nchain);
922a63188c8STomohiro Kusumi 		hammer2_inode_ref(nip);
923a63188c8STomohiro Kusumi 		hammer2_inode_unlock(nip);
924a63188c8STomohiro Kusumi 		hammer2_inode_chain_sync(nip);
925a63188c8STomohiro Kusumi 		hammer2_inode_chain_flush(nip, HAMMER2_XOP_INODE_STOP |
926a63188c8STomohiro Kusumi 					       HAMMER2_XOP_FSSYNC);
927a63188c8STomohiro Kusumi 					       /* XXX | HAMMER2_XOP_VOLHDR */
928a63188c8STomohiro Kusumi 		hammer2_inode_drop(nip);
929a63188c8STomohiro Kusumi 		/* nip is dead */
930a63188c8STomohiro Kusumi 
931a63188c8STomohiro Kusumi 		force_local = (hmp->hflags & HMNT2_LOCAL) ? hmp : NULL;
932a63188c8STomohiro Kusumi 
933a63188c8STomohiro Kusumi 		hammer2_chain_lock(nchain, HAMMER2_RESOLVE_ALWAYS);
934a63188c8STomohiro Kusumi 		wipdata = &nchain->data->ipdata;
935a63188c8STomohiro Kusumi 		kprintf("SNAPSHOT LOCAL PFS (IOCTL): %s\n", wipdata->filename);
936a63188c8STomohiro Kusumi 		hammer2_pfsalloc(nchain, wipdata, force_local);
937a63188c8STomohiro Kusumi 		nchain->pmp->inode_tid = starting_inum;
938a63188c8STomohiro Kusumi 
939a63188c8STomohiro Kusumi 		hammer2_chain_unlock(nchain);
940a63188c8STomohiro Kusumi 		hammer2_chain_drop(nchain);
941a63188c8STomohiro Kusumi 	}
942a63188c8STomohiro Kusumi 
943a63188c8STomohiro Kusumi 	hammer2_chain_unlock(chain);
944a63188c8STomohiro Kusumi 	hammer2_chain_drop(chain);
945a63188c8STomohiro Kusumi 
946a63188c8STomohiro Kusumi 	hammer2_inode_unlock(ip);
947a63188c8STomohiro Kusumi 	if (pfs->pfs_flags & HAMMER2_PFSFLAGS_NOSYNC) {
948a63188c8STomohiro Kusumi 		hammer2_trans_done(pmp, 0);
949a63188c8STomohiro Kusumi 	} else {
950a63188c8STomohiro Kusumi 		hammer2_trans_done(pmp, HAMMER2_TRANS_ISFLUSH |
951a63188c8STomohiro Kusumi 					HAMMER2_TRANS_SIDEQ);
952a63188c8STomohiro Kusumi 	}
953a63188c8STomohiro Kusumi 
954a63188c8STomohiro Kusumi 	lockmgr(&hmp->bulklk, LK_RELEASE);
955a63188c8STomohiro Kusumi 
956a63188c8STomohiro Kusumi 	return (hammer2_error_to_errno(error));
957a63188c8STomohiro Kusumi }
958a63188c8STomohiro Kusumi 
959a63188c8STomohiro Kusumi /*
960a63188c8STomohiro Kusumi  * Retrieve the raw inode structure, non-inclusive of node-specific data.
961a63188c8STomohiro Kusumi  */
962f804c425STomohiro Kusumi int
hammer2_ioctl_inode_get(hammer2_inode_t * ip,void * data)963a63188c8STomohiro Kusumi hammer2_ioctl_inode_get(hammer2_inode_t *ip, void *data)
964a63188c8STomohiro Kusumi {
965a63188c8STomohiro Kusumi 	hammer2_ioc_inode_t *ino = data;
966a63188c8STomohiro Kusumi 
967a63188c8STomohiro Kusumi 	hammer2_inode_lock(ip, HAMMER2_RESOLVE_SHARED);
968a63188c8STomohiro Kusumi 	ino->data_count = hammer2_inode_data_count(ip);
969a63188c8STomohiro Kusumi 	ino->inode_count = hammer2_inode_inode_count(ip);
970a63188c8STomohiro Kusumi 
971a63188c8STomohiro Kusumi 	bzero(&ino->ip_data, sizeof(ino->ip_data));
972a63188c8STomohiro Kusumi 	ino->ip_data.meta = ip->meta;
973a63188c8STomohiro Kusumi 	hammer2_inode_unlock(ip);
974a63188c8STomohiro Kusumi 
975a63188c8STomohiro Kusumi 	return 0;
976a63188c8STomohiro Kusumi }
977a63188c8STomohiro Kusumi 
978a63188c8STomohiro Kusumi /*
979a63188c8STomohiro Kusumi  * Set various parameters in an inode which cannot be set through
980a63188c8STomohiro Kusumi  * normal filesystem VNOPS.
981a63188c8STomohiro Kusumi  */
982465e1141STomohiro Kusumi int
hammer2_ioctl_inode_set(hammer2_inode_t * ip,void * data)983a63188c8STomohiro Kusumi hammer2_ioctl_inode_set(hammer2_inode_t *ip, void *data)
984a63188c8STomohiro Kusumi {
985a63188c8STomohiro Kusumi 	hammer2_ioc_inode_t *ino = data;
986a63188c8STomohiro Kusumi 
987a63188c8STomohiro Kusumi 	hammer2_trans_init(ip->pmp, 0);
988a63188c8STomohiro Kusumi 	hammer2_inode_lock(ip, 0);
989a63188c8STomohiro Kusumi 
990a63188c8STomohiro Kusumi 	if ((ino->flags & HAMMER2IOC_INODE_FLAG_CHECK) &&
991a63188c8STomohiro Kusumi 	    ip->meta.check_algo != ino->ip_data.meta.check_algo) {
992a63188c8STomohiro Kusumi 		hammer2_inode_modify(ip);
993a63188c8STomohiro Kusumi 		ip->meta.check_algo = ino->ip_data.meta.check_algo;
994a63188c8STomohiro Kusumi 	}
995a63188c8STomohiro Kusumi 	if ((ino->flags & HAMMER2IOC_INODE_FLAG_COMP) &&
996a63188c8STomohiro Kusumi 	    ip->meta.comp_algo != ino->ip_data.meta.comp_algo) {
997a63188c8STomohiro Kusumi 		hammer2_inode_modify(ip);
998a63188c8STomohiro Kusumi 		ip->meta.comp_algo = ino->ip_data.meta.comp_algo;
999a63188c8STomohiro Kusumi 	}
1000a63188c8STomohiro Kusumi 
1001a63188c8STomohiro Kusumi 	/* Ignore these flags for now...*/
1002a63188c8STomohiro Kusumi 	if ((ino->flags & HAMMER2IOC_INODE_FLAG_IQUOTA) &&
1003a63188c8STomohiro Kusumi 	    ip->meta.inode_quota != ino->ip_data.meta.inode_quota) {
1004a63188c8STomohiro Kusumi 		hammer2_inode_modify(ip);
1005a63188c8STomohiro Kusumi 		ip->meta.inode_quota = ino->ip_data.meta.inode_quota;
1006a63188c8STomohiro Kusumi 	}
1007a63188c8STomohiro Kusumi 	if ((ino->flags & HAMMER2IOC_INODE_FLAG_DQUOTA) &&
1008a63188c8STomohiro Kusumi 	    ip->meta.data_quota != ino->ip_data.meta.data_quota) {
1009a63188c8STomohiro Kusumi 		hammer2_inode_modify(ip);
1010a63188c8STomohiro Kusumi 		ip->meta.data_quota = ino->ip_data.meta.data_quota;
1011a63188c8STomohiro Kusumi 	}
1012a63188c8STomohiro Kusumi 	if ((ino->flags & HAMMER2IOC_INODE_FLAG_COPIES) &&
1013a63188c8STomohiro Kusumi 	    ip->meta.ncopies != ino->ip_data.meta.ncopies) {
1014a63188c8STomohiro Kusumi 		hammer2_inode_modify(ip);
1015a63188c8STomohiro Kusumi 		ip->meta.ncopies = ino->ip_data.meta.ncopies;
1016a63188c8STomohiro Kusumi 	}
1017a63188c8STomohiro Kusumi 	hammer2_inode_unlock(ip);
1018a63188c8STomohiro Kusumi 	hammer2_trans_done(ip->pmp, HAMMER2_TRANS_SIDEQ);
1019a63188c8STomohiro Kusumi 
1020a63188c8STomohiro Kusumi 	return (0);
1021a63188c8STomohiro Kusumi }
1022a63188c8STomohiro Kusumi 
1023465e1141STomohiro Kusumi #if 0
1024a63188c8STomohiro Kusumi static
1025a63188c8STomohiro Kusumi int
1026a63188c8STomohiro Kusumi hammer2_ioctl_debug_dump(hammer2_inode_t *ip, u_int flags)
1027a63188c8STomohiro Kusumi {
1028a63188c8STomohiro Kusumi 	hammer2_chain_t *chain;
1029a63188c8STomohiro Kusumi 	int count = 100000;
1030a63188c8STomohiro Kusumi 	int i;
1031a63188c8STomohiro Kusumi 
1032a63188c8STomohiro Kusumi 	for (i = 0; i < ip->cluster.nchains; ++i) {
1033a63188c8STomohiro Kusumi 		chain = ip->cluster.array[i].chain;
1034a63188c8STomohiro Kusumi 		if (chain == NULL)
1035a63188c8STomohiro Kusumi 			continue;
1036a63188c8STomohiro Kusumi 		kprintf("cluster #%d\n", i);
1037a63188c8STomohiro Kusumi 		hammer2_dump_chain(chain, 0, 0, &count, 'i', flags);
1038a63188c8STomohiro Kusumi 	}
1039a63188c8STomohiro Kusumi 	return 0;
1040a63188c8STomohiro Kusumi }
104148ed4577STomohiro Kusumi #endif
1042a63188c8STomohiro Kusumi 
1043a63188c8STomohiro Kusumi /*
1044a63188c8STomohiro Kusumi  * Turn on or off emergency mode on a filesystem.
1045a63188c8STomohiro Kusumi  */
1046a63188c8STomohiro Kusumi int
hammer2_ioctl_emerg_mode(hammer2_inode_t * ip,u_int mode)1047a63188c8STomohiro Kusumi hammer2_ioctl_emerg_mode(hammer2_inode_t *ip, u_int mode)
1048a63188c8STomohiro Kusumi {
1049a63188c8STomohiro Kusumi 	hammer2_pfs_t *pmp;
1050a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
1051a63188c8STomohiro Kusumi 	int i;
1052a63188c8STomohiro Kusumi 
1053a63188c8STomohiro Kusumi 	pmp = ip->pmp;
1054a63188c8STomohiro Kusumi 	if (mode) {
1055a63188c8STomohiro Kusumi 		kprintf("hammer2: WARNING: Emergency mode enabled\n");
1056a63188c8STomohiro Kusumi 		atomic_set_int(&pmp->flags, HAMMER2_PMPF_EMERG);
1057a63188c8STomohiro Kusumi 	} else {
1058a63188c8STomohiro Kusumi 		kprintf("hammer2: WARNING: Emergency mode disabled\n");
1059a63188c8STomohiro Kusumi 		atomic_clear_int(&pmp->flags, HAMMER2_PMPF_EMERG);
1060a63188c8STomohiro Kusumi 	}
1061a63188c8STomohiro Kusumi 	for (i = 0; i < HAMMER2_MAXCLUSTER; ++i) {
1062a63188c8STomohiro Kusumi 		hmp = pmp->pfs_hmps[i];
1063a63188c8STomohiro Kusumi 		if (hmp == NULL)
1064a63188c8STomohiro Kusumi 			continue;
1065a63188c8STomohiro Kusumi 		if (mode)
1066a63188c8STomohiro Kusumi 			atomic_set_int(&hmp->hflags, HMNT2_EMERG);
1067a63188c8STomohiro Kusumi 		else
1068a63188c8STomohiro Kusumi 			atomic_clear_int(&hmp->hflags, HMNT2_EMERG);
1069a63188c8STomohiro Kusumi 	}
1070a63188c8STomohiro Kusumi 	return 0;
1071a63188c8STomohiro Kusumi }
1072a63188c8STomohiro Kusumi 
1073a63188c8STomohiro Kusumi /*
1074a63188c8STomohiro Kusumi  * Do a bulkfree scan on media related to the PFS.  This routine will
1075a63188c8STomohiro Kusumi  * flush all PFSs associated with the media before doing the bulkfree
1076a63188c8STomohiro Kusumi  * scan.
1077a63188c8STomohiro Kusumi  *
1078a63188c8STomohiro Kusumi  * This version can only run on non-clustered media.  A new ioctl or a
1079a63188c8STomohiro Kusumi  * temporary mount of @LOCAL will be needed to run on clustered media.
1080a63188c8STomohiro Kusumi  */
1081a63188c8STomohiro Kusumi int
hammer2_ioctl_bulkfree_scan(hammer2_inode_t * ip,void * data)1082a63188c8STomohiro Kusumi hammer2_ioctl_bulkfree_scan(hammer2_inode_t *ip, void *data)
1083a63188c8STomohiro Kusumi {
1084a63188c8STomohiro Kusumi 	hammer2_ioc_bulkfree_t *bfi = data;
1085a63188c8STomohiro Kusumi 	hammer2_dev_t	*hmp;
1086a63188c8STomohiro Kusumi 	hammer2_pfs_t	*pmp;
1087a63188c8STomohiro Kusumi 	hammer2_chain_t *vchain;
1088a63188c8STomohiro Kusumi 	int error;
1089a63188c8STomohiro Kusumi 	int didsnap;
1090a63188c8STomohiro Kusumi 
1091a63188c8STomohiro Kusumi 	pmp = ip->pmp;
1092a63188c8STomohiro Kusumi 	ip = pmp->iroot;
1093a63188c8STomohiro Kusumi 
1094a63188c8STomohiro Kusumi 	hmp = pmp->pfs_hmps[0];
1095a63188c8STomohiro Kusumi 	if (hmp == NULL)
1096a63188c8STomohiro Kusumi 		return (EINVAL);
1097a63188c8STomohiro Kusumi 	if (bfi == NULL)
1098a63188c8STomohiro Kusumi 		return (EINVAL);
1099a63188c8STomohiro Kusumi 
1100a63188c8STomohiro Kusumi 	/*
1101a63188c8STomohiro Kusumi 	 * Bulkfree has to be serialized to guarantee at least one sync
1102a63188c8STomohiro Kusumi 	 * inbetween bulkfrees.
1103a63188c8STomohiro Kusumi 	 */
11043bbcb743STomohiro Kusumi 	error = lockmgr(&hmp->bflock, LK_EXCLUSIVE | LK_PCATCH);
1105a63188c8STomohiro Kusumi 	if (error)
1106a63188c8STomohiro Kusumi 		return error;
1107a63188c8STomohiro Kusumi 
1108a63188c8STomohiro Kusumi 	/*
1109a63188c8STomohiro Kusumi 	 * Sync all mounts related to the media
1110a63188c8STomohiro Kusumi 	 */
1111a63188c8STomohiro Kusumi 	lockmgr(&hammer2_mntlk, LK_EXCLUSIVE);
1112a63188c8STomohiro Kusumi 	TAILQ_FOREACH(pmp, &hammer2_pfslist, mntentry) {
1113a63188c8STomohiro Kusumi 		int etmp;
1114a63188c8STomohiro Kusumi 		int i;
1115a63188c8STomohiro Kusumi 
1116a63188c8STomohiro Kusumi 		for (i = 0; i < HAMMER2_MAXCLUSTER; ++i) {
1117a63188c8STomohiro Kusumi 			if (pmp->pfs_hmps[i] != hmp)
1118a63188c8STomohiro Kusumi 				continue;
1119a63188c8STomohiro Kusumi 			etmp = hammer2_vfs_sync_pmp(pmp, MNT_WAIT);
1120a63188c8STomohiro Kusumi 			if (etmp && (error == 0 || error == ENOSPC))
1121a63188c8STomohiro Kusumi 				error = etmp;
1122a63188c8STomohiro Kusumi 			break;
1123a63188c8STomohiro Kusumi 		}
1124a63188c8STomohiro Kusumi 	}
1125a63188c8STomohiro Kusumi 	lockmgr(&hammer2_mntlk, LK_RELEASE);
1126a63188c8STomohiro Kusumi 
1127a63188c8STomohiro Kusumi 	if (error && error != ENOSPC)
1128a63188c8STomohiro Kusumi 		goto failed;
1129a63188c8STomohiro Kusumi 
1130a63188c8STomohiro Kusumi 	/*
1131a63188c8STomohiro Kusumi 	 * If we have an ENOSPC error we have to bulkfree on the live
1132a63188c8STomohiro Kusumi 	 * topology.  Otherwise we can bulkfree on a snapshot.
1133a63188c8STomohiro Kusumi 	 */
1134a63188c8STomohiro Kusumi 	if (error) {
1135a63188c8STomohiro Kusumi 		kprintf("hammer2: WARNING! Bulkfree forced to use live "
1136a63188c8STomohiro Kusumi 			"topology due to ENOSPC\n");
1137a63188c8STomohiro Kusumi 		vchain = &hmp->vchain;
1138a63188c8STomohiro Kusumi 		hammer2_chain_ref(vchain);
1139a63188c8STomohiro Kusumi 		didsnap = 0;
1140a63188c8STomohiro Kusumi 	} else {
1141a63188c8STomohiro Kusumi 		vchain = hammer2_chain_bulksnap(hmp);
1142a63188c8STomohiro Kusumi 		didsnap = 1;
1143a63188c8STomohiro Kusumi 	}
1144a63188c8STomohiro Kusumi 
1145a63188c8STomohiro Kusumi 	/*
1146a63188c8STomohiro Kusumi 	 * Normal bulkfree operations do not require a transaction because
1147a63188c8STomohiro Kusumi 	 * they operate on a snapshot, and so can run concurrently with
1148a63188c8STomohiro Kusumi 	 * any operation except another bulkfree.
1149a63188c8STomohiro Kusumi 	 *
1150a63188c8STomohiro Kusumi 	 * If we are running bulkfree on the live topology we have to be
1151a63188c8STomohiro Kusumi 	 * in a FLUSH transaction.
1152a63188c8STomohiro Kusumi 	 */
1153a63188c8STomohiro Kusumi 	if (didsnap == 0)
1154a63188c8STomohiro Kusumi 		hammer2_trans_init(hmp->spmp, HAMMER2_TRANS_ISFLUSH);
1155a63188c8STomohiro Kusumi 
1156a63188c8STomohiro Kusumi 	if (bfi) {
1157a63188c8STomohiro Kusumi 		hammer2_thr_freeze(&hmp->bfthr);
1158a63188c8STomohiro Kusumi 		error = hammer2_bulkfree_pass(hmp, vchain, bfi);
1159a63188c8STomohiro Kusumi 		hammer2_thr_unfreeze(&hmp->bfthr);
1160a63188c8STomohiro Kusumi 	}
1161a63188c8STomohiro Kusumi 	if (didsnap) {
1162a63188c8STomohiro Kusumi 		hammer2_chain_bulkdrop(vchain);
1163a63188c8STomohiro Kusumi 	} else {
1164a63188c8STomohiro Kusumi 		hammer2_chain_drop(vchain);
1165a63188c8STomohiro Kusumi 		hammer2_trans_done(hmp->spmp, HAMMER2_TRANS_ISFLUSH |
1166a63188c8STomohiro Kusumi 					HAMMER2_TRANS_SIDEQ);
1167a63188c8STomohiro Kusumi 	}
1168a63188c8STomohiro Kusumi 	error = hammer2_error_to_errno(error);
1169a63188c8STomohiro Kusumi 
1170a63188c8STomohiro Kusumi failed:
1171a63188c8STomohiro Kusumi 	lockmgr(&hmp->bflock, LK_RELEASE);
1172a63188c8STomohiro Kusumi 	return error;
1173a63188c8STomohiro Kusumi }
1174a63188c8STomohiro Kusumi 
1175a63188c8STomohiro Kusumi /*
1176a63188c8STomohiro Kusumi  * Unconditionally delete meta-data in a hammer2 filesystem
1177a63188c8STomohiro Kusumi  */
1178a63188c8STomohiro Kusumi int
hammer2_ioctl_destroy(hammer2_inode_t * ip,void * data)1179a63188c8STomohiro Kusumi hammer2_ioctl_destroy(hammer2_inode_t *ip, void *data)
1180a63188c8STomohiro Kusumi {
1181a63188c8STomohiro Kusumi 	hammer2_ioc_destroy_t *iocd = data;
1182a63188c8STomohiro Kusumi 	hammer2_pfs_t *pmp = ip->pmp;
1183a63188c8STomohiro Kusumi 	int error;
1184a63188c8STomohiro Kusumi 
1185a63188c8STomohiro Kusumi 	if (pmp->ronly) {
1186a63188c8STomohiro Kusumi 		error = EROFS;
1187a63188c8STomohiro Kusumi 		return error;
1188a63188c8STomohiro Kusumi 	}
1189a63188c8STomohiro Kusumi 
1190a63188c8STomohiro Kusumi 	switch(iocd->cmd) {
1191a63188c8STomohiro Kusumi 	case HAMMER2_DELETE_FILE:
1192a63188c8STomohiro Kusumi 		/*
1193a63188c8STomohiro Kusumi 		 * Destroy a bad directory entry by name.  Caller must
1194a63188c8STomohiro Kusumi 		 * pass the directory as fd.
1195a63188c8STomohiro Kusumi 		 */
1196a63188c8STomohiro Kusumi 		{
1197a63188c8STomohiro Kusumi 		hammer2_xop_unlink_t *xop;
1198a63188c8STomohiro Kusumi 
1199a63188c8STomohiro Kusumi 		if (iocd->path[sizeof(iocd->path)-1]) {
1200a63188c8STomohiro Kusumi 			error = EINVAL;
1201a63188c8STomohiro Kusumi 			break;
1202a63188c8STomohiro Kusumi 		}
1203a63188c8STomohiro Kusumi 		if (ip->meta.type != HAMMER2_OBJTYPE_DIRECTORY) {
1204a63188c8STomohiro Kusumi 			error = EINVAL;
1205a63188c8STomohiro Kusumi 			break;
1206a63188c8STomohiro Kusumi 		}
1207a63188c8STomohiro Kusumi 		hammer2_pfs_memory_wait(pmp);
1208a63188c8STomohiro Kusumi 		hammer2_trans_init(pmp, 0);
1209a63188c8STomohiro Kusumi 		hammer2_inode_lock(ip, 0);
1210a63188c8STomohiro Kusumi 
1211a63188c8STomohiro Kusumi 		xop = hammer2_xop_alloc(ip, HAMMER2_XOP_MODIFYING);
1212a63188c8STomohiro Kusumi 		hammer2_xop_setname(&xop->head, iocd->path, strlen(iocd->path));
1213a63188c8STomohiro Kusumi 		xop->isdir = -1;
1214a63188c8STomohiro Kusumi 		xop->dopermanent = H2DOPERM_PERMANENT |
1215a63188c8STomohiro Kusumi 				   H2DOPERM_FORCE |
1216a63188c8STomohiro Kusumi 				   H2DOPERM_IGNINO;
1217a63188c8STomohiro Kusumi 		hammer2_xop_start(&xop->head, &hammer2_unlink_desc);
1218a63188c8STomohiro Kusumi 
1219a63188c8STomohiro Kusumi 		error = hammer2_xop_collect(&xop->head, 0);
1220a63188c8STomohiro Kusumi 		error = hammer2_error_to_errno(error);
1221a63188c8STomohiro Kusumi 		hammer2_inode_unlock(ip);
1222a63188c8STomohiro Kusumi 		hammer2_xop_retire(&xop->head, HAMMER2_XOPMASK_VOP);
1223a63188c8STomohiro Kusumi 		hammer2_trans_done(pmp, HAMMER2_TRANS_SIDEQ);
1224a63188c8STomohiro Kusumi 		}
1225a63188c8STomohiro Kusumi 		break;
1226a63188c8STomohiro Kusumi 	case HAMMER2_DELETE_INUM:
1227a63188c8STomohiro Kusumi 		/*
1228a63188c8STomohiro Kusumi 		 * Destroy a bad inode by inode number.
1229a63188c8STomohiro Kusumi 		 */
1230a63188c8STomohiro Kusumi 		{
1231a63188c8STomohiro Kusumi 		hammer2_xop_lookup_t *xop;
1232a63188c8STomohiro Kusumi 
1233a63188c8STomohiro Kusumi 		if (iocd->inum < 1) {
1234a63188c8STomohiro Kusumi 			error = EINVAL;
1235a63188c8STomohiro Kusumi 			break;
1236a63188c8STomohiro Kusumi 		}
1237a63188c8STomohiro Kusumi 		hammer2_pfs_memory_wait(pmp);
1238a63188c8STomohiro Kusumi 		hammer2_trans_init(pmp, 0);
1239a63188c8STomohiro Kusumi 
1240a63188c8STomohiro Kusumi 		xop = hammer2_xop_alloc(pmp->iroot, HAMMER2_XOP_MODIFYING);
1241a63188c8STomohiro Kusumi 		xop->lhc = iocd->inum;
1242a63188c8STomohiro Kusumi 		hammer2_xop_start(&xop->head, &hammer2_delete_desc);
1243a63188c8STomohiro Kusumi 		error = hammer2_xop_collect(&xop->head, 0);
1244a63188c8STomohiro Kusumi 		error = hammer2_error_to_errno(error);
1245a63188c8STomohiro Kusumi 		hammer2_xop_retire(&xop->head, HAMMER2_XOPMASK_VOP);
1246a63188c8STomohiro Kusumi 		hammer2_trans_done(pmp, HAMMER2_TRANS_SIDEQ);
1247a63188c8STomohiro Kusumi 		}
1248a63188c8STomohiro Kusumi 		break;
1249a63188c8STomohiro Kusumi 	default:
1250a63188c8STomohiro Kusumi 		error = EINVAL;
1251a63188c8STomohiro Kusumi 		break;
1252a63188c8STomohiro Kusumi 	}
1253a63188c8STomohiro Kusumi 	return error;
1254a63188c8STomohiro Kusumi }
1255a63188c8STomohiro Kusumi 
1256a63188c8STomohiro Kusumi /*
1257a63188c8STomohiro Kusumi  * Grow a filesystem into its partition size
1258a63188c8STomohiro Kusumi  */
1259afa5234bSTomohiro Kusumi int
hammer2_ioctl_growfs(hammer2_inode_t * ip,void * data,struct ucred * cred)1260a63188c8STomohiro Kusumi hammer2_ioctl_growfs(hammer2_inode_t *ip, void *data, struct ucred *cred)
1261a63188c8STomohiro Kusumi {
1262a63188c8STomohiro Kusumi 	hammer2_ioc_growfs_t *grow = data;
1263a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
1264961db90eSTomohiro Kusumi 	hammer2_off_t size, delta;
1265a63188c8STomohiro Kusumi 	hammer2_tid_t mtid;
1266961db90eSTomohiro Kusumi 	struct partinfo part;
1267afa5234bSTomohiro Kusumi 	struct stat st;
1268afa5234bSTomohiro Kusumi 	struct m_buf *bp;
1269a63188c8STomohiro Kusumi 	int error;
1270a63188c8STomohiro Kusumi 	int i;
1271a63188c8STomohiro Kusumi 
1272a63188c8STomohiro Kusumi 	hmp = ip->pmp->pfs_hmps[0];
1273a63188c8STomohiro Kusumi 
1274a63188c8STomohiro Kusumi 	if (hmp->nvolumes > 1) {
1275a63188c8STomohiro Kusumi 		kprintf("hammer2: growfs currently unsupported "
1276a63188c8STomohiro Kusumi 			"with multiple volumes\n");
1277a63188c8STomohiro Kusumi 		return EOPNOTSUPP;
1278a63188c8STomohiro Kusumi 	}
1279961db90eSTomohiro Kusumi 	KKASSERT(hmp->total_size == hmp->voldata.volu_size);
1280a63188c8STomohiro Kusumi 
1281a63188c8STomohiro Kusumi 	/*
1282a63188c8STomohiro Kusumi 	 * Extract from disklabel
1283a63188c8STomohiro Kusumi 	 */
1284afa5234bSTomohiro Kusumi 	if (ioctl(hmp->devvp->fs->fd, DIOCGPART, &part) == 0) {
1285961db90eSTomohiro Kusumi 		size = part.media_size;
1286961db90eSTomohiro Kusumi 		kprintf("hammer2: growfs partition-auto to %016jx\n",
1287961db90eSTomohiro Kusumi 			(intmax_t)size);
1288afa5234bSTomohiro Kusumi 	} else if (fstat(hmp->devvp->fs->fd, &st) == 0) {
1289afa5234bSTomohiro Kusumi 		size = st.st_size;
1290961db90eSTomohiro Kusumi 		kprintf("hammer2: growfs fstat-auto to %016jx\n",
1291961db90eSTomohiro Kusumi 			(intmax_t)size);
1292a63188c8STomohiro Kusumi 	} else {
1293a63188c8STomohiro Kusumi 		return EINVAL;
1294a63188c8STomohiro Kusumi 	}
1295961db90eSTomohiro Kusumi 
1296961db90eSTomohiro Kusumi 	/*
1297961db90eSTomohiro Kusumi 	 * Expand to devvp size unless specified.
1298961db90eSTomohiro Kusumi 	 */
1299961db90eSTomohiro Kusumi 	grow->modified = 0;
1300961db90eSTomohiro Kusumi 	if (grow->size == 0) {
1301961db90eSTomohiro Kusumi 		grow->size = size;
1302961db90eSTomohiro Kusumi 	} else if (grow->size > size) {
1303961db90eSTomohiro Kusumi 		kprintf("hammer2: growfs size %016jx exceeds device size "
1304961db90eSTomohiro Kusumi 			"%016jx\n",
1305961db90eSTomohiro Kusumi 			(intmax_t)grow->size, (intmax_t)size);
1306961db90eSTomohiro Kusumi 		return EINVAL;
1307a63188c8STomohiro Kusumi 	}
1308a63188c8STomohiro Kusumi 
1309a63188c8STomohiro Kusumi 	/*
1310a63188c8STomohiro Kusumi 	 * This is typically ~8MB alignment to avoid edge cases accessing
1311a63188c8STomohiro Kusumi 	 * reserved blocks at the base of each 2GB zone.
1312a63188c8STomohiro Kusumi 	 */
1313a63188c8STomohiro Kusumi 	grow->size &= ~HAMMER2_VOLUME_ALIGNMASK64;
1314a63188c8STomohiro Kusumi 	delta = grow->size - hmp->voldata.volu_size;
1315a63188c8STomohiro Kusumi 
1316a63188c8STomohiro Kusumi 	/*
1317a63188c8STomohiro Kusumi 	 * Maximum allowed size is 2^63
1318a63188c8STomohiro Kusumi 	 */
1319a63188c8STomohiro Kusumi 	if (grow->size > 0x7FFFFFFFFFFFFFFFLU) {
1320a63188c8STomohiro Kusumi 		kprintf("hammer2: growfs failure, limit is 2^63 - 1 bytes\n");
1321a63188c8STomohiro Kusumi 		return EINVAL;
1322a63188c8STomohiro Kusumi 	}
1323a63188c8STomohiro Kusumi 
1324a63188c8STomohiro Kusumi 	/*
1325a63188c8STomohiro Kusumi 	 * We can't shrink a filesystem
1326a63188c8STomohiro Kusumi 	 */
1327a63188c8STomohiro Kusumi 	if (grow->size < hmp->voldata.volu_size) {
1328a63188c8STomohiro Kusumi 		kprintf("hammer2: growfs failure, "
1329961db90eSTomohiro Kusumi 			"would shrink from %016jx to %016jx\n",
1330a63188c8STomohiro Kusumi 			(intmax_t)hmp->voldata.volu_size,
1331a63188c8STomohiro Kusumi 			(intmax_t)grow->size);
1332a63188c8STomohiro Kusumi 		return EINVAL;
1333a63188c8STomohiro Kusumi 	}
1334a63188c8STomohiro Kusumi 
1335a63188c8STomohiro Kusumi 	if (delta == 0) {
1336a63188c8STomohiro Kusumi 		kprintf("hammer2: growfs - size did not change\n");
1337a63188c8STomohiro Kusumi 		return 0;
1338a63188c8STomohiro Kusumi 	}
1339a63188c8STomohiro Kusumi 
1340a63188c8STomohiro Kusumi 	/*
1341a63188c8STomohiro Kusumi 	 * Clear any new volume header backups that we extend into.
1342a63188c8STomohiro Kusumi 	 * Skip volume headers that are already part of the filesystem.
1343a63188c8STomohiro Kusumi 	 */
1344a63188c8STomohiro Kusumi 	for (i = 0; i < HAMMER2_NUM_VOLHDRS; ++i) {
1345a63188c8STomohiro Kusumi 		if (i * HAMMER2_ZONE_BYTES64 < hmp->voldata.volu_size)
1346a63188c8STomohiro Kusumi 			continue;
1347a63188c8STomohiro Kusumi 		if (i * HAMMER2_ZONE_BYTES64 >= grow->size)
1348a63188c8STomohiro Kusumi 			break;
1349a63188c8STomohiro Kusumi 		kprintf("hammer2: growfs - clear volhdr %d ", i);
1350afa5234bSTomohiro Kusumi 		error = breadx(hmp->devvp, i * HAMMER2_ZONE_BYTES64,
1351a63188c8STomohiro Kusumi 			      HAMMER2_VOLUME_BYTES, &bp);
1352a63188c8STomohiro Kusumi 		if (error) {
1353a63188c8STomohiro Kusumi 			brelse(bp);
1354a63188c8STomohiro Kusumi 			kprintf("I/O error %d\n", error);
1355a63188c8STomohiro Kusumi 			return EINVAL;
1356a63188c8STomohiro Kusumi 		}
1357a63188c8STomohiro Kusumi 		bzero(bp->b_data, HAMMER2_VOLUME_BYTES);
1358a63188c8STomohiro Kusumi 		error = bwrite(bp);
1359a63188c8STomohiro Kusumi 		if (error) {
1360a63188c8STomohiro Kusumi 			kprintf("I/O error %d\n", error);
1361a63188c8STomohiro Kusumi 			return EINVAL;
1362a63188c8STomohiro Kusumi 		}
1363a63188c8STomohiro Kusumi 		kprintf("\n");
1364a63188c8STomohiro Kusumi 	}
1365a63188c8STomohiro Kusumi 
1366a63188c8STomohiro Kusumi 	hammer2_trans_init(hmp->spmp, HAMMER2_TRANS_ISFLUSH);
1367a63188c8STomohiro Kusumi 	mtid = hammer2_trans_sub(hmp->spmp);
1368a63188c8STomohiro Kusumi 
1369961db90eSTomohiro Kusumi 	kprintf("hammer2: growfs - expand by %016jx to %016jx mtid %016jx\n",
1370961db90eSTomohiro Kusumi 		(intmax_t)delta, (intmax_t)grow->size, (intmax_t)mtid);
1371a63188c8STomohiro Kusumi 
1372a63188c8STomohiro Kusumi 
1373a63188c8STomohiro Kusumi 	hammer2_voldata_lock(hmp);
1374a63188c8STomohiro Kusumi 	hammer2_voldata_modify(hmp);
1375a63188c8STomohiro Kusumi 
1376a63188c8STomohiro Kusumi 	/*
1377a63188c8STomohiro Kusumi 	 * NOTE: Just adjusting total_size for a single-volume filesystem
1378a63188c8STomohiro Kusumi 	 *	 or for the last volume in a multi-volume filesystem, is
1379a63188c8STomohiro Kusumi 	 *	 fine.  But we can't grow any other partition in a multi-volume
1380a63188c8STomohiro Kusumi 	 *	 filesystem.  For now we just punt (at the top) on any
1381a63188c8STomohiro Kusumi 	 *	 multi-volume filesystem.
1382a63188c8STomohiro Kusumi 	 */
1383a63188c8STomohiro Kusumi 	hmp->voldata.volu_size = grow->size;
1384a63188c8STomohiro Kusumi 	hmp->voldata.total_size += delta;
1385a63188c8STomohiro Kusumi 	hmp->voldata.allocator_size += delta;
1386a63188c8STomohiro Kusumi 	hmp->voldata.allocator_free += delta;
1387a63188c8STomohiro Kusumi 	hmp->total_size += delta;
1388a63188c8STomohiro Kusumi 	hmp->volumes[0].size += delta;	/* note: indexes first (only) volume */
1389a63188c8STomohiro Kusumi 
1390a63188c8STomohiro Kusumi 	hammer2_voldata_unlock(hmp);
1391a63188c8STomohiro Kusumi 
1392a63188c8STomohiro Kusumi 	hammer2_trans_done(hmp->spmp, HAMMER2_TRANS_ISFLUSH |
1393a63188c8STomohiro Kusumi 				      HAMMER2_TRANS_SIDEQ);
1394a63188c8STomohiro Kusumi 	grow->modified = 1;
1395a63188c8STomohiro Kusumi 
1396a63188c8STomohiro Kusumi 	/*
1397a63188c8STomohiro Kusumi 	 * Flush the mess right here and now.  We could just let the
1398a63188c8STomohiro Kusumi 	 * filesystem syncer do it, but this was a sensitive operation
1399a63188c8STomohiro Kusumi 	 * so don't take any chances.
1400a63188c8STomohiro Kusumi 	 */
1401a63188c8STomohiro Kusumi 	hammer2_vfs_sync(ip->pmp->mp, MNT_WAIT);
1402a63188c8STomohiro Kusumi 
1403a63188c8STomohiro Kusumi 	return 0;
1404a63188c8STomohiro Kusumi }
1405a63188c8STomohiro Kusumi 
1406afa5234bSTomohiro Kusumi #if 0
1407a63188c8STomohiro Kusumi /*
1408a63188c8STomohiro Kusumi  * Get a list of volumes.
1409a63188c8STomohiro Kusumi  */
1410a63188c8STomohiro Kusumi static int
1411a63188c8STomohiro Kusumi hammer2_ioctl_volume_list(hammer2_inode_t *ip, void *data)
1412a63188c8STomohiro Kusumi {
1413a63188c8STomohiro Kusumi 	hammer2_ioc_volume_list_t *vollist = data;
1414a63188c8STomohiro Kusumi 	hammer2_ioc_volume_t entry;
1415a63188c8STomohiro Kusumi 	hammer2_volume_t *vol;
1416a63188c8STomohiro Kusumi 	hammer2_dev_t *hmp;
1417a63188c8STomohiro Kusumi 	hammer2_pfs_t *pmp;
1418a63188c8STomohiro Kusumi 	int i, error = 0, cnt = 0;
1419a63188c8STomohiro Kusumi 
1420a63188c8STomohiro Kusumi 	pmp = ip->pmp;
1421a63188c8STomohiro Kusumi 	hmp = pmp->pfs_hmps[0];
1422a63188c8STomohiro Kusumi 	if (hmp == NULL)
1423a63188c8STomohiro Kusumi 		return (EINVAL);
1424a63188c8STomohiro Kusumi 
1425a63188c8STomohiro Kusumi 	hammer2_voldata_lock(hmp);
1426a63188c8STomohiro Kusumi 	for (i = 0; i < hmp->nvolumes; ++i) {
1427a63188c8STomohiro Kusumi 		if (cnt >= vollist->nvolumes)
1428a63188c8STomohiro Kusumi 			break;
1429a63188c8STomohiro Kusumi 		vol = &hmp->volumes[i];
1430a63188c8STomohiro Kusumi 		bzero(&entry, sizeof(entry));
1431a63188c8STomohiro Kusumi 		/* copy hammer2_volume_t fields */
1432a63188c8STomohiro Kusumi 		entry.id = vol->id;
1433a63188c8STomohiro Kusumi 		bcopy(vol->dev->path, entry.path, sizeof(entry.path));
1434a63188c8STomohiro Kusumi 		entry.offset = vol->offset;
1435a63188c8STomohiro Kusumi 		entry.size = vol->size;
1436a63188c8STomohiro Kusumi 		error = copyout(&entry, &vollist->volumes[cnt], sizeof(entry));
1437a63188c8STomohiro Kusumi 		if (error)
1438a63188c8STomohiro Kusumi 			goto failed;
1439a63188c8STomohiro Kusumi 		cnt++;
1440a63188c8STomohiro Kusumi 	}
1441a63188c8STomohiro Kusumi 	vollist->nvolumes = cnt;
1442a63188c8STomohiro Kusumi 	vollist->version = hmp->voldata.version;
1443a63188c8STomohiro Kusumi 	bcopy(pmp->pfs_names[0], vollist->pfs_name, sizeof(vollist->pfs_name));
1444a63188c8STomohiro Kusumi failed:
1445a63188c8STomohiro Kusumi 	hammer2_voldata_unlock(hmp);
1446a63188c8STomohiro Kusumi 
1447a63188c8STomohiro Kusumi 	return error;
1448a63188c8STomohiro Kusumi }
1449a63188c8STomohiro Kusumi #endif
1450