[s3]libsmbconf: add backend_requires_messaging() method to libsmbconf.
[ira/wip.git] / source3 / lib / smbconf / smbconf_reg.c
index 75b76a8de0d618303e37f0a8113058a8e6b145c5..6edb9ed22e8a998e6cfb483c17e37e86a6d44105 100644 (file)
@@ -52,6 +52,7 @@ static bool smbconf_reg_valname_forbidden(const char *valname)
                "lock dir",
                "config backend",
                "include",
+               "includes", /* this has a special meaning internally */
                NULL
        };
        const char **forbidden = NULL;
@@ -66,8 +67,8 @@ static bool smbconf_reg_valname_forbidden(const char *valname)
 
 static bool smbconf_reg_valname_valid(const char *valname)
 {
-       return (lp_parameter_is_valid(valname) &&
-               !smbconf_reg_valname_forbidden(valname));
+       return (!smbconf_reg_valname_forbidden(valname) &&
+               lp_parameter_is_valid(valname));
 }
 
 /**
@@ -110,7 +111,7 @@ static WERROR smbconf_reg_open_path(TALLOC_CTX *mem_ctx,
                             key);
 
        if (!W_ERROR_IS_OK(werr)) {
-               DEBUG(1, ("Error opening registry path '%s': %s\n",
+               DEBUG(5, ("Error opening registry path '%s': %s\n",
                          path, dos_errstr(werr)));
        }
 
@@ -131,12 +132,11 @@ static WERROR smbconf_reg_open_service_key(TALLOC_CTX *mem_ctx,
        char *path = NULL;
 
        if (servicename == NULL) {
-               DEBUG(3, ("Error: NULL servicename given.\n"));
-               werr = WERR_INVALID_PARAM;
-               goto done;
+               path = talloc_strdup(mem_ctx, ctx->path);
+       } else {
+               path = talloc_asprintf(mem_ctx, "%s\\%s", ctx->path,
+                                      servicename);
        }
-
-       path = talloc_asprintf(mem_ctx, "%s\\%s", ctx->path, servicename);
        if (path == NULL) {
                werr = WERR_NOMEM;
                goto done;
@@ -196,10 +196,7 @@ static WERROR smbconf_reg_create_service_key(TALLOC_CTX *mem_ctx,
        /* create a new talloc ctx for creation. it will hold
         * the intermediate parent key (SMBCONF) for creation
         * and will be destroyed when leaving this function... */
-       if (!(create_ctx = talloc_stackframe())) {
-               werr = WERR_NOMEM;
-               goto done;
-       }
+       create_ctx = talloc_stackframe();
 
        werr = smbconf_reg_open_base_key(create_ctx, ctx, REG_KEY_WRITE,
                                         &create_parent);
