libzfs/common/libzfs_diff.c

88 get_stats_for_obj(differ_info_t *di, const char *dsname, uint64_t obj,
98 	error = ioctl(di->zhp->zfs_hdl->libzfs_fd, ZFS_IOC_OBJ_TO_STATS, &zc);
99 	di->zerr = errno;
104 		ASSERT(di->zerr == 0);
109 	if (di->zerr == EPERM) {
110 		(void) snprintf(di->errbuf, sizeof (di->errbuf),
116 		(void) snprintf(di->errbuf, sizeof (di->errbuf),
193 print_cmn(FILE *fp, differ_info_t *di, const char *file)
195 	stream_bytes(fp, di->dsmnt);
200 print_rename(FILE *fp, differ_info_t *di, const char *old, const char *new,
203 	if (di->timestamped)
208 	if (di->classify) {
212 	print_cmn(fp, di, old);
213 	if (di->scripted)
217 	print_cmn(fp, di, new);
222 print_link_change(FILE *fp, differ_info_t *di, int delta, const char *file,
225 	if (di->timestamped)
230 	if (di->classify) {
234 	print_cmn(fp, di, file);
240 print_file(FILE *fp, differ_info_t *di, char type, const char *file,
243 	if (di->timestamped)
248 	if (di->classify) {
252 	print_cmn(fp, di, file);
257 write_inuse_diffs_one(FILE *fp, differ_info_t *di, uint64_t dobj)
266 	if (dobj == di->shares)
275 	fobjerr = get_stats_for_obj(di, di->fromsnap, dobj, fobjname,
277 	if (fobjerr && di->zerr != ENOENT && di->zerr != ENOTSUP)
280 	tobjerr = get_stats_for_obj(di, di->tosnap, dobj, tobjname,
282 	if (tobjerr && di->zerr != ENOENT && di->zerr != ENOTSUP)
289 		ASSERT(di->zerr == ENOENT || di->zerr == ENOTSUP);
290 		di->zerr = 0;
294 	di->zerr = 0; /* negate get_stats_for_obj() from side that failed */
305 			print_link_change(fp, di, change, tobjname, &tsb);
308 		print_file(fp, di, ZDIFF_ADDED, tobjname, &tsb);
312 			print_link_change(fp, di, change, fobjname, &fsb);
315 		print_file(fp, di, ZDIFF_REMOVED, fobjname, &fsb);
330 			print_link_change(fp, di, change,
333 			print_file(fp, di, ZDIFF_MODIFIED, fobjname, &tsb);
335 			print_rename(fp, di, fobjname, tobjname, &tsb);
340 		print_file(fp, di, ZDIFF_REMOVED, fobjname, &fsb);
341 		print_file(fp, di, ZDIFF_ADDED, tobjname, &tsb);
347 write_inuse_diffs(FILE *fp, differ_info_t *di, dmu_diff_record_t *dr)
353 		if (err = write_inuse_diffs_one(fp, di, o))
360 describe_free(FILE *fp, differ_info_t *di, uint64_t object, char *namebuf,
365 	if (get_stats_for_obj(di, di->fromsnap, object, namebuf,
368 		if (di->zerr == ENOENT && sb.zs_links == 0) {
369 			di->zerr = 0;
375 	print_file(fp, di, ZDIFF_REMOVED, namebuf, &sb);
380 write_free_diffs(FILE *fp, differ_info_t *di, dmu_diff_record_t *dr)
383 	libzfs_handle_t *lhdl = di->zhp->zfs_hdl;
386 	(void) strlcpy(zc.zc_name, di->fromsnap, sizeof (zc.zc_name));
389 	ASSERT(di->zerr == 0);
396 			if (zc.zc_obj == di->shares) {
403 			err = describe_free(fp, di, zc.zc_obj, fobjname,
410 			(void) snprintf(di->errbuf, sizeof (di->errbuf),
414 			di->zerr = errno;
418 	if (di->zerr)
426 	differ_info_t *di = arg;
431 	if ((ofp = fdopen(di->outputfd, "w")) == NULL) {
432 		di->zerr = errno;
433 		(void) strerror_r(errno, di->errbuf, sizeof (di->errbuf));
434 		(void) close(di->datafd);
444 			rv = read(di->datafd, cp, len);
450 			di->zerr = EPIPE;
459 			err = write_free_diffs(ofp, di, &dr);
462 			err = write_inuse_diffs(ofp, di, &dr);
465 			di->zerr = EPIPE;
469 		if (err || di->zerr)
474 	(void) close(di->datafd);
477 	if (di->zerr) {
478 		ASSERT(di->zerr == EINVAL);
479 		(void) snprintf(di->errbuf, sizeof (di->errbuf),
488 find_shares_object(differ_info_t *di)
493 	(void) strlcpy(fullpath, di->dsmnt, MAXPATHLEN);
498 		(void) snprintf(di->errbuf, sizeof (di->errbuf),
500 		return (zfs_error(di->zhp->zfs_hdl, EZFS_DIFF, di->errbuf));
506 	di->shares = (uint64_t)sb.st_ino;
511 make_temp_snapshot(differ_info_t *di)
513 	libzfs_handle_t *hdl = di->zhp->zfs_hdl;
518 	(void) strlcpy(zc.zc_name, di->ds, sizeof (zc.zc_name));
519 	zc.zc_cleanup_fd = di->cleanupfd;
524 			(void) snprintf(di->errbuf, sizeof (di->errbuf),
528 			return (zfs_error(hdl, EZFS_DIFF, di->errbuf));
530 			(void) snprintf(di->errbuf, sizeof (di->errbuf),
533 			return (zfs_standard_error(hdl, err, di->errbuf));
537 	di->tmpsnap = zfs_strdup(hdl, zc.zc_value);
538 	di->tosnap = zfs_asprintf(hdl, "%s@%s", di->ds, di->tmpsnap);
543 teardown_differ_info(differ_info_t *di)
545 	free(di->ds);
546 	free(di->dsmnt);
547 	free(di->fromsnap);
548 	free(di->frommnt);
549 	free(di->tosnap);
550 	free(di->tmpsnap);
551 	free(di->tomnt);
552 	(void) close(di->cleanupfd);
556 get_snapshot_names(differ_info_t *di, const char *fromsnap,
559 	libzfs_handle_t *hdl = di->zhp->zfs_hdl;
575 		(void) snprintf(di->errbuf, sizeof (di->errbuf),
582 			    di->errbuf));
589 		di->fromsnap = zfs_strdup(hdl, fromsnap);
590 		di->ds = zfs_strdup(hdl, fromsnap);
591 		di->ds[fdslen] = '\0';
594 		return (make_temp_snapshot(di));
597 	(void) snprintf(di->errbuf, sizeof (di->errbuf),
610 		return (zfs_error(hdl, EZFS_INVALIDNAME, di->errbuf));
621 		di->ds = zfs_alloc(di->zhp->zfs_hdl, tdslen + 1);
622 		(void) strncpy(di->ds, tosnap, tdslen);
623 		di->ds[tdslen] = '\0';
625 		zhp = zfs_open(hdl, di->ds, ZFS_TYPE_FILESYSTEM);
638 			(void) snprintf(di->errbuf, sizeof (di->errbuf),
641 			return (zfs_error(hdl, EZFS_INVALIDNAME, di->errbuf));
646 		di->isclone = B_TRUE;
647 		di->fromsnap = zfs_strdup(hdl, fromsnap);
649 			di->tosnap = zfs_strdup(hdl, tosnap);
651 			return (make_temp_snapshot(di));
656 		di->ds = zfs_alloc(hdl, dslen + 1);
657 		(void) strncpy(di->ds, fdslen ? fromsnap : tosnap, dslen);
658 		di->ds[dslen] = '\0';
660 		di->fromsnap = zfs_asprintf(hdl, "%s%s", di->ds, atptrf);
662 			di->tosnap = zfs_asprintf(hdl, "%s%s", di->ds, atptrt);
664 			return (make_temp_snapshot(di));
671 get_mountpoint(differ_info_t *di, char *dsnm, char **mntpt)
675 	mounted = is_mounted(di->zhp->zfs_hdl, dsnm, mntpt);
677 		(void) snprintf(di->errbuf, sizeof (di->errbuf),
680 		return (zfs_error(di->zhp->zfs_hdl, EZFS_BADTYPE, di->errbuf));
690 get_mountpoints(differ_info_t *di)
698 	if (get_mountpoint(di, di->ds, &di->dsmnt) != 0)
701 	strptr = strchr(di->tosnap, '@');
703 	di->tomnt = zfs_asprintf(di->zhp->zfs_hdl, "%s%s%s", di->dsmnt,
706 	strptr = strchr(di->fromsnap, '@');
709 	frommntpt = di->dsmnt;
710 	if (di->isclone) {
715 		err = get_mountpoint(di, di->fromsnap, &mntpt);
722 	di->frommnt = zfs_asprintf(di->zhp->zfs_hdl, "%s%s%s", frommntpt,
725 	if (di->isclone)
733     const char *tosnap, differ_info_t *di)
735 	di->zhp = zhp;
737 	di->cleanupfd = open(ZFS_DEV, O_RDWR|O_EXCL);
738 	VERIFY(di->cleanupfd >= 0);
740 	if (get_snapshot_names(di, fromsnap, tosnap) != 0)
743 	if (get_mountpoints(di) != 0)
746 	if (find_shares_object(di) != 0)
758 	differ_info_t di = { 0 };
766 	if (setup_differ_info(zhp, fromsnap, tosnap, &di)) {
767 		teardown_differ_info(&di);
773 		teardown_differ_info(&di);
777 	di.scripted = (flags & ZFS_DIFF_PARSEABLE);
778 	di.classify = (flags & ZFS_DIFF_CLASSIFY);
779 	di.timestamped = (flags & ZFS_DIFF_TIMESTAMP);
781 	di.outputfd = outfd;
782 	di.datafd = pipefd[0];
784 	if (pthread_create(&tid, NULL, differ, &di)) {
788 		teardown_differ_info(&di);
794 	(void) strlcpy(zc.zc_value, di.fromsnap, strlen(di.fromsnap) + 1);
795 	(void) strlcpy(zc.zc_name, di.tosnap, strlen(di.tosnap) + 1);
810 		} else if (errno != EPIPE || di.zerr == 0) {
816 		teardown_differ_info(&di);
817 		if (di.zerr != 0 && di.zerr != EPIPE) {
818 			zfs_error_aux(zhp->zfs_hdl, strerror(di.zerr));
819 			return (zfs_error(zhp->zfs_hdl, EZFS_DIFF, di.errbuf));
828 	if (di.zerr != 0) {
829 		zfs_error_aux(zhp->zfs_hdl, strerror(di.zerr));
830 		return (zfs_error(zhp->zfs_hdl, EZFS_DIFF, di.errbuf));
832 	teardown_differ_info(&di);