From 6fe479a210adb53d419ca75512dec3a584296289 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Pavel=20B=C5=99ezina?= Date: Tue, 13 Aug 2019 13:00:23 +0200 Subject: [PATCH 77/90] cache_req: add autofs entry by name plugin MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit We will use the current data provider call that downloads all map entries but we will replace it later when new call is available. Resolves: https://pagure.io/SSSD/sssd/issue/2607 Reviewed-by: Tomáš Halman --- Makefile.am | 1 + src/responder/common/cache_req/cache_req.c | 3 +- src/responder/common/cache_req/cache_req.h | 21 +++ .../common/cache_req/cache_req_data.c | 33 +++++ .../common/cache_req/cache_req_plugin.h | 1 + .../common/cache_req/cache_req_private.h | 1 + .../plugins/cache_req_autofs_entry_by_name.c | 129 ++++++++++++++++++ src/tests/cwrap/Makefile.am | 1 + 8 files changed, 189 insertions(+), 1 deletion(-) create mode 100644 src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c diff --git a/Makefile.am b/Makefile.am index 461a9355f..bc74906a7 100644 --- a/Makefile.am +++ b/Makefile.am @@ -561,6 +561,7 @@ SSSD_CACHE_REQ_OBJ = \ src/responder/common/cache_req/plugins/cache_req_host_by_name.c \ src/responder/common/cache_req/plugins/cache_req_autofs_map_entries.c \ src/responder/common/cache_req/plugins/cache_req_autofs_map_by_name.c \ + src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c \ $(NULL) SSSD_RESPONDER_IFACE_OBJ = \ diff --git a/src/responder/common/cache_req/cache_req.c b/src/responder/common/cache_req/cache_req.c index 75f396a23..febca2468 100644 --- a/src/responder/common/cache_req/cache_req.c +++ b/src/responder/common/cache_req/cache_req.c @@ -62,7 +62,8 @@ cache_req_get_plugin(enum cache_req_type type) &cache_req_host_by_name, &cache_req_autofs_map_entries, - &cache_req_autofs_map_by_name + &cache_req_autofs_map_by_name, + &cache_req_autofs_entry_by_name }; if (type >= CACHE_REQ_SENTINEL) { diff --git a/src/responder/common/cache_req/cache_req.h b/src/responder/common/cache_req/cache_req.h index 66a13445c..412f6221b 100644 --- a/src/responder/common/cache_req/cache_req.h +++ b/src/responder/common/cache_req/cache_req.h @@ -56,6 +56,7 @@ enum cache_req_type { CACHE_REQ_AUTOFS_MAP_ENTRIES, CACHE_REQ_AUTOFS_MAP_BY_NAME, + CACHE_REQ_AUTOFS_ENTRY_BY_NAME, CACHE_REQ_SENTINEL }; @@ -126,6 +127,13 @@ cache_req_data_host(TALLOC_CTX *mem_ctx, const char *name, const char *alias, const char **attrs); + +struct cache_req_data * +cache_req_data_autofs_entry(TALLOC_CTX *mem_ctx, + enum cache_req_type type, + const char *mapname, + const char *entryname); + void cache_req_data_set_bypass_cache(struct cache_req_data *data, bool bypass_cache); @@ -457,4 +465,17 @@ cache_req_autofs_map_by_name_send(TALLOC_CTX *mem_ctx, #define cache_req_autofs_map_by_name_recv(mem_ctx, req, _result) \ cache_req_single_domain_recv(mem_ctx, req, _result) +struct tevent_req * +cache_req_autofs_entry_by_name_send(TALLOC_CTX *mem_ctx, + struct tevent_context *ev, + struct resp_ctx *rctx, + struct sss_nc_ctx *ncache, + int cache_refresh_percent, + const char *domain, + const char *mapname, + const char *entryname); + +#define cache_req_autofs_entry_by_name_recv(mem_ctx, req, _result) \ + cache_req_single_domain_recv(mem_ctx, req, _result) + #endif /* _CACHE_REQ_H_ */ diff --git a/src/responder/common/cache_req/cache_req_data.c b/src/responder/common/cache_req/cache_req_data.c index ad6176641..01eeedbc4 100644 --- a/src/responder/common/cache_req/cache_req_data.c +++ b/src/responder/common/cache_req/cache_req_data.c @@ -209,6 +209,25 @@ cache_req_data_create(TALLOC_CTX *mem_ctx, goto done; } break; + case CACHE_REQ_AUTOFS_ENTRY_BY_NAME: + if (input->name.input == NULL) { + DEBUG(SSSDBG_CRIT_FAILURE, "Bug: name cannot be NULL!\n"); + ret = ERR_INTERNAL; + goto done; + } + + data->name.input = talloc_strdup(data, input->name.input); + if (data->name.input == NULL) { + ret = ENOMEM; + goto done; + } + + data->autofs_entry_name = talloc_strdup(data, input->autofs_entry_name); + if (data->autofs_entry_name == NULL) { + ret = ENOMEM; + goto done; + } + break; case CACHE_REQ_SENTINEL: DEBUG(SSSDBG_CRIT_FAILURE, "Invalid cache request type!\n"); ret = ERR_INTERNAL; @@ -356,6 +375,20 @@ cache_req_data_host(TALLOC_CTX *mem_ctx, return cache_req_data_create(mem_ctx, type, &input); } +struct cache_req_data * +cache_req_data_autofs_entry(TALLOC_CTX *mem_ctx, + enum cache_req_type type, + const char *mapname, + const char *entryname) +{ + struct cache_req_data input = {0}; + + input.name.input = mapname; + input.autofs_entry_name = entryname; + + return cache_req_data_create(mem_ctx, type, &input); +} + void cache_req_data_set_bypass_cache(struct cache_req_data *data, bool bypass_cache) diff --git a/src/responder/common/cache_req/cache_req_plugin.h b/src/responder/common/cache_req/cache_req_plugin.h index c040bf380..745a36c0e 100644 --- a/src/responder/common/cache_req/cache_req_plugin.h +++ b/src/responder/common/cache_req/cache_req_plugin.h @@ -316,5 +316,6 @@ extern const struct cache_req_plugin cache_req_netgroup_by_name; extern const struct cache_req_plugin cache_req_host_by_name; extern const struct cache_req_plugin cache_req_autofs_map_entries; extern const struct cache_req_plugin cache_req_autofs_map_by_name; +extern const struct cache_req_plugin cache_req_autofs_entry_by_name; #endif /* _CACHE_REQ_PLUGIN_H_ */ diff --git a/src/responder/common/cache_req/cache_req_private.h b/src/responder/common/cache_req/cache_req_private.h index a88c838d9..34bd3ce15 100644 --- a/src/responder/common/cache_req/cache_req_private.h +++ b/src/responder/common/cache_req/cache_req_private.h @@ -83,6 +83,7 @@ struct cache_req_data { const char *sid; const char *alias; const char **attrs; + const char *autofs_entry_name; struct { struct cache_req_parsed_name *name; diff --git a/src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c b/src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c new file mode 100644 index 000000000..17b0b508e --- /dev/null +++ b/src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c @@ -0,0 +1,129 @@ +/* + Authors: + Pavel Březina + + Copyright (C) 2019 Red Hat + + 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 . +*/ + +#include +#include + +#include "db/sysdb.h" +#include "db/sysdb_autofs.h" +#include "util/util.h" +#include "providers/data_provider.h" +#include "responder/common/cache_req/cache_req_plugin.h" + +static const char * +cache_req_autofs_entry_by_name_create_debug_name(TALLOC_CTX *mem_ctx, + struct cache_req_data *data, + struct sss_domain_info *domain) +{ + return talloc_asprintf(mem_ctx, "%s:%s", + data->name.name, + data->autofs_entry_name); +} + +static errno_t +cache_req_autofs_entry_by_name_lookup(TALLOC_CTX *mem_ctx, + struct cache_req *cr, + struct cache_req_data *data, + struct sss_domain_info *domain, + struct ldb_result **_result) +{ + struct ldb_message *entry; + struct ldb_result *result; + errno_t ret; + + ret = sysdb_get_autofsentry(mem_ctx, domain, data->name.name, + data->autofs_entry_name, &entry); + if (ret != EOK) { + return ret; + } + + result = cache_req_create_ldb_result_from_msg(mem_ctx, entry); + if (result == NULL) { + talloc_free(entry); + return ENOMEM; + } + + *_result = talloc_steal(mem_ctx, result); + return EOK; +} + +static struct tevent_req * +cache_req_autofs_entry_by_name_dp_send(TALLOC_CTX *mem_ctx, + struct cache_req *cr, + struct cache_req_data *data, + struct sss_domain_info *domain, + struct ldb_result *result) +{ + return sss_dp_get_autofs_send(mem_ctx, cr->rctx, domain, true, + SSS_DP_AUTOFS, data->name.name); +} + +const struct cache_req_plugin cache_req_autofs_entry_by_name = { + .name = "Get autofs entry", + .attr_expiration = SYSDB_CACHE_EXPIRE, + .parse_name = true, + .ignore_default_domain = true, + .bypass_cache = false, + .only_one_result = false, + .search_all_domains = false, + .require_enumeration = false, + .allow_missing_fqn = true, + .allow_switch_to_upn = false, + .upn_equivalent = CACHE_REQ_SENTINEL, + .get_next_domain_flags = 0, + + .is_well_known_fn = NULL, + .prepare_domain_data_fn = NULL, + .create_debug_name_fn = cache_req_autofs_entry_by_name_create_debug_name, + .global_ncache_add_fn = NULL, + .ncache_check_fn = NULL, + .ncache_add_fn = NULL, + .ncache_filter_fn = NULL, + .lookup_fn = cache_req_autofs_entry_by_name_lookup, + .dp_send_fn = cache_req_autofs_entry_by_name_dp_send, + .dp_recv_fn = cache_req_common_dp_recv, + .dp_get_domain_check_fn = NULL, + .dp_get_domain_send_fn = NULL, + .dp_get_domain_recv_fn = NULL, +}; + +struct tevent_req * +cache_req_autofs_entry_by_name_send(TALLOC_CTX *mem_ctx, + struct tevent_context *ev, + struct resp_ctx *rctx, + struct sss_nc_ctx *ncache, + int cache_refresh_percent, + const char *domain, + const char *mapname, + const char *entryname) +{ + struct cache_req_data *data; + + data = cache_req_data_autofs_entry(mem_ctx, CACHE_REQ_AUTOFS_ENTRY_BY_NAME, + mapname, entryname); + if (data == NULL) { + return NULL; + } + + return cache_req_steal_data_and_send(mem_ctx, ev, rctx, ncache, + cache_refresh_percent, + CACHE_REQ_POSIX_DOM, domain, + data); +} diff --git a/src/tests/cwrap/Makefile.am b/src/tests/cwrap/Makefile.am index 3fbcebf3c..aaec6c700 100644 --- a/src/tests/cwrap/Makefile.am +++ b/src/tests/cwrap/Makefile.am @@ -66,6 +66,7 @@ SSSD_CACHE_REQ_OBJ = \ ../../../src/responder/common/cache_req/plugins/cache_req_host_by_name.c \ ../../../src/responder/common/cache_req/plugins/cache_req_autofs_map_entries.c \ ../../../src/responder/common/cache_req/plugins/cache_req_autofs_map_by_name.c \ + ../../../src/responder/common/cache_req/plugins/cache_req_autofs_entry_by_name.c \ $(NULL) SSSD_RESPONDER_IFACE_OBJ = \ -- 2.20.1