2 * Module for snapshot IO using snapper
4 * Copyright (C) David Disseldorp 2012-2014
6 * Portions taken from vfs_shadow_copy2.c:
7 * Copyright (C) Andrew Tridgell 2007
8 * Copyright (C) Ed Plese 2009
9 * Copyright (C) Volker Lendecke 2011
10 * Copyright (C) Christian Ambach 2011
11 * Copyright (C) Michael Adam 2013
13 * This program is free software; you can redistribute it and/or modify
14 * it under the terms of the GNU General Public License as published by
15 * the Free Software Foundation; either version 3 of the License, or
16 * (at your option) any later version.
18 * This program is distributed in the hope that it will be useful,
19 * but WITHOUT ANY WARRANTY; without even the implied warranty of
20 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
21 * GNU General Public License for more details.
23 * You should have received a copy of the GNU General Public License
24 * along with this program; if not, see <http://www.gnu.org/licenses/>.
27 #include <dbus/dbus.h>
28 #ifdef HAVE_LINUX_IOCTL_H
29 #include <linux/ioctl.h>
31 #include <sys/ioctl.h>
35 #include "include/ntioctl.h"
36 #include "include/smb.h"
37 #include "system/filesys.h"
38 #include "smbd/smbd.h"
39 #include "lib/util/tevent_ntstatus.h"
41 #define SNAPPER_SIG_LIST_SNAPS_RSP "a(uquxussa{ss})"
42 #define SNAPPER_SIG_LIST_CONFS_RSP "a(ssa{ss})"
43 #define SNAPPER_SIG_CREATE_SNAP_RSP "u"
44 #define SNAPPER_SIG_DEL_SNAPS_RSP ""
45 #define SNAPPER_SIG_STRING_DICT "{ss}"
60 uint32_t num_user_data
;
61 struct snapper_dict
*user_data
;
68 struct snapper_dict
*attrs
;
72 const char *snapper_err_str
;
74 } snapper_err_map
[] = {
75 { "error.no_permissions", NT_STATUS_ACCESS_DENIED
},
78 static NTSTATUS
snapper_err_ntstatus_map(const char *snapper_err_str
)
82 if (snapper_err_str
== NULL
) {
83 return NT_STATUS_UNSUCCESSFUL
;
85 for (i
= 0; i
< ARRAY_SIZE(snapper_err_map
); i
++) {
86 if (!strcmp(snapper_err_map
[i
].snapper_err_str
,
88 return snapper_err_map
[i
].status
;
91 DEBUG(2, ("no explicit mapping for dbus error: %s\n", snapper_err_str
));
93 return NT_STATUS_UNSUCCESSFUL
;
97 * Strings are UTF-8. Other characters must be encoded hexadecimal as "\x??".
98 * As a consequence "\" must be encoded as "\\".
100 static NTSTATUS
snapper_dbus_str_encode(TALLOC_CTX
*mem_ctx
, const char *in_str
,
109 if (in_str
== NULL
) {
110 return NT_STATUS_INVALID_PARAMETER
;
113 in_len
= strlen(in_str
);
115 /* output can be max 4 times the length of @in_str, +1 for terminator */
116 out_len
= (in_len
* 4) + 1;
118 out_str
= talloc_array(mem_ctx
, char, out_len
);
119 if (out_str
== NULL
) {
120 return NT_STATUS_NO_MEMORY
;
124 for (i
= 0; i
< in_len
; i
++) {
127 if (in_str
[i
] == '\\') {
128 pushed
= snprintf(out_str
+ out_off
, out_len
- out_off
,
130 } else if ((unsigned char)in_str
[i
] > 127) {
131 pushed
= snprintf(out_str
+ out_off
, out_len
- out_off
,
132 "\\x%02x", (unsigned char)in_str
[i
]);
134 /* regular character */
135 *(out_str
+ out_off
) = in_str
[i
];
136 pushed
= sizeof(char);
138 if (pushed
>= out_len
- out_off
) {
139 /* truncated, should never happen */
140 talloc_free(out_str
);
141 return NT_STATUS_INTERNAL_ERROR
;
146 *(out_str
+ out_off
) = '\0';
152 static NTSTATUS
snapper_dbus_str_decode(TALLOC_CTX
*mem_ctx
, const char *in_str
,
161 if (in_str
== NULL
) {
162 return NT_STATUS_INVALID_PARAMETER
;
165 in_len
= strlen(in_str
);
167 /* output cannot be larger than input, +1 for terminator */
168 out_len
= in_len
+ 1;
170 out_str
= talloc_array(mem_ctx
, char, out_len
);
171 if (out_str
== NULL
) {
172 return NT_STATUS_NO_MEMORY
;
176 for (i
= 0; i
< in_len
; i
++) {
179 unsigned int non_ascii_byte
;
181 if (in_str
[i
] != '\\') {
182 out_str
[out_off
] = in_str
[i
];
188 if (in_str
[i
] == '\\') {
189 out_str
[out_off
] = '\\';
192 } else if (in_str
[i
] != 'x') {
193 goto err_invalid_src_encoding
;
196 /* non-ASCII, encoded as two hex chars */
197 for (j
= 0; j
< 2; j
++) {
199 if ((in_str
[i
] == '\0') || !isxdigit(in_str
[i
])) {
200 goto err_invalid_src_encoding
;
202 hex_buf
[j
] = in_str
[i
];
206 sscanf(hex_buf
, "%x", &non_ascii_byte
);
207 out_str
[out_off
] = (unsigned char)non_ascii_byte
;
211 out_str
[out_off
] = '\0';
215 err_invalid_src_encoding
:
216 DEBUG(0, ("invalid encoding %s\n", in_str
));
217 return NT_STATUS_INVALID_PARAMETER
;
220 static DBusConnection
*snapper_dbus_conn_create(void)
223 DBusConnection
*dconn
;
225 dbus_error_init(&err
);
228 * Always create a new DBus connection, to ensure snapperd detects the
229 * correct client [E]UID. With dbus_bus_get() it does not!
231 dconn
= dbus_bus_get_private(DBUS_BUS_SYSTEM
, &err
);
232 if (dbus_error_is_set(&err
)) {
233 DEBUG(0, ("dbus connection error: %s\n", err
.message
));
234 dbus_error_free(&err
);
240 /* dbus_bus_get_private() sets exit-on-disconnect by default, undo it */
241 dbus_connection_set_exit_on_disconnect(dconn
, false);
246 static void snapper_dbus_conn_destroy(DBusConnection
*dconn
)
249 DEBUG(2, ("attempt to destroy NULL dbus connection\n"));
253 dbus_connection_close(dconn
);
254 dbus_connection_unref(dconn
);
258 * send the message @send_msg over the dbus and wait for a response, return the
259 * responsee via @recv_msg_out.
260 * @send_msg is not freed, dbus_message_unref() must be handled by the caller.
262 static NTSTATUS
snapper_dbus_msg_xchng(DBusConnection
*dconn
,
263 DBusMessage
*send_msg
,
264 DBusMessage
**recv_msg_out
)
266 DBusPendingCall
*pending
;
267 DBusMessage
*recv_msg
;
269 /* send message and get a handle for a reply */
270 if (!dbus_connection_send_with_reply(dconn
, send_msg
, &pending
, -1)) {
271 return NT_STATUS_NO_MEMORY
;
273 if (NULL
== pending
) {
274 DEBUG(0, ("dbus msg send failed\n"));
275 return NT_STATUS_UNSUCCESSFUL
;
278 dbus_connection_flush(dconn
);
280 /* block until we receive a reply */
281 dbus_pending_call_block(pending
);
283 /* get the reply message */
284 recv_msg
= dbus_pending_call_steal_reply(pending
);
285 if (recv_msg
== NULL
) {
286 DEBUG(0, ("Reply Null\n"));
287 return NT_STATUS_UNSUCCESSFUL
;
289 /* free the pending message handle */
290 dbus_pending_call_unref(pending
);
291 *recv_msg_out
= recv_msg
;
296 static NTSTATUS
snapper_type_check(DBusMessageIter
*iter
,
299 int type
= dbus_message_iter_get_arg_type(iter
);
300 if (type
!= expected_type
) {
301 DEBUG(0, ("got type %d, expecting %d\n",
302 type
, expected_type
));
303 return NT_STATUS_INVALID_PARAMETER
;
309 static NTSTATUS
snapper_type_check_get(DBusMessageIter
*iter
,
314 status
= snapper_type_check(iter
, expected_type
);
315 if (!NT_STATUS_IS_OK(status
)) {
319 dbus_message_iter_get_basic(iter
, val
);
324 static NTSTATUS
snapper_dict_unpack(TALLOC_CTX
*mem_ctx
,
325 DBusMessageIter
*iter
,
326 struct snapper_dict
*dict_out
)
330 DBusMessageIter dct_iter
;
334 status
= snapper_type_check(iter
, DBUS_TYPE_DICT_ENTRY
);
335 if (!NT_STATUS_IS_OK(status
)) {
338 dbus_message_iter_recurse(iter
, &dct_iter
);
340 status
= snapper_type_check_get(&dct_iter
, DBUS_TYPE_STRING
,
342 if (!NT_STATUS_IS_OK(status
)) {
345 status
= snapper_dbus_str_decode(mem_ctx
, key_encoded
, &dict_out
->key
);
346 if (!NT_STATUS_IS_OK(status
)) {
350 dbus_message_iter_next(&dct_iter
);
351 status
= snapper_type_check_get(&dct_iter
, DBUS_TYPE_STRING
,
353 if (!NT_STATUS_IS_OK(status
)) {
354 talloc_free(dict_out
->key
);
357 status
= snapper_dbus_str_decode(mem_ctx
, val_encoded
, &dict_out
->val
);
358 if (!NT_STATUS_IS_OK(status
)) {
359 talloc_free(dict_out
->key
);
366 static void snapper_dict_array_print(uint32_t num_dicts
,
367 struct snapper_dict
*dicts
)
371 for (i
= 0; i
< num_dicts
; i
++) {
372 DEBUG(10, ("dict (key: %s, val: %s)\n",
373 dicts
[i
].key
, dicts
[i
].val
));
377 static NTSTATUS
snapper_dict_array_unpack(TALLOC_CTX
*mem_ctx
,
378 DBusMessageIter
*iter
,
379 uint32_t *num_dicts_out
,
380 struct snapper_dict
**dicts_out
)
383 DBusMessageIter array_iter
;
385 struct snapper_dict
*dicts
= NULL
;
387 status
= snapper_type_check(iter
, DBUS_TYPE_ARRAY
);
388 if (!NT_STATUS_IS_OK(status
)) {
391 dbus_message_iter_recurse(iter
, &array_iter
);
394 while (dbus_message_iter_get_arg_type(&array_iter
)
395 != DBUS_TYPE_INVALID
) {
397 dicts
= talloc_realloc(mem_ctx
, dicts
, struct snapper_dict
,
402 status
= snapper_dict_unpack(mem_ctx
, &array_iter
,
403 &dicts
[num_dicts
- 1]);
404 if (!NT_STATUS_IS_OK(status
)) {
408 dbus_message_iter_next(&array_iter
);
411 *num_dicts_out
= num_dicts
;
417 static NTSTATUS
snapper_list_confs_pack(DBusMessage
**req_msg_out
)
421 msg
= dbus_message_new_method_call("org.opensuse.Snapper",
422 "/org/opensuse/Snapper",
423 "org.opensuse.Snapper",
426 DEBUG(0, ("null msg\n"));
427 return NT_STATUS_NO_MEMORY
;
430 /* no arguments to append */
436 static NTSTATUS
snapper_conf_unpack(TALLOC_CTX
*mem_ctx
,
437 DBusMessageIter
*iter
,
438 struct snapper_conf
*conf_out
)
441 DBusMessageIter st_iter
;
445 status
= snapper_type_check(iter
, DBUS_TYPE_STRUCT
);
446 if (!NT_STATUS_IS_OK(status
)) {
449 dbus_message_iter_recurse(iter
, &st_iter
);
451 status
= snapper_type_check_get(&st_iter
, DBUS_TYPE_STRING
,
453 if (!NT_STATUS_IS_OK(status
)) {
457 status
= snapper_dbus_str_decode(mem_ctx
, name_encoded
,
459 if (!NT_STATUS_IS_OK(status
)) {
463 dbus_message_iter_next(&st_iter
);
464 status
= snapper_type_check_get(&st_iter
, DBUS_TYPE_STRING
,
466 if (!NT_STATUS_IS_OK(status
)) {
467 talloc_free(conf_out
->name
);
471 status
= snapper_dbus_str_decode(mem_ctx
, mnt_encoded
,
473 if (!NT_STATUS_IS_OK(status
)) {
474 talloc_free(conf_out
->name
);
478 dbus_message_iter_next(&st_iter
);
479 status
= snapper_dict_array_unpack(mem_ctx
, &st_iter
,
480 &conf_out
->num_attrs
,
482 if (!NT_STATUS_IS_OK(status
)) {
483 talloc_free(conf_out
->mnt
);
484 talloc_free(conf_out
->name
);
491 static struct snapper_conf
*snapper_conf_array_base_find(int32_t num_confs
,
492 struct snapper_conf
*confs
,
497 for (i
= 0; i
< num_confs
; i
++) {
498 if (strcmp(confs
[i
].mnt
, base
) == 0) {
499 DEBUG(5, ("found snapper conf %s for path %s\n",
500 confs
[i
].name
, base
));
504 DEBUG(5, ("config for base %s not found\n", base
));
509 static void snapper_conf_array_print(int32_t num_confs
,
510 struct snapper_conf
*confs
)
514 for (i
= 0; i
< num_confs
; i
++) {
515 DEBUG(10, ("name: %s, mnt: %s\n",
516 confs
[i
].name
, confs
[i
].mnt
));
517 snapper_dict_array_print(confs
[i
].num_attrs
, confs
[i
].attrs
);
521 static NTSTATUS
snapper_conf_array_unpack(TALLOC_CTX
*mem_ctx
,
522 DBusMessageIter
*iter
,
523 uint32_t *num_confs_out
,
524 struct snapper_conf
**confs_out
)
528 struct snapper_conf
*confs
= NULL
;
529 DBusMessageIter array_iter
;
532 status
= snapper_type_check(iter
, DBUS_TYPE_ARRAY
);
533 if (!NT_STATUS_IS_OK(status
)) {
536 dbus_message_iter_recurse(iter
, &array_iter
);
539 while (dbus_message_iter_get_arg_type(&array_iter
)
540 != DBUS_TYPE_INVALID
) {
542 confs
= talloc_realloc(mem_ctx
, confs
, struct snapper_conf
,
547 status
= snapper_conf_unpack(confs
, &array_iter
,
548 &confs
[num_confs
- 1]);
549 if (!NT_STATUS_IS_OK(status
)) {
553 dbus_message_iter_next(&array_iter
);
556 *num_confs_out
= num_confs
;
562 static NTSTATUS
snapper_list_confs_unpack(TALLOC_CTX
*mem_ctx
,
563 DBusConnection
*dconn
,
564 DBusMessage
*rsp_msg
,
565 uint32_t *num_confs_out
,
566 struct snapper_conf
**confs_out
)
569 DBusMessageIter iter
;
572 struct snapper_conf
*confs
;
575 msg_type
= dbus_message_get_type(rsp_msg
);
576 if (msg_type
== DBUS_MESSAGE_TYPE_ERROR
) {
577 const char *err_str
= dbus_message_get_error_name(rsp_msg
);
578 DEBUG(0, ("list_confs error response: %s\n", err_str
));
579 return snapper_err_ntstatus_map(err_str
);
582 if (msg_type
!= DBUS_MESSAGE_TYPE_METHOD_RETURN
) {
583 DEBUG(0, ("unexpected list_confs ret type: %d\n",
585 return NT_STATUS_INVALID_PARAMETER
;
588 sig
= dbus_message_get_signature(rsp_msg
);
590 || (strcmp(sig
, SNAPPER_SIG_LIST_CONFS_RSP
) != 0)) {
591 DEBUG(0, ("bad list confs response sig: %s, expected: %s\n",
592 (sig
? sig
: "NULL"), SNAPPER_SIG_LIST_CONFS_RSP
));
593 return NT_STATUS_INVALID_PARAMETER
;
596 if (!dbus_message_iter_init(rsp_msg
, &iter
)) {
597 /* FIXME return empty? */
598 DEBUG(0, ("Message has no arguments!\n"));
599 return NT_STATUS_INVALID_PARAMETER
;
602 status
= snapper_conf_array_unpack(mem_ctx
, &iter
, &num_confs
, &confs
);
603 if (!NT_STATUS_IS_OK(status
)) {
604 DEBUG(0, ("failed to unpack conf array\n"));
608 snapper_conf_array_print(num_confs
, confs
);
610 *num_confs_out
= num_confs
;
616 static NTSTATUS
snapper_list_snaps_pack(TALLOC_CTX
*mem_ctx
,
618 DBusMessage
**req_msg_out
)
621 DBusMessageIter args
;
625 msg
= dbus_message_new_method_call("org.opensuse.Snapper", /* target for the method call */
626 "/org/opensuse/Snapper", /* object to call on */
627 "org.opensuse.Snapper", /* interface to call on */
628 "ListSnapshots"); /* method name */
630 DEBUG(0, ("failed to create list snaps message\n"));
631 return NT_STATUS_NO_MEMORY
;
634 status
= snapper_dbus_str_encode(mem_ctx
, snapper_conf
, &conf_encoded
);
635 if (!NT_STATUS_IS_OK(status
)) {
636 dbus_message_unref(msg
);
640 /* append arguments */
641 dbus_message_iter_init_append(msg
, &args
);
642 if (!dbus_message_iter_append_basic(&args
, DBUS_TYPE_STRING
,
644 talloc_free(conf_encoded
);
645 dbus_message_unref(msg
);
646 return NT_STATUS_NO_MEMORY
;
654 static NTSTATUS
snapper_snap_struct_unpack(TALLOC_CTX
*mem_ctx
,
655 DBusMessageIter
*iter
,
656 struct snapper_snap
*snap_out
)
659 DBusMessageIter st_iter
;
661 char *cleanup_encoded
;
663 status
= snapper_type_check(iter
, DBUS_TYPE_STRUCT
);
664 if (!NT_STATUS_IS_OK(status
)) {
667 dbus_message_iter_recurse(iter
, &st_iter
);
669 status
= snapper_type_check_get(&st_iter
, DBUS_TYPE_UINT32
,
671 if (!NT_STATUS_IS_OK(status
)) {
675 dbus_message_iter_next(&st_iter
);
676 status
= snapper_type_check_get(&st_iter
, DBUS_TYPE_UINT16
,
678 if (!NT_STATUS_IS_OK(status
)) {
682 dbus_message_iter_next(&st_iter
);
683 status
= snapper_type_check_get(&st_iter
, DBUS_TYPE_UINT32
,
685 if (!NT_STATUS_IS_OK(status
)) {
689 dbus_message_iter_next(&st_iter
);
690 status
= snapper_type_check_get(&st_iter
, DBUS_TYPE_INT64
,
692 if (!NT_STATUS_IS_OK(status
)) {
696 dbus_message_iter_next(&st_iter
);
697 status
= snapper_type_check_get(&st_iter
, DBUS_TYPE_UINT32
,
698 &snap_out
->creator_uid
);
699 if (!NT_STATUS_IS_OK(status
)) {
703 dbus_message_iter_next(&st_iter
);
704 status
= snapper_type_check_get(&st_iter
, DBUS_TYPE_STRING
,
706 if (!NT_STATUS_IS_OK(status
)) {
710 status
= snapper_dbus_str_decode(mem_ctx
, desc_encoded
,
712 if (!NT_STATUS_IS_OK(status
)) {
716 dbus_message_iter_next(&st_iter
);
717 status
= snapper_type_check_get(&st_iter
, DBUS_TYPE_STRING
,
719 if (!NT_STATUS_IS_OK(status
)) {
720 talloc_free(snap_out
->desc
);
724 status
= snapper_dbus_str_decode(mem_ctx
, cleanup_encoded
,
726 if (!NT_STATUS_IS_OK(status
)) {
727 talloc_free(snap_out
->desc
);
731 dbus_message_iter_next(&st_iter
);
732 status
= snapper_dict_array_unpack(mem_ctx
, &st_iter
,
733 &snap_out
->num_user_data
,
734 &snap_out
->user_data
);
735 if (!NT_STATUS_IS_OK(status
)) {
736 talloc_free(snap_out
->cleanup
);
737 talloc_free(snap_out
->desc
);
744 static void snapper_snap_array_print(int32_t num_snaps
,
745 struct snapper_snap
*snaps
)
749 for (i
= 0; i
< num_snaps
; i
++) {
750 DEBUG(10, ("id: %u, "
757 (unsigned int)snaps
[i
].id
,
758 (unsigned int)snaps
[i
].type
,
759 (unsigned int)snaps
[i
].pre_id
,
760 (long int)snaps
[i
].time
,
761 (unsigned int)snaps
[i
].creator_uid
,
764 snapper_dict_array_print(snaps
[i
].num_user_data
,
769 static NTSTATUS
snapper_snap_array_unpack(TALLOC_CTX
*mem_ctx
,
770 DBusMessageIter
*iter
,
771 uint32_t *num_snaps_out
,
772 struct snapper_snap
**snaps_out
)
776 struct snapper_snap
*snaps
= NULL
;
777 DBusMessageIter array_iter
;
780 status
= snapper_type_check(iter
, DBUS_TYPE_ARRAY
);
781 if (!NT_STATUS_IS_OK(status
)) {
784 dbus_message_iter_recurse(iter
, &array_iter
);
787 while (dbus_message_iter_get_arg_type(&array_iter
)
788 != DBUS_TYPE_INVALID
) {
790 snaps
= talloc_realloc(mem_ctx
, snaps
, struct snapper_snap
,
795 status
= snapper_snap_struct_unpack(snaps
, &array_iter
,
796 &snaps
[num_snaps
- 1]);
797 if (!NT_STATUS_IS_OK(status
)) {
801 dbus_message_iter_next(&array_iter
);
804 *num_snaps_out
= num_snaps
;
810 static NTSTATUS
snapper_list_snaps_unpack(TALLOC_CTX
*mem_ctx
,
811 DBusMessage
*rsp_msg
,
812 uint32_t *num_snaps_out
,
813 struct snapper_snap
**snaps_out
)
816 DBusMessageIter iter
;
819 struct snapper_snap
*snaps
;
822 msg_type
= dbus_message_get_type(rsp_msg
);
823 if (msg_type
== DBUS_MESSAGE_TYPE_ERROR
) {
824 const char *err_str
= dbus_message_get_error_name(rsp_msg
);
825 DEBUG(0, ("list_snaps error response: %s\n", err_str
));
826 return snapper_err_ntstatus_map(err_str
);
829 if (msg_type
!= DBUS_MESSAGE_TYPE_METHOD_RETURN
) {
830 DEBUG(0,("unexpected list_snaps ret type: %d\n",
832 return NT_STATUS_INVALID_PARAMETER
;
835 sig
= dbus_message_get_signature(rsp_msg
);
837 || (strcmp(sig
, SNAPPER_SIG_LIST_SNAPS_RSP
) != 0)) {
838 DEBUG(0, ("bad list snaps response sig: %s, "
840 (sig
? sig
: "NULL"),
841 SNAPPER_SIG_LIST_SNAPS_RSP
));
842 return NT_STATUS_INVALID_PARAMETER
;
845 /* read the parameters */
846 if (!dbus_message_iter_init(rsp_msg
, &iter
)) {
847 DEBUG(0, ("response has no arguments!\n"));
848 return NT_STATUS_INVALID_PARAMETER
;
851 status
= snapper_snap_array_unpack(mem_ctx
, &iter
, &num_snaps
, &snaps
);
852 if (!NT_STATUS_IS_OK(status
)) {
853 DEBUG(0, ("failed to unpack snap array\n"));
854 return NT_STATUS_INVALID_PARAMETER
;
857 snapper_snap_array_print(num_snaps
, snaps
);
859 *num_snaps_out
= num_snaps
;
865 static NTSTATUS
snapper_create_snap_pack(TALLOC_CTX
*mem_ctx
,
866 const char *snapper_conf
,
868 uint32_t num_user_data
,
869 struct snapper_dict
*user_data
,
870 DBusMessage
**req_msg_out
)
873 DBusMessageIter args
;
874 DBusMessageIter array_iter
;
875 DBusMessageIter struct_iter
;
876 const char *empty
= "";
883 DEBUG(10, ("CreateSingleSnapshot: %s, %s, %s, num user %u\n",
884 snapper_conf
, desc
, empty
, num_user_data
));
886 enc_ctx
= talloc_new(mem_ctx
);
887 if (enc_ctx
== NULL
) {
888 return NT_STATUS_NO_MEMORY
;
891 msg
= dbus_message_new_method_call("org.opensuse.Snapper",
892 "/org/opensuse/Snapper",
893 "org.opensuse.Snapper",
894 "CreateSingleSnapshot");
896 DEBUG(0, ("failed to create req msg\n"));
897 talloc_free(enc_ctx
);
898 return NT_STATUS_NO_MEMORY
;
901 status
= snapper_dbus_str_encode(enc_ctx
, snapper_conf
, &str_encoded
);
902 if (!NT_STATUS_IS_OK(status
)) {
903 dbus_message_unref(msg
);
904 talloc_free(enc_ctx
);
908 /* append arguments */
909 dbus_message_iter_init_append(msg
, &args
);
910 ok
= dbus_message_iter_append_basic(&args
, DBUS_TYPE_STRING
,
913 dbus_message_unref(msg
);
914 talloc_free(enc_ctx
);
915 return NT_STATUS_NO_MEMORY
;
918 status
= snapper_dbus_str_encode(enc_ctx
, desc
, &str_encoded
);
919 if (!NT_STATUS_IS_OK(status
)) {
920 dbus_message_unref(msg
);
921 talloc_free(enc_ctx
);
925 ok
= dbus_message_iter_append_basic(&args
, DBUS_TYPE_STRING
,
928 dbus_message_unref(msg
);
929 talloc_free(enc_ctx
);
930 return NT_STATUS_NO_MEMORY
;
933 /* cleanup - no need to encode empty string */
934 ok
= dbus_message_iter_append_basic(&args
, DBUS_TYPE_STRING
,
937 dbus_message_unref(msg
);
938 talloc_free(enc_ctx
);
939 return NT_STATUS_NO_MEMORY
;
942 ok
= dbus_message_iter_open_container(&args
, DBUS_TYPE_ARRAY
,
943 SNAPPER_SIG_STRING_DICT
,
946 dbus_message_unref(msg
);
947 talloc_free(enc_ctx
);
948 return NT_STATUS_NO_MEMORY
;
951 for (i
= 0; i
< num_user_data
; i
++) {
952 ok
= dbus_message_iter_open_container(&array_iter
,
953 DBUS_TYPE_DICT_ENTRY
,
956 dbus_message_unref(msg
);
957 talloc_free(enc_ctx
);
958 return NT_STATUS_NO_MEMORY
;
961 status
= snapper_dbus_str_encode(enc_ctx
, user_data
[i
].key
,
963 if (!NT_STATUS_IS_OK(status
)) {
964 dbus_message_unref(msg
);
965 talloc_free(enc_ctx
);
969 ok
= dbus_message_iter_append_basic(&struct_iter
,
973 dbus_message_unref(msg
);
974 talloc_free(enc_ctx
);
975 return NT_STATUS_NO_MEMORY
;
978 status
= snapper_dbus_str_encode(enc_ctx
, user_data
[i
].val
,
980 if (!NT_STATUS_IS_OK(status
)) {
981 dbus_message_unref(msg
);
982 talloc_free(enc_ctx
);
986 ok
= dbus_message_iter_append_basic(&struct_iter
,
990 dbus_message_unref(msg
);
991 talloc_free(enc_ctx
);
992 return NT_STATUS_NO_MEMORY
;
995 ok
= dbus_message_iter_close_container(&array_iter
, &struct_iter
);
997 dbus_message_unref(msg
);
998 talloc_free(enc_ctx
);
999 return NT_STATUS_NO_MEMORY
;
1003 ok
= dbus_message_iter_close_container(&args
, &array_iter
);
1005 dbus_message_unref(msg
);
1006 talloc_free(enc_ctx
);
1007 return NT_STATUS_NO_MEMORY
;
1012 return NT_STATUS_OK
;
1015 static NTSTATUS
snapper_create_snap_unpack(DBusConnection
*conn
,
1016 DBusMessage
*rsp_msg
,
1017 uint32_t *snap_id_out
)
1020 DBusMessageIter iter
;
1025 msg_type
= dbus_message_get_type(rsp_msg
);
1026 if (msg_type
== DBUS_MESSAGE_TYPE_ERROR
) {
1027 const char *err_str
= dbus_message_get_error_name(rsp_msg
);
1028 DEBUG(0, ("create snap error response: %s, euid %d egid %d\n",
1029 err_str
, geteuid(), getegid()));
1030 return snapper_err_ntstatus_map(err_str
);
1033 if (msg_type
!= DBUS_MESSAGE_TYPE_METHOD_RETURN
) {
1034 DEBUG(0, ("unexpected create snap ret type: %d\n",
1036 return NT_STATUS_INVALID_PARAMETER
;
1039 sig
= dbus_message_get_signature(rsp_msg
);
1041 || (strcmp(sig
, SNAPPER_SIG_CREATE_SNAP_RSP
) != 0)) {
1042 DEBUG(0, ("bad create snap response sig: %s, expected: %s\n",
1043 (sig
? sig
: "NULL"), SNAPPER_SIG_CREATE_SNAP_RSP
));
1044 return NT_STATUS_INVALID_PARAMETER
;
1047 /* read the parameters */
1048 if (!dbus_message_iter_init(rsp_msg
, &iter
)) {
1049 DEBUG(0, ("response has no arguments!\n"));
1050 return NT_STATUS_INVALID_PARAMETER
;
1053 status
= snapper_type_check_get(&iter
, DBUS_TYPE_UINT32
, &snap_id
);
1054 if (!NT_STATUS_IS_OK(status
)) {
1057 *snap_id_out
= snap_id
;
1059 return NT_STATUS_OK
;
1062 static NTSTATUS
snapper_del_snap_pack(TALLOC_CTX
*mem_ctx
,
1063 const char *snapper_conf
,
1065 DBusMessage
**req_msg_out
)
1068 DBusMessageIter args
;
1069 DBusMessageIter array_iter
;
1074 msg
= dbus_message_new_method_call("org.opensuse.Snapper",
1075 "/org/opensuse/Snapper",
1076 "org.opensuse.Snapper",
1079 DEBUG(0, ("failed to create req msg\n"));
1080 return NT_STATUS_NO_MEMORY
;
1083 status
= snapper_dbus_str_encode(mem_ctx
, snapper_conf
, &conf_encoded
);
1084 if (!NT_STATUS_IS_OK(status
)) {
1085 dbus_message_unref(msg
);
1089 /* append arguments */
1090 dbus_message_iter_init_append(msg
, &args
);
1091 ok
= dbus_message_iter_append_basic(&args
, DBUS_TYPE_STRING
,
1094 talloc_free(conf_encoded
);
1095 dbus_message_unref(msg
);
1096 return NT_STATUS_NO_MEMORY
;
1099 ok
= dbus_message_iter_open_container(&args
, DBUS_TYPE_ARRAY
,
1100 DBUS_TYPE_UINT32_AS_STRING
,
1103 talloc_free(conf_encoded
);
1104 dbus_message_unref(msg
);
1105 return NT_STATUS_NO_MEMORY
;
1108 ok
= dbus_message_iter_append_basic(&array_iter
,
1112 talloc_free(conf_encoded
);
1113 dbus_message_unref(msg
);
1114 return NT_STATUS_NO_MEMORY
;
1117 dbus_message_iter_close_container(&args
, &array_iter
);
1120 return NT_STATUS_OK
;
1123 static NTSTATUS
snapper_del_snap_unpack(DBusConnection
*conn
,
1124 DBusMessage
*rsp_msg
)
1129 msg_type
= dbus_message_get_type(rsp_msg
);
1130 if (msg_type
== DBUS_MESSAGE_TYPE_ERROR
) {
1131 const char *err_str
= dbus_message_get_error_name(rsp_msg
);
1132 DEBUG(0, ("del snap error response: %s\n", err_str
));
1133 return snapper_err_ntstatus_map(err_str
);
1136 if (msg_type
!= DBUS_MESSAGE_TYPE_METHOD_RETURN
) {
1137 DEBUG(0, ("unexpected del snap ret type: %d\n",
1139 return NT_STATUS_INVALID_PARAMETER
;
1142 sig
= dbus_message_get_signature(rsp_msg
);
1144 || (strcmp(sig
, SNAPPER_SIG_DEL_SNAPS_RSP
) != 0)) {
1145 DEBUG(0, ("bad create snap response sig: %s, expected: %s\n",
1146 (sig
? sig
: "NULL"), SNAPPER_SIG_DEL_SNAPS_RSP
));
1147 return NT_STATUS_INVALID_PARAMETER
;
1150 /* no parameters in response */
1152 return NT_STATUS_OK
;
1155 static NTSTATUS
snapper_list_snaps_at_time_pack(TALLOC_CTX
*mem_ctx
,
1156 const char *snapper_conf
,
1159 DBusMessage
**req_msg_out
)
1162 DBusMessageIter args
;
1166 msg
= dbus_message_new_method_call("org.opensuse.Snapper",
1167 "/org/opensuse/Snapper",
1168 "org.opensuse.Snapper",
1169 "ListSnapshotsAtTime");
1171 DEBUG(0, ("failed to create list snaps message\n"));
1172 return NT_STATUS_NO_MEMORY
;
1175 status
= snapper_dbus_str_encode(mem_ctx
, snapper_conf
, &conf_encoded
);
1176 if (!NT_STATUS_IS_OK(status
)) {
1177 dbus_message_unref(msg
);
1181 dbus_message_iter_init_append(msg
, &args
);
1182 if (!dbus_message_iter_append_basic(&args
, DBUS_TYPE_STRING
,
1184 talloc_free(conf_encoded
);
1185 dbus_message_unref(msg
);
1186 return NT_STATUS_NO_MEMORY
;
1189 if (!dbus_message_iter_append_basic(&args
, DBUS_TYPE_INT64
,
1191 talloc_free(conf_encoded
);
1192 dbus_message_unref(msg
);
1193 return NT_STATUS_NO_MEMORY
;
1196 if (!dbus_message_iter_append_basic(&args
, DBUS_TYPE_INT64
,
1198 talloc_free(conf_encoded
);
1199 dbus_message_unref(msg
);
1200 return NT_STATUS_NO_MEMORY
;
1205 return NT_STATUS_OK
;
1207 /* no snapper_list_snaps_at_time_unpack, use snapper_list_snaps_unpack */
1210 * Determine the snapper snapshot id given a path.
1211 * Ideally this should be determined via a lookup.
1213 static NTSTATUS
snapper_snap_path_to_id(TALLOC_CTX
*mem_ctx
,
1214 const char *snap_path
,
1215 uint32_t *snap_id_out
)
1222 path_dup
= talloc_strdup(mem_ctx
, snap_path
);
1223 if (path_dup
== NULL
) {
1224 return NT_STATUS_NO_MEMORY
;
1227 /* trim trailing '/' */
1228 str_idx
= path_dup
+ strlen(path_dup
) - 1;
1229 while (*str_idx
== '/') {
1234 str_idx
= strrchr(path_dup
, '/');
1235 if ((str_idx
== NULL
)
1236 || (strcmp(str_idx
+ 1, "snapshot") != 0)) {
1237 talloc_free(path_dup
);
1238 return NT_STATUS_INVALID_PARAMETER
;
1241 while (*str_idx
== '/') {
1246 str_idx
= strrchr(path_dup
, '/');
1247 if (str_idx
== NULL
) {
1248 talloc_free(path_dup
);
1249 return NT_STATUS_INVALID_PARAMETER
;
1253 snap_id
= strtoul(str_idx
, &str_end
, 10);
1254 if (str_idx
== str_end
) {
1255 talloc_free(path_dup
);
1256 return NT_STATUS_INVALID_PARAMETER
;
1259 talloc_free(path_dup
);
1260 *snap_id_out
= snap_id
;
1261 return NT_STATUS_OK
;
1265 * Determine the snapper snapshot path given an id and base.
1266 * Ideally this should be determined via a lookup.
1268 static NTSTATUS
snapper_snap_id_to_path(TALLOC_CTX
*mem_ctx
,
1269 const char *base_path
,
1271 char **snap_path_out
)
1275 snap_path
= talloc_asprintf(mem_ctx
, "%s/.snapshots/%u/snapshot",
1276 base_path
, snap_id
);
1277 if (snap_path
== NULL
) {
1278 return NT_STATUS_NO_MEMORY
;
1281 *snap_path_out
= snap_path
;
1282 return NT_STATUS_OK
;
1285 static NTSTATUS
snapper_get_conf_call(TALLOC_CTX
*mem_ctx
,
1286 DBusConnection
*dconn
,
1288 char **conf_name_out
,
1289 char **base_path_out
)
1292 DBusMessage
*req_msg
;
1293 DBusMessage
*rsp_msg
;
1294 uint32_t num_confs
= 0;
1295 struct snapper_conf
*confs
= NULL
;
1296 struct snapper_conf
*conf
;
1300 status
= snapper_list_confs_pack(&req_msg
);
1301 if (!NT_STATUS_IS_OK(status
)) {
1305 status
= snapper_dbus_msg_xchng(dconn
, req_msg
, &rsp_msg
);
1306 if (!NT_STATUS_IS_OK(status
)) {
1310 status
= snapper_list_confs_unpack(mem_ctx
, dconn
, rsp_msg
,
1311 &num_confs
, &confs
);
1312 if (!NT_STATUS_IS_OK(status
)) {
1317 * for now we only support shares where the path directly corresponds
1318 * to a snapper configuration.
1320 conf
= snapper_conf_array_base_find(num_confs
, confs
,
1323 status
= NT_STATUS_NOT_SUPPORTED
;
1324 goto err_array_free
;
1327 conf_name
= talloc_strdup(mem_ctx
, conf
->name
);
1328 if (conf_name
== NULL
) {
1329 status
= NT_STATUS_NO_MEMORY
;
1330 goto err_array_free
;
1332 base_path
= talloc_strdup(mem_ctx
, conf
->mnt
);
1333 if (base_path
== NULL
) {
1334 status
= NT_STATUS_NO_MEMORY
;
1335 goto err_conf_name_free
;
1339 dbus_message_unref(rsp_msg
);
1340 dbus_message_unref(req_msg
);
1342 *conf_name_out
= conf_name
;
1343 *base_path_out
= base_path
;
1345 return NT_STATUS_OK
;
1348 talloc_free(conf_name
);
1352 dbus_message_unref(rsp_msg
);
1354 dbus_message_unref(req_msg
);
1360 * Check whether a path can be shadow copied. Return the base volume, allowing
1361 * the caller to determine if multiple paths lie on the same base volume.
1363 static NTSTATUS
snapper_snap_check_path(struct vfs_handle_struct
*handle
,
1364 TALLOC_CTX
*mem_ctx
,
1365 const char *service_path
,
1369 DBusConnection
*dconn
;
1373 dconn
= snapper_dbus_conn_create();
1374 if (dconn
== NULL
) {
1375 return NT_STATUS_UNSUCCESSFUL
;
1378 status
= snapper_get_conf_call(mem_ctx
, dconn
, service_path
,
1379 &conf_name
, &base_path
);
1380 if (!NT_STATUS_IS_OK(status
)) {
1381 goto err_conn_close
;
1384 talloc_free(conf_name
);
1385 *base_volume
= base_path
;
1386 snapper_dbus_conn_destroy(dconn
);
1388 return NT_STATUS_OK
;
1391 snapper_dbus_conn_destroy(dconn
);
1395 static NTSTATUS
snapper_create_snap_call(TALLOC_CTX
*mem_ctx
,
1396 DBusConnection
*dconn
,
1397 const char *conf_name
,
1398 const char *base_path
,
1399 const char *snap_desc
,
1400 uint32_t num_user_data
,
1401 struct snapper_dict
*user_data
,
1402 char **snap_path_out
)
1405 DBusMessage
*req_msg
;
1406 DBusMessage
*rsp_msg
;
1407 uint32_t snap_id
= 0;
1410 status
= snapper_create_snap_pack(mem_ctx
,
1416 if (!NT_STATUS_IS_OK(status
)) {
1420 status
= snapper_dbus_msg_xchng(dconn
, req_msg
, &rsp_msg
);
1421 if (!NT_STATUS_IS_OK(status
)) {
1425 status
= snapper_create_snap_unpack(dconn
, rsp_msg
, &snap_id
);
1426 if (!NT_STATUS_IS_OK(status
)) {
1430 status
= snapper_snap_id_to_path(mem_ctx
, base_path
, snap_id
,
1432 if (!NT_STATUS_IS_OK(status
)) {
1436 dbus_message_unref(rsp_msg
);
1437 dbus_message_unref(req_msg
);
1439 DEBUG(6, ("created new snapshot %u at %s\n", snap_id
, snap_path
));
1440 *snap_path_out
= snap_path
;
1442 return NT_STATUS_OK
;
1445 dbus_message_unref(rsp_msg
);
1447 dbus_message_unref(req_msg
);
1452 static NTSTATUS
snapper_snap_create(struct vfs_handle_struct
*handle
,
1453 TALLOC_CTX
*mem_ctx
,
1454 const char *base_volume
,
1460 DBusConnection
*dconn
;
1465 TALLOC_CTX
*tmp_ctx
;
1467 tmp_ctx
= talloc_new(mem_ctx
);
1468 if (tmp_ctx
== NULL
) {
1469 return NT_STATUS_NO_MEMORY
;
1472 dconn
= snapper_dbus_conn_create();
1473 if (dconn
== NULL
) {
1474 talloc_free(tmp_ctx
);
1475 return NT_STATUS_UNSUCCESSFUL
;
1478 status
= snapper_get_conf_call(tmp_ctx
, dconn
, base_volume
,
1479 &conf_name
, &base_path
);
1480 if (!NT_STATUS_IS_OK(status
)) {
1481 snapper_dbus_conn_destroy(dconn
);
1482 talloc_free(tmp_ctx
);
1486 status
= snapper_create_snap_call(tmp_ctx
, dconn
,
1487 conf_name
, base_path
,
1488 "Snapshot created by Samba",
1491 if (!NT_STATUS_IS_OK(status
)) {
1492 snapper_dbus_conn_destroy(dconn
);
1493 talloc_free(tmp_ctx
);
1497 snapper_dbus_conn_destroy(dconn
);
1498 *_base_path
= talloc_steal(mem_ctx
, base_path
);
1499 *_snap_path
= talloc_steal(mem_ctx
, snap_path
);
1500 talloc_free(tmp_ctx
);
1502 return NT_STATUS_OK
;
1505 static NTSTATUS
snapper_delete_snap_call(TALLOC_CTX
*mem_ctx
,
1506 DBusConnection
*dconn
,
1507 const char *conf_name
,
1511 DBusMessage
*req_msg
;
1512 DBusMessage
*rsp_msg
;
1514 status
= snapper_del_snap_pack(mem_ctx
, conf_name
, snap_id
, &req_msg
);
1515 if (!NT_STATUS_IS_OK(status
)) {
1519 status
= snapper_dbus_msg_xchng(dconn
, req_msg
, &rsp_msg
);
1520 if (!NT_STATUS_IS_OK(status
)) {
1524 status
= snapper_del_snap_unpack(dconn
, rsp_msg
);
1525 if (!NT_STATUS_IS_OK(status
)) {
1529 dbus_message_unref(rsp_msg
);
1530 dbus_message_unref(req_msg
);
1532 DEBUG(6, ("deleted snapshot %u\n", snap_id
));
1534 return NT_STATUS_OK
;
1537 dbus_message_unref(rsp_msg
);
1539 dbus_message_unref(req_msg
);
1544 static NTSTATUS
snapper_snap_delete(struct vfs_handle_struct
*handle
,
1545 TALLOC_CTX
*mem_ctx
,
1549 DBusConnection
*dconn
;
1552 char *snap_base_path
;
1554 TALLOC_CTX
*tmp_ctx
;
1556 tmp_ctx
= talloc_new(mem_ctx
);
1557 if (tmp_ctx
== NULL
) {
1558 return NT_STATUS_NO_MEMORY
;
1561 dconn
= snapper_dbus_conn_create();
1562 if (dconn
== NULL
) {
1563 talloc_free(tmp_ctx
);
1564 return NT_STATUS_UNSUCCESSFUL
;
1567 status
= snapper_get_conf_call(tmp_ctx
, dconn
, base_path
,
1568 &conf_name
, &snap_base_path
);
1569 if (!NT_STATUS_IS_OK(status
)) {
1570 snapper_dbus_conn_destroy(dconn
);
1571 talloc_free(tmp_ctx
);
1575 status
= snapper_snap_path_to_id(tmp_ctx
, snap_path
, &snap_id
);
1576 if (!NT_STATUS_IS_OK(status
)) {
1577 snapper_dbus_conn_destroy(dconn
);
1578 talloc_free(tmp_ctx
);
1582 status
= snapper_delete_snap_call(tmp_ctx
, dconn
, conf_name
, snap_id
);
1583 if (!NT_STATUS_IS_OK(status
)) {
1584 snapper_dbus_conn_destroy(dconn
);
1585 talloc_free(tmp_ctx
);
1589 snapper_dbus_conn_destroy(dconn
);
1590 talloc_free(tmp_ctx
);
1592 return NT_STATUS_OK
;
1595 /* sc_data used as parent talloc context for all labels */
1596 static int snapper_get_shadow_copy_data(struct vfs_handle_struct
*handle
,
1597 struct files_struct
*fsp
,
1598 struct shadow_copy_data
*sc_data
,
1601 DBusConnection
*dconn
;
1602 TALLOC_CTX
*tmp_ctx
;
1606 DBusMessage
*req_msg
;
1607 DBusMessage
*rsp_msg
;
1609 struct snapper_snap
*snaps
;
1613 tmp_ctx
= talloc_new(sc_data
);
1614 if (tmp_ctx
== NULL
) {
1615 status
= NT_STATUS_NO_MEMORY
;
1619 dconn
= snapper_dbus_conn_create();
1620 if (dconn
== NULL
) {
1621 status
= NT_STATUS_UNSUCCESSFUL
;
1622 goto err_mem_ctx_free
;
1625 if (fsp
->conn
->connectpath
== NULL
) {
1626 status
= NT_STATUS_INVALID_PARAMETER
;
1630 status
= snapper_get_conf_call(tmp_ctx
, dconn
,
1631 fsp
->conn
->connectpath
,
1634 if (!NT_STATUS_IS_OK(status
)) {
1638 status
= snapper_list_snaps_pack(tmp_ctx
, conf_name
, &req_msg
);
1639 if (!NT_STATUS_IS_OK(status
)) {
1643 status
= snapper_dbus_msg_xchng(dconn
, req_msg
, &rsp_msg
);
1644 if (!NT_STATUS_IS_OK(status
)) {
1648 status
= snapper_list_snaps_unpack(tmp_ctx
, rsp_msg
,
1649 &num_snaps
, &snaps
);
1650 if (!NT_STATUS_IS_OK(status
)) {
1653 /* we should always get at least one snapshot (current) */
1654 if (num_snaps
== 0) {
1655 DEBUG(1, ("zero snapshots in snap list response\n"));
1656 status
= NT_STATUS_UNSUCCESSFUL
;
1660 /* subtract 1, (current) snapshot is not returned */
1661 sc_data
->num_volumes
= num_snaps
- 1;
1662 sc_data
->labels
= NULL
;
1664 if ((labels
== false) || (sc_data
->num_volumes
== 0)) {
1665 /* tokens need not be added to the labels array */
1669 sc_data
->labels
= talloc_array(sc_data
, SHADOW_COPY_LABEL
,
1670 sc_data
->num_volumes
);
1671 if (sc_data
->labels
== NULL
) {
1672 status
= NT_STATUS_NO_MEMORY
;
1676 /* start at end for decending order, do not include 0 (current) */
1678 for (i
= num_snaps
- 1; i
> 0; i
--) {
1679 char *lbl
= sc_data
->labels
[lbl_off
++];
1680 struct tm gmt_snap_time
;
1684 tm_ret
= gmtime_r((time_t *)&snaps
[i
].time
, &gmt_snap_time
);
1685 if (tm_ret
== NULL
) {
1686 status
= NT_STATUS_UNSUCCESSFUL
;
1687 goto err_labels_free
;
1689 str_sz
= strftime(lbl
, sizeof(SHADOW_COPY_LABEL
),
1690 "@GMT-%Y.%m.%d-%H.%M.%S", &gmt_snap_time
);
1692 status
= NT_STATUS_UNSUCCESSFUL
;
1693 goto err_labels_free
;
1698 talloc_free(tmp_ctx
);
1699 dbus_message_unref(rsp_msg
);
1700 dbus_message_unref(req_msg
);
1701 snapper_dbus_conn_destroy(dconn
);
1706 TALLOC_FREE(sc_data
->labels
);
1708 dbus_message_unref(rsp_msg
);
1710 dbus_message_unref(req_msg
);
1712 snapper_dbus_conn_destroy(dconn
);
1714 talloc_free(tmp_ctx
);
1716 errno
= map_errno_from_nt_status(status
);
1720 static bool snapper_gmt_strip_snapshot(TALLOC_CTX
*mem_ctx
,
1721 struct vfs_handle_struct
*handle
,
1731 size_t rest_len
, dst_len
;
1733 p
= strstr_m(name
, "@GMT-");
1737 if ((p
> name
) && (p
[-1] != '/')) {
1740 q
= strptime(p
, GMT_FORMAT
, &tm
);
1745 timestamp
= timegm(&tm
);
1746 if (timestamp
== (time_t)-1) {
1749 if ((p
== name
) && (q
[0] == '\0')) {
1750 if (pstripped
!= NULL
) {
1751 stripped
= talloc_strdup(mem_ctx
, "");
1752 if (stripped
== NULL
) {
1755 *pstripped
= stripped
;
1757 *ptimestamp
= timestamp
;
1765 rest_len
= strlen(q
);
1766 dst_len
= (p
-name
) + rest_len
;
1768 if (pstripped
!= NULL
) {
1769 stripped
= talloc_array(mem_ctx
, char, dst_len
+1);
1770 if (stripped
== NULL
) {
1775 memcpy(stripped
, name
, p
-name
);
1778 memcpy(stripped
+ (p
-name
), q
, rest_len
);
1780 stripped
[dst_len
] = '\0';
1781 *pstripped
= stripped
;
1783 *ptimestamp
= timestamp
;
1790 static NTSTATUS
snapper_get_snap_at_time_call(TALLOC_CTX
*mem_ctx
,
1791 DBusConnection
*dconn
,
1792 const char *conf_name
,
1793 const char *base_path
,
1795 char **snap_path_out
)
1798 DBusMessage
*req_msg
;
1799 DBusMessage
*rsp_msg
;
1801 struct snapper_snap
*snaps
;
1804 status
= snapper_list_snaps_at_time_pack(mem_ctx
,
1809 if (!NT_STATUS_IS_OK(status
)) {
1813 status
= snapper_dbus_msg_xchng(dconn
, req_msg
, &rsp_msg
);
1814 if (!NT_STATUS_IS_OK(status
)) {
1818 status
= snapper_list_snaps_unpack(mem_ctx
, rsp_msg
,
1819 &num_snaps
, &snaps
);
1820 if (!NT_STATUS_IS_OK(status
)) {
1824 if (num_snaps
== 0) {
1825 DEBUG(4, ("no snapshots found with time: %lu\n", snaptime
));
1826 status
= NT_STATUS_INVALID_PARAMETER
;
1827 goto err_snap_array_free
;
1828 } else if (num_snaps
> 0) {
1829 DEBUG(4, ("got %u snapshots for single time %lu, using top\n",
1830 num_snaps
, snaptime
));
1833 status
= snapper_snap_id_to_path(mem_ctx
, base_path
, snaps
[0].id
,
1835 if (!NT_STATUS_IS_OK(status
)) {
1836 goto err_snap_array_free
;
1839 *snap_path_out
= snap_path
;
1840 err_snap_array_free
:
1843 dbus_message_unref(rsp_msg
);
1845 dbus_message_unref(req_msg
);
1850 static NTSTATUS
snapper_snap_path_expand(struct connection_struct
*conn
,
1851 TALLOC_CTX
*mem_ctx
,
1853 char **snap_dir_out
)
1855 DBusConnection
*dconn
;
1861 dconn
= snapper_dbus_conn_create();
1862 if (dconn
== NULL
) {
1863 status
= NT_STATUS_UNSUCCESSFUL
;
1867 if (conn
->connectpath
== NULL
) {
1868 status
= NT_STATUS_INVALID_PARAMETER
;
1872 status
= snapper_get_conf_call(mem_ctx
, dconn
,
1876 if (!NT_STATUS_IS_OK(status
)) {
1880 status
= snapper_get_snap_at_time_call(mem_ctx
, dconn
,
1881 conf_name
, base_path
, snap_time
,
1883 if (!NT_STATUS_IS_OK(status
)) {
1884 goto err_conf_name_free
;
1887 /* confirm snapshot path is nested under base path */
1888 if (strncmp(snap_path
, base_path
, strlen(base_path
)) != 0) {
1889 status
= NT_STATUS_INVALID_PARAMETER
;
1890 goto err_snap_path_free
;
1893 talloc_free(conf_name
);
1894 talloc_free(base_path
);
1895 snapper_dbus_conn_destroy(dconn
);
1896 *snap_dir_out
= snap_path
;
1898 return NT_STATUS_OK
;
1901 talloc_free(snap_path
);
1903 talloc_free(conf_name
);
1904 talloc_free(base_path
);
1906 snapper_dbus_conn_destroy(dconn
);
1911 static char *snapper_gmt_convert(TALLOC_CTX
*mem_ctx
,
1912 struct vfs_handle_struct
*handle
,
1913 const char *name
, time_t timestamp
)
1915 char *snap_path
= NULL
;
1920 status
= snapper_snap_path_expand(handle
->conn
, mem_ctx
, timestamp
,
1922 if (!NT_STATUS_IS_OK(status
)) {
1923 errno
= map_errno_from_nt_status(status
);
1927 path
= talloc_asprintf(mem_ctx
, "%s/%s", snap_path
, name
);
1930 goto err_snap_path_free
;
1933 DEBUG(10, ("converted %s/%s @ time to %s\n",
1934 handle
->conn
->connectpath
, name
, path
));
1938 saved_errno
= errno
;
1939 talloc_free(snap_path
);
1940 errno
= saved_errno
;
1945 static DIR *snapper_gmt_opendir(vfs_handle_struct
*handle
,
1956 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
1957 ×tamp
, &stripped
)) {
1960 if (timestamp
== 0) {
1961 return SMB_VFS_NEXT_OPENDIR(handle
, fname
, mask
, attr
);
1963 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
1964 TALLOC_FREE(stripped
);
1968 ret
= SMB_VFS_NEXT_OPENDIR(handle
, conv
, mask
, attr
);
1969 saved_errno
= errno
;
1971 errno
= saved_errno
;
1975 static int snapper_gmt_rename(vfs_handle_struct
*handle
,
1976 const struct smb_filename
*smb_fname_src
,
1977 const struct smb_filename
*smb_fname_dst
)
1979 time_t timestamp_src
, timestamp_dst
;
1981 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
,
1982 smb_fname_src
->base_name
,
1983 ×tamp_src
, NULL
)) {
1986 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
,
1987 smb_fname_dst
->base_name
,
1988 ×tamp_dst
, NULL
)) {
1991 if (timestamp_src
!= 0) {
1995 if (timestamp_dst
!= 0) {
1999 return SMB_VFS_NEXT_RENAME(handle
, smb_fname_src
, smb_fname_dst
);
2002 static int snapper_gmt_symlink(vfs_handle_struct
*handle
,
2003 const char *oldname
, const char *newname
)
2005 time_t timestamp_old
, timestamp_new
;
2007 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, oldname
,
2008 ×tamp_old
, NULL
)) {
2011 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, newname
,
2012 ×tamp_new
, NULL
)) {
2015 if ((timestamp_old
!= 0) || (timestamp_new
!= 0)) {
2019 return SMB_VFS_NEXT_SYMLINK(handle
, oldname
, newname
);
2022 static int snapper_gmt_link(vfs_handle_struct
*handle
,
2023 const char *oldname
, const char *newname
)
2025 time_t timestamp_old
, timestamp_new
;
2027 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, oldname
,
2028 ×tamp_old
, NULL
)) {
2031 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, newname
,
2032 ×tamp_new
, NULL
)) {
2035 if ((timestamp_old
!= 0) || (timestamp_new
!= 0)) {
2039 return SMB_VFS_NEXT_LINK(handle
, oldname
, newname
);
2042 static int snapper_gmt_stat(vfs_handle_struct
*handle
,
2043 struct smb_filename
*smb_fname
)
2046 char *stripped
, *tmp
;
2047 int ret
, saved_errno
;
2049 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
,
2050 smb_fname
->base_name
,
2051 ×tamp
, &stripped
)) {
2054 if (timestamp
== 0) {
2055 return SMB_VFS_NEXT_STAT(handle
, smb_fname
);
2058 tmp
= smb_fname
->base_name
;
2059 smb_fname
->base_name
= snapper_gmt_convert(talloc_tos(), handle
,
2060 stripped
, timestamp
);
2061 TALLOC_FREE(stripped
);
2063 if (smb_fname
->base_name
== NULL
) {
2064 smb_fname
->base_name
= tmp
;
2068 ret
= SMB_VFS_NEXT_STAT(handle
, smb_fname
);
2069 saved_errno
= errno
;
2071 TALLOC_FREE(smb_fname
->base_name
);
2072 smb_fname
->base_name
= tmp
;
2074 errno
= saved_errno
;
2078 static int snapper_gmt_lstat(vfs_handle_struct
*handle
,
2079 struct smb_filename
*smb_fname
)
2082 char *stripped
, *tmp
;
2083 int ret
, saved_errno
;
2085 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
,
2086 smb_fname
->base_name
,
2087 ×tamp
, &stripped
)) {
2090 if (timestamp
== 0) {
2091 return SMB_VFS_NEXT_LSTAT(handle
, smb_fname
);
2094 tmp
= smb_fname
->base_name
;
2095 smb_fname
->base_name
= snapper_gmt_convert(talloc_tos(), handle
,
2096 stripped
, timestamp
);
2097 TALLOC_FREE(stripped
);
2099 if (smb_fname
->base_name
== NULL
) {
2100 smb_fname
->base_name
= tmp
;
2104 ret
= SMB_VFS_NEXT_LSTAT(handle
, smb_fname
);
2105 saved_errno
= errno
;
2107 TALLOC_FREE(smb_fname
->base_name
);
2108 smb_fname
->base_name
= tmp
;
2110 errno
= saved_errno
;
2114 static int snapper_gmt_fstat(vfs_handle_struct
*handle
, files_struct
*fsp
,
2115 SMB_STRUCT_STAT
*sbuf
)
2120 ret
= SMB_VFS_NEXT_FSTAT(handle
, fsp
, sbuf
);
2124 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
,
2125 fsp
->fsp_name
->base_name
,
2126 ×tamp
, NULL
)) {
2132 static int snapper_gmt_open(vfs_handle_struct
*handle
,
2133 struct smb_filename
*smb_fname
, files_struct
*fsp
,
2134 int flags
, mode_t mode
)
2137 char *stripped
, *tmp
;
2138 int ret
, saved_errno
;
2140 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
,
2141 smb_fname
->base_name
,
2142 ×tamp
, &stripped
)) {
2145 if (timestamp
== 0) {
2146 return SMB_VFS_NEXT_OPEN(handle
, smb_fname
, fsp
, flags
, mode
);
2149 tmp
= smb_fname
->base_name
;
2150 smb_fname
->base_name
= snapper_gmt_convert(talloc_tos(), handle
,
2151 stripped
, timestamp
);
2152 TALLOC_FREE(stripped
);
2154 if (smb_fname
->base_name
== NULL
) {
2155 smb_fname
->base_name
= tmp
;
2159 ret
= SMB_VFS_NEXT_OPEN(handle
, smb_fname
, fsp
, flags
, mode
);
2160 saved_errno
= errno
;
2162 TALLOC_FREE(smb_fname
->base_name
);
2163 smb_fname
->base_name
= tmp
;
2165 errno
= saved_errno
;
2169 static int snapper_gmt_unlink(vfs_handle_struct
*handle
,
2170 const struct smb_filename
*smb_fname
)
2174 int ret
, saved_errno
;
2175 struct smb_filename
*conv
;
2177 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
,
2178 smb_fname
->base_name
,
2179 ×tamp
, &stripped
)) {
2182 if (timestamp
== 0) {
2183 return SMB_VFS_NEXT_UNLINK(handle
, smb_fname
);
2185 conv
= cp_smb_filename(talloc_tos(), smb_fname
);
2190 conv
->base_name
= snapper_gmt_convert(conv
, handle
,
2191 stripped
, timestamp
);
2192 TALLOC_FREE(stripped
);
2193 if (conv
->base_name
== NULL
) {
2196 ret
= SMB_VFS_NEXT_UNLINK(handle
, conv
);
2197 saved_errno
= errno
;
2199 errno
= saved_errno
;
2203 static int snapper_gmt_chmod(vfs_handle_struct
*handle
, const char *fname
,
2208 int ret
, saved_errno
;
2211 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2212 ×tamp
, &stripped
)) {
2215 if (timestamp
== 0) {
2216 return SMB_VFS_NEXT_CHMOD(handle
, fname
, mode
);
2218 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2219 TALLOC_FREE(stripped
);
2223 ret
= SMB_VFS_NEXT_CHMOD(handle
, conv
, mode
);
2224 saved_errno
= errno
;
2226 errno
= saved_errno
;
2230 static int snapper_gmt_chown(vfs_handle_struct
*handle
, const char *fname
,
2231 uid_t uid
, gid_t gid
)
2235 int ret
, saved_errno
;
2238 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2239 ×tamp
, &stripped
)) {
2242 if (timestamp
== 0) {
2243 return SMB_VFS_NEXT_CHOWN(handle
, fname
, uid
, gid
);
2245 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2246 TALLOC_FREE(stripped
);
2250 ret
= SMB_VFS_NEXT_CHOWN(handle
, conv
, uid
, gid
);
2251 saved_errno
= errno
;
2253 errno
= saved_errno
;
2257 static int snapper_gmt_chdir(vfs_handle_struct
*handle
,
2262 int ret
, saved_errno
;
2265 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2266 ×tamp
, &stripped
)) {
2269 if (timestamp
== 0) {
2270 return SMB_VFS_NEXT_CHDIR(handle
, fname
);
2272 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2273 TALLOC_FREE(stripped
);
2277 ret
= SMB_VFS_NEXT_CHDIR(handle
, conv
);
2278 saved_errno
= errno
;
2280 errno
= saved_errno
;
2284 static int snapper_gmt_ntimes(vfs_handle_struct
*handle
,
2285 const struct smb_filename
*smb_fname
,
2286 struct smb_file_time
*ft
)
2290 int ret
, saved_errno
;
2291 struct smb_filename
*conv
;
2293 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
,
2294 smb_fname
->base_name
,
2295 ×tamp
, &stripped
)) {
2298 if (timestamp
== 0) {
2299 return SMB_VFS_NEXT_NTIMES(handle
, smb_fname
, ft
);
2301 conv
= cp_smb_filename(talloc_tos(), smb_fname
);
2306 conv
->base_name
= snapper_gmt_convert(conv
, handle
,
2307 stripped
, timestamp
);
2308 TALLOC_FREE(stripped
);
2309 if (conv
->base_name
== NULL
) {
2312 ret
= SMB_VFS_NEXT_NTIMES(handle
, conv
, ft
);
2313 saved_errno
= errno
;
2315 errno
= saved_errno
;
2319 static int snapper_gmt_readlink(vfs_handle_struct
*handle
,
2320 const char *fname
, char *buf
, size_t bufsiz
)
2324 int ret
, saved_errno
;
2327 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2328 ×tamp
, &stripped
)) {
2331 if (timestamp
== 0) {
2332 return SMB_VFS_NEXT_READLINK(handle
, fname
, buf
, bufsiz
);
2334 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2335 TALLOC_FREE(stripped
);
2339 ret
= SMB_VFS_NEXT_READLINK(handle
, conv
, buf
, bufsiz
);
2340 saved_errno
= errno
;
2342 errno
= saved_errno
;
2346 static int snapper_gmt_mknod(vfs_handle_struct
*handle
,
2347 const char *fname
, mode_t mode
, SMB_DEV_T dev
)
2351 int ret
, saved_errno
;
2354 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2355 ×tamp
, &stripped
)) {
2358 if (timestamp
== 0) {
2359 return SMB_VFS_NEXT_MKNOD(handle
, fname
, mode
, dev
);
2361 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2362 TALLOC_FREE(stripped
);
2366 ret
= SMB_VFS_NEXT_MKNOD(handle
, conv
, mode
, dev
);
2367 saved_errno
= errno
;
2369 errno
= saved_errno
;
2373 static char *snapper_gmt_realpath(vfs_handle_struct
*handle
,
2377 char *stripped
= NULL
;
2379 char *result
= NULL
;
2382 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2383 ×tamp
, &stripped
)) {
2386 if (timestamp
== 0) {
2387 return SMB_VFS_NEXT_REALPATH(handle
, fname
);
2390 tmp
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2395 result
= SMB_VFS_NEXT_REALPATH(handle
, tmp
);
2396 if (result
== NULL
) {
2401 saved_errno
= errno
;
2403 TALLOC_FREE(stripped
);
2404 errno
= saved_errno
;
2408 static NTSTATUS
snapper_gmt_fget_nt_acl(vfs_handle_struct
*handle
,
2409 struct files_struct
*fsp
,
2410 uint32_t security_info
,
2411 TALLOC_CTX
*mem_ctx
,
2412 struct security_descriptor
**ppdesc
)
2419 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
,
2420 fsp
->fsp_name
->base_name
,
2421 ×tamp
, &stripped
)) {
2422 return map_nt_error_from_unix(errno
);
2424 if (timestamp
== 0) {
2425 return SMB_VFS_NEXT_FGET_NT_ACL(handle
, fsp
, security_info
,
2429 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2430 TALLOC_FREE(stripped
);
2432 return map_nt_error_from_unix(errno
);
2434 status
= SMB_VFS_NEXT_GET_NT_ACL(handle
, conv
, security_info
,
2440 static NTSTATUS
snapper_gmt_get_nt_acl(vfs_handle_struct
*handle
,
2442 uint32_t security_info
,
2443 TALLOC_CTX
*mem_ctx
,
2444 struct security_descriptor
**ppdesc
)
2451 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2452 ×tamp
, &stripped
)) {
2453 return map_nt_error_from_unix(errno
);
2455 if (timestamp
== 0) {
2456 return SMB_VFS_NEXT_GET_NT_ACL(handle
, fname
, security_info
,
2459 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2460 TALLOC_FREE(stripped
);
2462 return map_nt_error_from_unix(errno
);
2464 status
= SMB_VFS_NEXT_GET_NT_ACL(handle
, conv
, security_info
,
2470 static int snapper_gmt_mkdir(vfs_handle_struct
*handle
,
2471 const char *fname
, mode_t mode
)
2475 int ret
, saved_errno
;
2478 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2479 ×tamp
, &stripped
)) {
2482 if (timestamp
== 0) {
2483 return SMB_VFS_NEXT_MKDIR(handle
, fname
, mode
);
2485 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2486 TALLOC_FREE(stripped
);
2490 ret
= SMB_VFS_NEXT_MKDIR(handle
, conv
, mode
);
2491 saved_errno
= errno
;
2493 errno
= saved_errno
;
2497 static int snapper_gmt_rmdir(vfs_handle_struct
*handle
, const char *fname
)
2501 int ret
, saved_errno
;
2504 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2505 ×tamp
, &stripped
)) {
2508 if (timestamp
== 0) {
2509 return SMB_VFS_NEXT_RMDIR(handle
, fname
);
2511 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2512 TALLOC_FREE(stripped
);
2516 ret
= SMB_VFS_NEXT_RMDIR(handle
, conv
);
2517 saved_errno
= errno
;
2519 errno
= saved_errno
;
2523 static int snapper_gmt_chflags(vfs_handle_struct
*handle
, const char *fname
,
2528 int ret
, saved_errno
;
2531 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2532 ×tamp
, &stripped
)) {
2535 if (timestamp
== 0) {
2536 return SMB_VFS_NEXT_CHFLAGS(handle
, fname
, flags
);
2538 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2539 TALLOC_FREE(stripped
);
2543 ret
= SMB_VFS_NEXT_CHFLAGS(handle
, conv
, flags
);
2544 saved_errno
= errno
;
2546 errno
= saved_errno
;
2550 static ssize_t
snapper_gmt_getxattr(vfs_handle_struct
*handle
,
2551 const char *fname
, const char *aname
,
2552 void *value
, size_t size
)
2560 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2561 ×tamp
, &stripped
)) {
2564 if (timestamp
== 0) {
2565 return SMB_VFS_NEXT_GETXATTR(handle
, fname
, aname
, value
,
2568 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2569 TALLOC_FREE(stripped
);
2573 ret
= SMB_VFS_NEXT_GETXATTR(handle
, conv
, aname
, value
, size
);
2574 saved_errno
= errno
;
2576 errno
= saved_errno
;
2580 static ssize_t
snapper_gmt_listxattr(struct vfs_handle_struct
*handle
,
2582 char *list
, size_t size
)
2590 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2591 ×tamp
, &stripped
)) {
2594 if (timestamp
== 0) {
2595 return SMB_VFS_NEXT_LISTXATTR(handle
, fname
, list
, size
);
2597 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2598 TALLOC_FREE(stripped
);
2602 ret
= SMB_VFS_NEXT_LISTXATTR(handle
, conv
, list
, size
);
2603 saved_errno
= errno
;
2605 errno
= saved_errno
;
2609 static int snapper_gmt_removexattr(vfs_handle_struct
*handle
,
2610 const char *fname
, const char *aname
)
2614 int ret
, saved_errno
;
2617 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2618 ×tamp
, &stripped
)) {
2621 if (timestamp
== 0) {
2622 return SMB_VFS_NEXT_REMOVEXATTR(handle
, fname
, aname
);
2624 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2625 TALLOC_FREE(stripped
);
2629 ret
= SMB_VFS_NEXT_REMOVEXATTR(handle
, conv
, aname
);
2630 saved_errno
= errno
;
2632 errno
= saved_errno
;
2636 static int snapper_gmt_setxattr(struct vfs_handle_struct
*handle
,
2638 const char *aname
, const void *value
,
2639 size_t size
, int flags
)
2647 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2648 ×tamp
, &stripped
)) {
2651 if (timestamp
== 0) {
2652 return SMB_VFS_NEXT_SETXATTR(handle
, fname
, aname
, value
, size
,
2655 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2656 TALLOC_FREE(stripped
);
2660 ret
= SMB_VFS_NEXT_SETXATTR(handle
, conv
, aname
, value
, size
, flags
);
2661 saved_errno
= errno
;
2663 errno
= saved_errno
;
2667 static int snapper_gmt_chmod_acl(vfs_handle_struct
*handle
,
2668 const char *fname
, mode_t mode
)
2676 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, fname
,
2677 ×tamp
, &stripped
)) {
2680 if (timestamp
== 0) {
2681 return SMB_VFS_NEXT_CHMOD_ACL(handle
, fname
, mode
);
2683 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2684 TALLOC_FREE(stripped
);
2688 ret
= SMB_VFS_NEXT_CHMOD_ACL(handle
, conv
, mode
);
2689 saved_errno
= errno
;
2691 errno
= saved_errno
;
2695 static int snapper_gmt_get_real_filename(struct vfs_handle_struct
*handle
,
2698 TALLOC_CTX
*mem_ctx
,
2707 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, path
,
2708 ×tamp
, &stripped
)) {
2711 if (timestamp
== 0) {
2712 return SMB_VFS_NEXT_GET_REAL_FILENAME(handle
, path
, name
,
2713 mem_ctx
, found_name
);
2715 if (stripped
[0] == '\0') {
2716 *found_name
= talloc_strdup(mem_ctx
, name
);
2717 if (*found_name
== NULL
) {
2723 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2724 TALLOC_FREE(stripped
);
2728 ret
= SMB_VFS_NEXT_GET_REAL_FILENAME(handle
, conv
, name
,
2729 mem_ctx
, found_name
);
2730 saved_errno
= errno
;
2732 errno
= saved_errno
;
2736 static uint64_t snapper_gmt_disk_free(vfs_handle_struct
*handle
,
2737 const char *path
, uint64_t *bsize
,
2738 uint64_t *dfree
, uint64_t *dsize
)
2746 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, path
,
2747 ×tamp
, &stripped
)) {
2750 if (timestamp
== 0) {
2751 return SMB_VFS_NEXT_DISK_FREE(handle
, path
,
2752 bsize
, dfree
, dsize
);
2755 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2756 TALLOC_FREE(stripped
);
2761 ret
= SMB_VFS_NEXT_DISK_FREE(handle
, conv
, bsize
, dfree
, dsize
);
2763 saved_errno
= errno
;
2765 errno
= saved_errno
;
2770 static int snapper_gmt_get_quota(vfs_handle_struct
*handle
, const char *path
,
2771 enum SMB_QUOTA_TYPE qtype
, unid_t id
,
2780 if (!snapper_gmt_strip_snapshot(talloc_tos(), handle
, path
, ×tamp
,
2784 if (timestamp
== 0) {
2785 return SMB_VFS_NEXT_GET_QUOTA(handle
, path
, qtype
, id
, dq
);
2788 conv
= snapper_gmt_convert(talloc_tos(), handle
, stripped
, timestamp
);
2789 TALLOC_FREE(stripped
);
2794 ret
= SMB_VFS_NEXT_GET_QUOTA(handle
, conv
, qtype
, id
, dq
);
2796 saved_errno
= errno
;
2798 errno
= saved_errno
;
2804 static struct vfs_fn_pointers snapper_fns
= {
2805 .snap_check_path_fn
= snapper_snap_check_path
,
2806 .snap_create_fn
= snapper_snap_create
,
2807 .snap_delete_fn
= snapper_snap_delete
,
2808 .get_shadow_copy_data_fn
= snapper_get_shadow_copy_data
,
2809 .opendir_fn
= snapper_gmt_opendir
,
2810 .disk_free_fn
= snapper_gmt_disk_free
,
2811 .get_quota_fn
= snapper_gmt_get_quota
,
2812 .rename_fn
= snapper_gmt_rename
,
2813 .link_fn
= snapper_gmt_link
,
2814 .symlink_fn
= snapper_gmt_symlink
,
2815 .stat_fn
= snapper_gmt_stat
,
2816 .lstat_fn
= snapper_gmt_lstat
,
2817 .fstat_fn
= snapper_gmt_fstat
,
2818 .open_fn
= snapper_gmt_open
,
2819 .unlink_fn
= snapper_gmt_unlink
,
2820 .chmod_fn
= snapper_gmt_chmod
,
2821 .chown_fn
= snapper_gmt_chown
,
2822 .chdir_fn
= snapper_gmt_chdir
,
2823 .ntimes_fn
= snapper_gmt_ntimes
,
2824 .readlink_fn
= snapper_gmt_readlink
,
2825 .mknod_fn
= snapper_gmt_mknod
,
2826 .realpath_fn
= snapper_gmt_realpath
,
2827 .get_nt_acl_fn
= snapper_gmt_get_nt_acl
,
2828 .fget_nt_acl_fn
= snapper_gmt_fget_nt_acl
,
2829 .mkdir_fn
= snapper_gmt_mkdir
,
2830 .rmdir_fn
= snapper_gmt_rmdir
,
2831 .getxattr_fn
= snapper_gmt_getxattr
,
2832 .listxattr_fn
= snapper_gmt_listxattr
,
2833 .removexattr_fn
= snapper_gmt_removexattr
,
2834 .setxattr_fn
= snapper_gmt_setxattr
,
2835 .chmod_acl_fn
= snapper_gmt_chmod_acl
,
2836 .chflags_fn
= snapper_gmt_chflags
,
2837 .get_real_filename_fn
= snapper_gmt_get_real_filename
,
2840 NTSTATUS
vfs_snapper_init(void);
2841 NTSTATUS
vfs_snapper_init(void)
2843 return smb_register_vfs(SMB_VFS_INTERFACE_VERSION
,
2844 "snapper", &snapper_fns
);