The branch, master has been updated
       via  f0f18c5 vfs_snapper: use a talloc hierarchy for arrays
       via  224e1c1 vfs_snapper: don't redefine GMT_FORMAT macro
       via  4478dfe doc: add vfs_snapper manpage
       via  377a1c8 vfs: add previous file version support for vfs_snapper
       via  9261f7c vfs: add vfs_snapper module
      from  654ca05 smbd: Make messaging_send_to_children static

http://gitweb.samba.org/?p=samba.git;a=shortlog;h=master


- Log -----------------------------------------------------------------
commit f0f18c56c68325e9a1cf9b422d270a8787c980ba
Author: David Disseldorp <[email protected]>
Date:   Mon Jun 30 14:40:14 2014 +0200

    vfs_snapper: use a talloc hierarchy for arrays
    
    Currently the config and snapshot array entries are freed individually.
    A talloc hierarchy can be used to avoid this behaviour.
    
    Signed-off-by: David Disseldorp <[email protected]>
    Reviewed-by: Jeremy Allison <[email protected]>
    
    Autobuild-User(master): Jeremy Allison <[email protected]>
    Autobuild-Date(master): Mon Jun 30 21:41:13 CEST 2014 on sn-devel-104

commit 224e1c105be2ecf2c02ca9cd3e8bb9660ea932aa
Author: David Disseldorp <[email protected]>
Date:   Mon Jun 30 14:40:13 2014 +0200

    vfs_snapper: don't redefine GMT_FORMAT macro
    
    Use existing header definition.
    
    Signed-off-by: David Disseldorp <[email protected]>
    Reviewed-by: Jeremy Allison <[email protected]>

commit 4478dfe2082d795d8531b92c3c70b1e8847cc7aa
Author: David Disseldorp <[email protected]>
Date:   Fri Jun 27 15:31:37 2014 +0200

    doc: add vfs_snapper manpage
    
    Document usage of the snapper VFS module, detailing permissions required
    to list and access snapshots.
    
    Signed-off-by: David Disseldorp <[email protected]>
    Reviewed-by: Jeremy Allison <[email protected]>

commit 377a1c860e3de2d4b0bd7ab8cd78c2c48687a3cf
Author: David Disseldorp <[email protected]>
Date:   Fri Jun 27 15:31:36 2014 +0200

    vfs: add previous file version support for vfs_snapper
    
    Windows attempts to access previous file versions by first issuing an
    FSCTL_SRV_ENUMERATE_SNAPSHOTS request, and then using the corresponding
    snapshot timestamps in subsequent path based requests.
    
    This change sees vfs_snapper provide snapshot enumeration data via the
    get_shadow_copy_data VFS hook. Path based operations are also
    intercepted, with @GMT-$time components converted to snapper .snapshot/#
    paths.
    
    Signed-off-by: David Disseldorp <[email protected]>
    Reviewed-by: Jeremy Allison <[email protected]>

commit 9261f7c6a0caae171eab5a499bae4b1f54c3a452
Author: David Disseldorp <[email protected]>
Date:   Fri Jun 27 15:31:35 2014 +0200

    vfs: add vfs_snapper module
    
    Provides an interface for accessing snapshots exposed by Snapper. The
    module communicates with snapperd on the local machine using the D-Bus
    interface.
    
    Signed-off-by: David Disseldorp <[email protected]>
    Reviewed-by: Jeremy Allison <[email protected]>

-----------------------------------------------------------------------

Summary of changes:
 docs-xml/manpages/vfs_snapper.8.xml |   93 ++
 docs-xml/wscript_build              |    1 +
 source3/modules/vfs_snapper.c       | 2019 +++++++++++++++++++++++++++++++++++
 source3/modules/wscript_build       |    8 +
 source3/wscript                     |    9 +
 5 files changed, 2130 insertions(+), 0 deletions(-)
 create mode 100644 docs-xml/manpages/vfs_snapper.8.xml
 create mode 100644 source3/modules/vfs_snapper.c


Changeset truncated at 500 lines:

diff --git a/docs-xml/manpages/vfs_snapper.8.xml 
b/docs-xml/manpages/vfs_snapper.8.xml
new file mode 100644
index 0000000..0e06ec5
--- /dev/null
+++ b/docs-xml/manpages/vfs_snapper.8.xml
@@ -0,0 +1,93 @@
+<?xml version="1.0" encoding="iso-8859-1"?>
+<!DOCTYPE refentry PUBLIC "-//Samba-Team//DTD DocBook V4.2-Based Variant 
V1.0//EN" "http://www.samba.org/samba/DTD/samba-doc";>
+<refentry id="vfs_snapper.8">
+
+<refmeta>
+       <refentrytitle>vfs_snapper</refentrytitle>
+       <manvolnum>8</manvolnum>
+       <refmiscinfo class="source">Samba</refmiscinfo>
+       <refmiscinfo class="manual">System Administration tools</refmiscinfo>
+       <refmiscinfo class="version">4.2</refmiscinfo>
+</refmeta>
+
+
+<refnamediv>
+       <refname>vfs_snapper</refname>
+       <refpurpose>
+               Expose snapshots managed by snapper as shadow-copies
+       </refpurpose>
+</refnamediv>
+
+<refsynopsisdiv>
+       <cmdsynopsis>
+               <command>vfs objects = snapper</command>
+       </cmdsynopsis>
+</refsynopsisdiv>
+
+<refsect1>
+       <title>DESCRIPTION</title>
+
+       <para>This VFS module is part of the
+       <citerefentry><refentrytitle>samba</refentrytitle>
+       <manvolnum>8</manvolnum></citerefentry> suite.</para>
+
+       <para>
+               The <command>vfs_snapper</command> VFS module exposes snapshots
+               managed by snapper for use by Samba. This provides the ability
+               for remote SMB clients to access shadow-copies via Windows
+               Explorer using the "previous versions" dialog.
+       </para>
+
+       <para>
+               This module is stackable.
+       </para>
+</refsect1>
+
+<refsect1>
+       <title>CONFIGURATION</title>
+
+       <para>
+               The underlying share path must have a corresponding snapper
+               configuration file. The snapshot directory tree must allow
+               access for relavent users.
+       </para>
+
+       <programlisting>
+               <smbconfsection name="[share]"/>
+               <smbconfoption name="vfs objects">snapper</smbconfoption>
+       </programlisting>
+</refsect1>
+
+<refsect1>
+       <title>PERMISSIONS</title>
+       <para>
+               Snapper stores snapshots under a .snapshots subdirectory. This
+               directory must permit traversal for any users wishing to access
+               snapshots via the Windows Explorer previous versions dialog.
+               By default, traversal is forbidden for all non-root users.
+               Additionally, users must be granted permission to list snapshots
+               managed by snapper, via snapper's ALLOW_USERS or ALLOW_GROUPS
+               options. Snapper can grant these users and groups .snapshots
+               traversal access automatically via the SYNC_ACL option.
+       </para>
+</refsect1>
+
+<refsect1>
+       <title>VERSION</title>
+
+       <para>
+               This man page is correct for version 4.2.0 of the Samba suite.
+       </para>
+</refsect1>
+
+<refsect1>
+       <title>AUTHOR</title>
+
+       <para>The original Samba software and related utilities
+       were created by Andrew Tridgell. Samba is now developed
+       by the Samba Team as an Open Source project similar
+       to the way the Linux kernel is developed.</para>
+
+</refsect1>
+
+</refentry>
diff --git a/docs-xml/wscript_build b/docs-xml/wscript_build
index d59d4b5..42c9a85 100644
--- a/docs-xml/wscript_build
+++ b/docs-xml/wscript_build
@@ -75,6 +75,7 @@ manpages='''
          manpages/vfs_shadow_copy.8
          manpages/vfs_shadow_copy2.8
          manpages/vfs_smb_traffic_analyzer.8
+        manpages/vfs_snapper.8
          manpages/vfs_streams_depot.8
          manpages/vfs_streams_xattr.8
          manpages/vfs_syncops.8
diff --git a/source3/modules/vfs_snapper.c b/source3/modules/vfs_snapper.c
new file mode 100644
index 0000000..f0f0b5c
--- /dev/null
+++ b/source3/modules/vfs_snapper.c
@@ -0,0 +1,2019 @@
+/*
+ * Module for snapshot IO using snapper
+ *
+ * Copyright (C) David Disseldorp 2012-2014
+ *
+ * Portions taken from vfs_shadow_copy2.c:
+ * Copyright (C) Andrew Tridgell   2007
+ * Copyright (C) Ed Plese          2009
+ * Copyright (C) Volker Lendecke   2011
+ * Copyright (C) Christian Ambach  2011
+ * Copyright (C) Michael Adam      2013
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include <dbus/dbus.h>
+#include <linux/ioctl.h>
+#include <sys/ioctl.h>
+#include <dirent.h>
+#include <libgen.h>
+#include "includes.h"
+#include "include/ntioctl.h"
+#include "include/smb.h"
+#include "system/filesys.h"
+#include "smbd/smbd.h"
+#include "lib/util/tevent_ntstatus.h"
+
+#define SNAPPER_SIG_LIST_SNAPS_RSP "a(uquxussa{ss})"
+#define SNAPPER_SIG_LIST_CONFS_RSP "a(ssa{ss})"
+#define SNAPPER_SIG_STRING_DICT "{ss}"
+
+struct snapper_dict {
+       char *key;
+       char *val;
+};
+
+struct snapper_snap {
+       uint32_t id;
+       uint16_t type;
+       uint32_t pre_id;
+       int64_t time;
+       uint32_t creator_uid;
+       char *desc;
+       char *cleanup;
+       uint32_t num_user_data;
+       struct snapper_dict *user_data;
+};
+
+struct snapper_conf {
+       char *name;
+       char *mnt;
+       uint32_t num_attrs;
+       struct snapper_dict *attrs;
+};
+
+static const struct {
+       const char *snapper_err_str;
+       NTSTATUS status;
+} snapper_err_map[] = {
+       { "error.no_permissions", NT_STATUS_ACCESS_DENIED },
+};
+
+static NTSTATUS snapper_err_ntstatus_map(const char *snapper_err_str)
+{
+       int i;
+
+       if (snapper_err_str == NULL) {
+               return NT_STATUS_UNSUCCESSFUL;
+       }
+       for (i = 0; i < ARRAY_SIZE(snapper_err_map); i++) {
+               if (!strcmp(snapper_err_map[i].snapper_err_str,
+                           snapper_err_str)) {
+                       return snapper_err_map[i].status;
+               }
+       }
+       DEBUG(2, ("no explicit mapping for dbus error: %s\n", snapper_err_str));
+
+       return NT_STATUS_UNSUCCESSFUL;
+}
+
+static DBusConnection *snapper_dbus_conn_create(void)
+{
+       DBusError err;
+       DBusConnection *dconn;
+
+       dbus_error_init(&err);
+
+       /*
+        * Always create a new DBus connection, to ensure snapperd detects the
+        * correct client [E]UID. With dbus_bus_get() it does not!
+        */
+       dconn = dbus_bus_get_private(DBUS_BUS_SYSTEM, &err);
+       if (dbus_error_is_set(&err)) {
+               DEBUG(0, ("dbus connection error: %s\n", err.message));
+               dbus_error_free(&err);
+       }
+       if (dconn == NULL) {
+               return NULL;
+       }
+
+       /* dbus_bus_get_private() sets exit-on-disconnect by default, undo it */
+       dbus_connection_set_exit_on_disconnect(dconn, false);
+
+       return dconn;
+}
+
+static void snapper_dbus_conn_destroy(DBusConnection *dconn)
+{
+       if (dconn == NULL) {
+               DEBUG(2, ("attempt to destroy NULL dbus connection\n"));
+               return;
+       }
+
+       dbus_connection_close(dconn);
+       dbus_connection_unref(dconn);
+}
+
+/*
+ * send the message @send_msg over the dbus and wait for a response, return the
+ * responsee via @recv_msg_out.
+ * @send_msg is not freed, dbus_message_unref() must be handled by the caller.
+ */
+static NTSTATUS snapper_dbus_msg_xchng(DBusConnection *dconn,
+                                      DBusMessage *send_msg,
+                                      DBusMessage **recv_msg_out)
+{
+       DBusPendingCall *pending;
+       DBusMessage *recv_msg;
+
+       /* send message and get a handle for a reply */
+       if (!dbus_connection_send_with_reply(dconn, send_msg, &pending, -1)) {
+               return NT_STATUS_NO_MEMORY;
+       }
+       if (NULL == pending) {
+               DEBUG(0, ("dbus msg send failed\n"));
+               return NT_STATUS_UNSUCCESSFUL;
+       }
+
+       dbus_connection_flush(dconn);
+
+       /* block until we receive a reply */
+       dbus_pending_call_block(pending);
+
+       /* get the reply message */
+       recv_msg = dbus_pending_call_steal_reply(pending);
+       if (recv_msg == NULL) {
+               DEBUG(0, ("Reply Null\n"));
+               return NT_STATUS_UNSUCCESSFUL;
+       }
+       /* free the pending message handle */
+       dbus_pending_call_unref(pending);
+       *recv_msg_out = recv_msg;
+
+       return NT_STATUS_OK;
+}
+
+static NTSTATUS snapper_type_check(DBusMessageIter *iter,
+                                  int expected_type)
+{
+       int type = dbus_message_iter_get_arg_type(iter);
+       if (type != expected_type) {
+               DEBUG(0, ("got type %d, expecting %d\n",
+                       type, expected_type));
+               return NT_STATUS_INVALID_PARAMETER;
+       }
+
+       return NT_STATUS_OK;
+}
+
+static NTSTATUS snapper_type_check_get(DBusMessageIter *iter,
+                                      int expected_type,
+                                      void *val)
+{
+       NTSTATUS status;
+       status = snapper_type_check(iter, expected_type);
+       if (!NT_STATUS_IS_OK(status)) {
+               return status;
+       }
+
+       dbus_message_iter_get_basic(iter, val);
+
+       return NT_STATUS_OK;
+}
+
+static NTSTATUS snapper_dict_unpack(DBusMessageIter *iter,
+                                   struct snapper_dict *dict_out)
+
+{
+       NTSTATUS status;
+       DBusMessageIter dct_iter;
+
+       status = snapper_type_check(iter, DBUS_TYPE_DICT_ENTRY);
+       if (!NT_STATUS_IS_OK(status)) {
+               return status;
+       }
+       dbus_message_iter_recurse(iter, &dct_iter);
+
+       status = snapper_type_check_get(&dct_iter, DBUS_TYPE_STRING,
+                                       &dict_out->key);
+       if (!NT_STATUS_IS_OK(status)) {
+               return status;
+       }
+
+       dbus_message_iter_next(&dct_iter);
+       status = snapper_type_check_get(&dct_iter, DBUS_TYPE_STRING,
+                                       &dict_out->val);
+       if (!NT_STATUS_IS_OK(status)) {
+               return status;
+       }
+
+       return NT_STATUS_OK;
+}
+
+static void snapper_dict_array_print(uint32_t num_dicts,
+                                    struct snapper_dict *dicts)
+{
+       int i;
+
+       for (i = 0; i < num_dicts; i++) {
+               DEBUG(10, ("dict (key: %s, val: %s)\n",
+                          dicts[i].key, dicts[i].val));
+       }
+}
+
+static NTSTATUS snapper_dict_array_unpack(TALLOC_CTX *mem_ctx,
+                                         DBusMessageIter *iter,
+                                         uint32_t *num_dicts_out,
+                                         struct snapper_dict **dicts_out)
+{
+       NTSTATUS status;
+       DBusMessageIter array_iter;
+       uint32_t num_dicts;
+       struct snapper_dict *dicts = NULL;
+
+       status = snapper_type_check(iter, DBUS_TYPE_ARRAY);
+       if (!NT_STATUS_IS_OK(status)) {
+               return status;
+       }
+       dbus_message_iter_recurse(iter, &array_iter);
+
+       num_dicts = 0;
+       while (dbus_message_iter_get_arg_type(&array_iter)
+                                                       != DBUS_TYPE_INVALID) {
+               num_dicts++;
+               dicts = talloc_realloc(mem_ctx, dicts, struct snapper_dict,
+                                      num_dicts);
+               if (dicts == NULL)
+                       abort();
+
+               status = snapper_dict_unpack(&array_iter,
+                                            &dicts[num_dicts - 1]);
+               if (!NT_STATUS_IS_OK(status)) {
+                       talloc_free(dicts);
+                       return status;
+               }
+               dbus_message_iter_next(&array_iter);
+       }
+
+       *num_dicts_out = num_dicts;
+       *dicts_out = dicts;
+
+       return NT_STATUS_OK;
+}
+
+static NTSTATUS snapper_list_confs_pack(DBusMessage **req_msg_out)
+{
+       DBusMessage *msg;
+
+       msg = dbus_message_new_method_call("org.opensuse.Snapper",
+                                          "/org/opensuse/Snapper",
+                                          "org.opensuse.Snapper",
+                                          "ListConfigs");
+       if (msg == NULL) {
+               DEBUG(0, ("null msg\n"));
+               return NT_STATUS_NO_MEMORY;
+       }
+
+       /* no arguments to append */
+       *req_msg_out = msg;
+
+       return NT_STATUS_OK;
+}
+
+static NTSTATUS snapper_conf_unpack(TALLOC_CTX *mem_ctx,
+                                   DBusMessageIter *iter,
+                                   struct snapper_conf *conf_out)
+{
+       NTSTATUS status;
+       DBusMessageIter st_iter;
+
+       status = snapper_type_check(iter, DBUS_TYPE_STRUCT);
+       if (!NT_STATUS_IS_OK(status)) {
+               return status;
+       }
+       dbus_message_iter_recurse(iter, &st_iter);
+
+       status = snapper_type_check_get(&st_iter, DBUS_TYPE_STRING,
+                                       &conf_out->name);
+       if (!NT_STATUS_IS_OK(status)) {
+               return status;
+       }
+
+       dbus_message_iter_next(&st_iter);
+       status = snapper_type_check_get(&st_iter, DBUS_TYPE_STRING,
+                                       &conf_out->mnt);
+       if (!NT_STATUS_IS_OK(status)) {
+               return status;
+       }
+
+       dbus_message_iter_next(&st_iter);
+       status = snapper_dict_array_unpack(mem_ctx, &st_iter,
+                                          &conf_out->num_attrs,
+                                          &conf_out->attrs);
+
+       return status;
+}
+
+static struct snapper_conf *snapper_conf_array_base_find(int32_t num_confs,
+                                               struct snapper_conf *confs,
+                                                        const char *base)
+{
+       int i;
+
+       for (i = 0; i < num_confs; i++) {
+               if (strcmp(confs[i].mnt, base) == 0) {
+                       DEBUG(5, ("found snapper conf %s for path %s\n",
+                                 confs[i].name, base));
+                       return &confs[i];
+               }
+       }
+       DEBUG(5, ("config for base %s not found\n", base));
+
+       return NULL;
+}
+
+static void snapper_conf_array_print(int32_t num_confs,
+                                    struct snapper_conf *confs)
+{
+       int i;
+
+       for (i = 0; i < num_confs; i++) {
+               DEBUG(10, ("name: %s, mnt: %s\n",
+                          confs[i].name, confs[i].mnt));
+               snapper_dict_array_print(confs[i].num_attrs, confs[i].attrs);
+       }
+}
+
+static NTSTATUS snapper_conf_array_unpack(TALLOC_CTX *mem_ctx,
+                                         DBusMessageIter *iter,
+                                         uint32_t *num_confs_out,
+                                         struct snapper_conf **confs_out)
+{
+       uint32_t num_confs;
+       NTSTATUS status;
+       struct snapper_conf *confs = NULL;
+       DBusMessageIter array_iter;
+
+
+       status = snapper_type_check(iter, DBUS_TYPE_ARRAY);
+       if (!NT_STATUS_IS_OK(status)) {
+               return status;
+       }
+       dbus_message_iter_recurse(iter, &array_iter);
+
+       num_confs = 0;
+       while (dbus_message_iter_get_arg_type(&array_iter)
+                                                       != DBUS_TYPE_INVALID) {
+               num_confs++;
+               confs = talloc_realloc(mem_ctx, confs, struct snapper_conf,
+                                      num_confs);
+               if (confs == NULL)
+                       abort();


-- 
Samba Shared Repository

Reply via email to