@@ -211,7 +208,7 @@ static WERROR smbconf_reg_create_service_key(TALLOC_CTX *mem_ctx,
                             REG_KEY_WRITE, newkey, &action);
        if (W_ERROR_IS_OK(werr) && (action != REG_CREATED_NEW_KEY)) {
                DEBUG(10, ("Key '%s' already exists.\n", subkeyname));
-               werr = WERR_ALREADY_EXISTS;
+               werr = WERR_FILE_EXISTS;
        }
        if (!W_ERROR_IS_OK(werr)) {
                DEBUG(5, ("Error creating key %s: %s\n",
@@ -399,6 +396,9 @@ static WERROR smbconf_reg_get_includes_internal(TALLOC_CTX *mem_ctx,
 
        if (!smbconf_value_exists(key, INCLUDES_VALNAME)) {
                /* no includes */
+               *num_includes = 0;
+               *includes = NULL;
+               werr = WERR_OK;
                goto done;
        }
 
@@ -469,10 +469,6 @@ static WERROR smbconf_reg_get_values(TALLOC_CTX *mem_ctx,
        }
 
        tmp_ctx = talloc_stackframe();
-       if (tmp_ctx == NULL) {
-               werr = WERR_NOMEM;
-               goto done;
-       }
 
        for (count = 0;
             werr = reg_enumvalue(tmp_ctx, key, count, &valname, &valvalue),
@@ -541,6 +537,65 @@ done:
        return werr;
 }
 
+static bool smbconf_reg_key_has_values(struct registry_key *key)
+{
+       WERROR werr;
+       uint32_t num_subkeys;
+       uint32_t max_subkeylen;
+       uint32_t max_subkeysize;
+       uint32_t num_values;
+       uint32_t max_valnamelen;
+       uint32_t max_valbufsize;
+       uint32_t secdescsize;
+       NTTIME last_changed_time;
+
+       werr = reg_queryinfokey(key, &num_subkeys, &max_subkeylen,
+                               &max_subkeysize, &num_values, &max_valnamelen,
+                               &max_valbufsize, &secdescsize,
+                               &last_changed_time);
+       if (!W_ERROR_IS_OK(werr)) {
+               return false;
+       }
+
+       return (num_values != 0);
+}
+
+/**
+ * delete all values from a key
+ */
+static WERROR smbconf_reg_delete_values(struct registry_key *key)
+{
+       WERROR werr;
+       char *valname;
+       struct registry_value *valvalue;
+       uint32_t count;
+       TALLOC_CTX *mem_ctx = talloc_stackframe();
+
+       for (count = 0;
+            werr = reg_enumvalue(mem_ctx, key, count, &valname, &valvalue),
+            W_ERROR_IS_OK(werr);
+            count++)
+       {
+               werr = reg_deletevalue(key, valname);
+               if (!W_ERROR_IS_OK(werr)) {
+                       goto done;
+               }
+       }
+       if (!W_ERROR_EQUAL(WERR_NO_MORE_ITEMS, werr)) {
+               DEBUG(1, ("smbconf_reg_delete_values: "
+                         "Error enumerating values of %s: %s\n",
+                         key->key->name,
+                         dos_errstr(werr)));
+               goto done;
+       }
+
+       werr = WERR_OK;
+
+done:
+       TALLOC_FREE(mem_ctx);
+       return werr;
+}
+
 /**********************************************************************
  *
  * smbconf operations: registry implementations
@@ -573,8 +628,8 @@ static WERROR smbconf_reg_init(struct smbconf_ctx *ctx, const char *path)
        }
        rpd(ctx)->open = false;
 
-       if (!registry_init_smbconf()) {
-               werr = WERR_REG_IO_FAILURE;
+       werr = registry_init_smbconf(path);
+       if (!W_ERROR_IS_OK(werr)) {
                goto done;
        }
 
@@ -587,6 +642,16 @@ static int smbconf_reg_shutdown(struct smbconf_ctx *ctx)
        return ctx->ops->close_conf(ctx);
 }
 
+static bool smbconf_reg_requires_messaging(struct smbconf_ctx *ctx)
+{
+#ifdef CLUSTER_SUPPORT
+       if (lp_clustering() && lp_parm_bool(-1, "ctdb", "registry.tdb", true)) {
+               return true;
+       }
+#endif
+       return false;
+}
+
 static WERROR smbconf_reg_open(struct smbconf_ctx *ctx)
 {
        WERROR werr;
@@ -699,25 +764,31 @@ static WERROR smbconf_reg_get_share_names(struct smbconf_ctx *ctx,
        }
 
        tmp_ctx = talloc_stackframe();
-       if (tmp_ctx == NULL) {
-               werr = WERR_NOMEM;
+
+       /* if there are values in the base key, return NULL as share name */
+       werr = smbconf_reg_open_base_key(tmp_ctx, ctx,
+                                        SEC_RIGHTS_ENUM_SUBKEYS, &key);
+       if (!W_ERROR_IS_OK(werr)) {
                goto done;
        }
 
-       /* make sure "global" is always listed first */
-       if (smbconf_share_exists(ctx, GLOBAL_NAME)) {
+       if (smbconf_reg_key_has_values(key)) {
                werr = smbconf_add_string_to_array(tmp_ctx, &tmp_share_names,
-                                                  0, GLOBAL_NAME);
+                                                  0, NULL);
                if (!W_ERROR_IS_OK(werr)) {
                        goto done;
                }
                added_count++;
        }
 
-       werr = smbconf_reg_open_base_key(tmp_ctx, ctx,
-                                        SEC_RIGHTS_ENUM_SUBKEYS, &key);
-       if (!W_ERROR_IS_OK(werr)) {
-               goto done;
+       /* make sure "global" is always listed first */
+       if (smbconf_share_exists(ctx, GLOBAL_NAME)) {
+               werr = smbconf_add_string_to_array(tmp_ctx, &tmp_share_names,
+                                                  added_count, GLOBAL_NAME);
+               if (!W_ERROR_IS_OK(werr)) {
+                       goto done;
+               }
+               added_count++;
        }
 
        for (count = 0;
@@ -786,7 +857,13 @@ static WERROR smbconf_reg_create_share(struct smbconf_ctx *ctx,
        TALLOC_CTX *mem_ctx = talloc_stackframe();
        struct registry_key *key = NULL;
 
-       werr = smbconf_reg_create_service_key(mem_ctx, ctx, servicename, &key);
+       if (servicename == NULL) {
+               werr = smbconf_reg_open_base_key(mem_ctx, ctx, REG_KEY_WRITE,
+                                                &key);
+       } else {
+               werr = smbconf_reg_create_service_key(mem_ctx, ctx,
+                                                     servicename, &key);
+       }
 
        TALLOC_FREE(mem_ctx);
        return werr;
@@ -798,23 +875,44 @@ static WERROR smbconf_reg_create_share(struct smbconf_ctx *ctx,
 static WERROR smbconf_reg_get_share(struct smbconf_ctx *ctx,
                                    TALLOC_CTX *mem_ctx,
                                    const char *servicename,
-                                   uint32_t *num_params,
-                                   char ***param_names, char ***param_values)
+                                   struct smbconf_service **service)
 {
        WERROR werr = WERR_OK;
        struct registry_key *key = NULL;
+       struct smbconf_service *tmp_service = NULL;
+       TALLOC_CTX *tmp_ctx = talloc_stackframe();
 
-       werr = smbconf_reg_open_service_key(mem_ctx, ctx, servicename,
+       werr = smbconf_reg_open_service_key(tmp_ctx, ctx, servicename,
                                            REG_KEY_READ, &key);
        if (!W_ERROR_IS_OK(werr)) {
                goto done;
        }
 
-       werr = smbconf_reg_get_values(mem_ctx, key, num_params,
-                                     param_names, param_values);
+       tmp_service = TALLOC_ZERO_P(tmp_ctx, struct smbconf_service);
+       if (tmp_service == NULL) {
+               werr =  WERR_NOMEM;
+               goto done;
+       }
+
+       if (servicename != NULL) {
+               tmp_service->name = talloc_strdup(tmp_service, servicename);
+               if (tmp_service->name == NULL) {
+                       werr = WERR_NOMEM;
+                       goto done;
+               }
+       }
+
+       werr = smbconf_reg_get_values(tmp_service, key,
+                                     &(tmp_service->num_params),
+                                     &(tmp_service->param_names),
+                                     &(tmp_service->param_values));
+
+       if (W_ERROR_IS_OK(werr)) {
+               *service = talloc_move(mem_ctx, &tmp_service);
+       }
 
 done:
-       TALLOC_FREE(key);
+       TALLOC_FREE(tmp_ctx);
        return werr;
 }
 
@@ -833,7 +931,11 @@ static WERROR smbconf_reg_delete_share(struct smbconf_ctx *ctx,
                goto done;
        }
 
-       werr = reg_deletekey_recursive(key, key, servicename);
+       if (servicename != NULL) {
+               werr = reg_deletekey_recursive(key, key, servicename);
+       } else {
+               werr = smbconf_reg_delete_values(key);
+       }
 
 done:
        TALLOC_FREE(mem_ctx);
@@ -884,6 +986,11 @@ static WERROR smbconf_reg_get_parameter(struct smbconf_ctx *ctx,
                goto done;
        }
 
+       if (!smbconf_reg_valname_valid(param)) {
+               werr = WERR_INVALID_PARAM;
+               goto done;
+       }
+
        if (!smbconf_value_exists(key, param)) {
                werr = WERR_INVALID_PARAM;
                goto done;
@@ -923,6 +1030,11 @@ static WERROR smbconf_reg_delete_parameter(struct smbconf_ctx *ctx,
                goto done;
        }
 
+       if (!smbconf_reg_valname_valid(param)) {
+               werr = WERR_INVALID_PARAM;
+               goto done;
+       }
+
        if (!smbconf_value_exists(key, param)) {
                werr = WERR_INVALID_PARAM;
                goto done;
@@ -974,18 +1086,50 @@ static WERROR smbconf_reg_set_includes(struct smbconf_ctx *ctx,
                goto done;
        }
 
-       werr = smbconf_reg_set_multi_sz_value(key, INCLUDES_VALNAME,
-                                             num_includes, includes);
+       if (num_includes == 0) {
+               if (!smbconf_value_exists(key, INCLUDES_VALNAME)) {
+                       goto done;
+               }
+               werr = reg_deletevalue(key, INCLUDES_VALNAME);
+       } else {
+               werr = smbconf_reg_set_multi_sz_value(key, INCLUDES_VALNAME,
+                                                     num_includes, includes);
+       }
 
 done:
        TALLOC_FREE(tmp_ctx);
        return werr;
 }
 
+static WERROR smbconf_reg_delete_includes(struct smbconf_ctx *ctx,
+                                         const char *service)
+{
+       WERROR werr = WERR_OK;
+       struct registry_key *key = NULL;
+       TALLOC_CTX *tmp_ctx = talloc_stackframe();
+
+       werr = smbconf_reg_open_service_key(tmp_ctx, ctx, service,
+                                           REG_KEY_ALL, &key);
+       if (!W_ERROR_IS_OK(werr)) {
+               goto done;
+       }
+
+       if (!smbconf_value_exists(key, INCLUDES_VALNAME)) {
+               goto done;
+       }
+
+       werr = reg_deletevalue(key, INCLUDES_VALNAME);
+
+
+done:
+       TALLOC_FREE(tmp_ctx);
+       return werr;
+}
 
 struct smbconf_ops smbconf_ops_reg = {
        .init                   = smbconf_reg_init,
        .shutdown               = smbconf_reg_shutdown,
+       .requires_messaging     = smbconf_reg_requires_messaging,
        .open_conf              = smbconf_reg_open,
        .close_conf             = smbconf_reg_close,
        .get_csn                = smbconf_reg_get_csn,
@@ -1000,6 +1144,7 @@ struct smbconf_ops smbconf_ops_reg = {
        .delete_parameter       = smbconf_reg_delete_parameter,
        .get_includes           = smbconf_reg_get_includes,
        .set_includes           = smbconf_reg_set_includes,
+       .delete_includes        = smbconf_reg_delete_includes,
 };
 
 
@@ -1010,5 +1155,5 @@ struct smbconf_ops smbconf_ops_reg = {
 WERROR smbconf_init_reg(TALLOC_CTX *mem_ctx, struct smbconf_ctx **conf_ctx,
                        const char *path)
 {
-       return smbconf_init(mem_ctx, conf_ctx, path, &smbconf_ops_reg);
+       return smbconf_init_internal(mem_ctx, conf_ctx, path, &smbconf_ops_reg);
 }