fail_over_srv.c revision 77d165f0629966db65753a3aee84a8b4971673af
77d165f0629966db65753a3aee84a8b4971673afPavel Březina/*
77d165f0629966db65753a3aee84a8b4971673afPavel Březina Authors:
77d165f0629966db65753a3aee84a8b4971673afPavel Březina Pavel B??ezina <pbrezina@redhat.com>
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina Copyright (C) 2013 Red Hat
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina This program is free software; you can redistribute it and/or modify
77d165f0629966db65753a3aee84a8b4971673afPavel Březina it under the terms of the GNU General Public License as published by
77d165f0629966db65753a3aee84a8b4971673afPavel Březina the Free Software Foundation; either version 3 of the License, or
77d165f0629966db65753a3aee84a8b4971673afPavel Březina (at your option) any later version.
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina This program is distributed in the hope that it will be useful,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina but WITHOUT ANY WARRANTY; without even the implied warranty of
77d165f0629966db65753a3aee84a8b4971673afPavel Březina MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
77d165f0629966db65753a3aee84a8b4971673afPavel Březina GNU General Public License for more details.
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina You should have received a copy of the GNU General Public License
77d165f0629966db65753a3aee84a8b4971673afPavel Březina along with this program. If not, see <http://www.gnu.org/licenses/>.
77d165f0629966db65753a3aee84a8b4971673afPavel Březina*/
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina#include <string.h>
77d165f0629966db65753a3aee84a8b4971673afPavel Březina#include <talloc.h>
77d165f0629966db65753a3aee84a8b4971673afPavel Březina#include <tevent.h>
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina#include "util/util.h"
77d165f0629966db65753a3aee84a8b4971673afPavel Březina#include "resolv/async_resolv.h"
77d165f0629966db65753a3aee84a8b4971673afPavel Březina#include "providers/fail_over_srv.h"
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastruct fo_discover_srv_state {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina char *dns_domain;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_server_info *servers;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina size_t num_servers;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina};
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastatic void fo_discover_srv_done(struct tevent_req *subreq);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastruct tevent_req *fo_discover_srv_send(TALLOC_CTX *mem_ctx,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_context *ev,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct resolv_ctx *resolv_ctx,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *service,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *protocol,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char **discovery_domains)
77d165f0629966db65753a3aee84a8b4971673afPavel Březina{
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_discover_srv_state *state = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *req = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *subreq = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina errno_t ret;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina req = tevent_req_create(mem_ctx, &state, struct fo_discover_srv_state);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (req == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina DEBUG(SSSDBG_CRIT_FAILURE, ("tevent_req_create() failed\n"));
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina subreq = resolv_discover_srv_send(state, ev, resolv_ctx, service,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina protocol, discovery_domains);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (subreq == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = ENOMEM;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto immediately;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_set_callback(subreq, fo_discover_srv_done, req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return req;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinaimmediately:
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_error(req, ret);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_post(req, ev);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return req;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina}
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastatic void fo_discover_srv_done(struct tevent_req *subreq)
77d165f0629966db65753a3aee84a8b4971673afPavel Březina{
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_discover_srv_state *state = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *req = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct ares_srv_reply *reply_list = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct ares_srv_reply *record = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina int i;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina errno_t ret;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina req = tevent_req_callback_data(subreq, struct tevent_req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state = tevent_req_data(req, struct fo_discover_srv_state);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = resolv_discover_srv_recv(state, subreq,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina &reply_list, &state->dns_domain);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina talloc_zfree(subreq);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret == ENOENT) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = ERR_SRV_NOT_FOUND;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina } else if (ret == EIO) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = ERR_SRV_LOOKUP_ERROR;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina } else if (ret != EOK) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina DEBUG(SSSDBG_TRACE_FUNC, ("Got answer. Processing...\n"));
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina /* sort and store the answer */
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = resolv_sort_srv_reply(state, &reply_list);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret != EOK) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina DEBUG(SSSDBG_CRIT_FAILURE, ("Could not sort the answers from DNS "
77d165f0629966db65753a3aee84a8b4971673afPavel Březina "[%d]: %s\n", ret, strerror(ret)));
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->num_servers = 0;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina for (record = reply_list; record != NULL; record = record->next) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->num_servers++;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina DEBUG(SSSDBG_TRACE_FUNC, ("Got %lu servers\n", state->num_servers));
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->servers = talloc_array(state, struct fo_server_info,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->num_servers);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (state->servers == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = ENOMEM;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina for (record = reply_list, i = 0;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina record != NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina record = record->next, i++) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->servers[i].host = talloc_steal(state->servers, record->host);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->servers[i].port = record->port;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina talloc_zfree(reply_list);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = EOK;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinadone:
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret != EOK) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_error(req, ret);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_done(req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina}
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinaerrno_t fo_discover_srv_recv(TALLOC_CTX *mem_ctx,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *req,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina char **_dns_domain,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_server_info **_servers,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina size_t *_num_servers)
77d165f0629966db65753a3aee84a8b4971673afPavel Březina{
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_discover_srv_state *state = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state = tevent_req_data(req, struct fo_discover_srv_state);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina TEVENT_REQ_RETURN_ON_ERROR(req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (_dns_domain != NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina *_dns_domain = talloc_steal(mem_ctx, state->dns_domain);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (_servers != NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina *_servers = talloc_steal(mem_ctx, state->servers);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (_num_servers != NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina *_num_servers = state->num_servers;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return EOK;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina}
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastruct fo_resolve_srv_dns_ctx {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct resolv_ctx *resolv_ctx;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina enum restrict_family family_order;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina enum host_database *host_dbs;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina char *hostname;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina char *sssd_domain;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina char *detected_domain;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina};
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastruct fo_resolve_srv_dns_state {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_context *ev;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_resolve_srv_dns_ctx *ctx;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *service;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *protocol;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *discovery_domain;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina char *dns_domain;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_server_info *servers;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina size_t num_servers;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina};
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastatic void fo_resolve_srv_dns_domain_done(struct tevent_req *subreq);
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastatic errno_t fo_resolve_srv_dns_discover(struct tevent_req *req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastatic void fo_resolve_srv_dns_done(struct tevent_req *subreq);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastruct fo_resolve_srv_dns_ctx *
77d165f0629966db65753a3aee84a8b4971673afPavel Březinafo_resolve_srv_dns_ctx_init(TALLOC_CTX *mem_ctx,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct resolv_ctx *resolv_ctx,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina enum restrict_family family_order,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina enum host_database *host_dbs,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *hostname,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *sssd_domain)
77d165f0629966db65753a3aee84a8b4971673afPavel Březina{
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_resolve_srv_dns_ctx *ctx = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx = talloc_zero(mem_ctx, struct fo_resolve_srv_dns_ctx);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ctx == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx->resolv_ctx = resolv_ctx;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx->family_order = family_order;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx->host_dbs = host_dbs;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx->hostname = talloc_strdup(ctx, hostname);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ctx->hostname == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto fail;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx->sssd_domain = talloc_strdup(ctx, sssd_domain);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ctx->sssd_domain == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto fail;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return ctx;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinafail:
77d165f0629966db65753a3aee84a8b4971673afPavel Březina talloc_free(ctx);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina}
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastruct tevent_req *fo_resolve_srv_dns_send(TALLOC_CTX *mem_ctx,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_context *ev,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *service,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *protocol,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char *discovery_domain,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina void *pvt)
77d165f0629966db65753a3aee84a8b4971673afPavel Březina{
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_resolve_srv_dns_state *state = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_resolve_srv_dns_ctx *ctx = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *req = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *subreq = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina errno_t ret;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina req = tevent_req_create(mem_ctx, &state, struct fo_resolve_srv_dns_state);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (req == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina DEBUG(SSSDBG_CRIT_FAILURE, ("tevent_req_create() failed\n"));
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx = talloc_get_type(pvt, struct fo_resolve_srv_dns_ctx);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ctx == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = EINVAL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto immediately;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->ev = ev;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->ctx = ctx;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->service = service;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->protocol = protocol;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (discovery_domain == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->discovery_domain = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina } else {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->discovery_domain = discovery_domain;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (discovery_domain == NULL && ctx->detected_domain == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina /* we will try to detect proper discovery domain */
77d165f0629966db65753a3aee84a8b4971673afPavel Březina subreq = resolv_get_domain_send(state, state->ev, ctx->resolv_ctx,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx->hostname, ctx->host_dbs,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx->family_order);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (subreq == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = ENOMEM;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto immediately;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_set_callback(subreq, fo_resolve_srv_dns_domain_done, req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina } else {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina /* we will use either provided or previously detected
77d165f0629966db65753a3aee84a8b4971673afPavel Březina * discovery domain */
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = fo_resolve_srv_dns_discover(req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret != EAGAIN) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto immediately;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return req;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinaimmediately:
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret == EOK) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_done(req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina } else {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_error(req, ret);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_post(req, ev);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return req;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina}
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastatic void fo_resolve_srv_dns_domain_done(struct tevent_req *subreq)
77d165f0629966db65753a3aee84a8b4971673afPavel Březina{
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_resolve_srv_dns_state *state = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *req = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina errno_t ret;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina req = tevent_req_callback_data(subreq, struct tevent_req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state = tevent_req_data(req, struct fo_resolve_srv_dns_state);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = resolv_get_domain_recv(state->ctx, subreq,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina &state->ctx->detected_domain);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina talloc_zfree(subreq);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret != EOK) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = fo_resolve_srv_dns_discover(req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinadone:
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret == EOK) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_done(req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina } else if (ret != EAGAIN) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_error(req, ret);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina}
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastatic errno_t fo_resolve_srv_dns_discover(struct tevent_req *req)
77d165f0629966db65753a3aee84a8b4971673afPavel Březina{
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_resolve_srv_dns_state *state = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_resolve_srv_dns_ctx *ctx = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *subreq = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina const char **domains = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina errno_t ret;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state = tevent_req_data(req, struct fo_resolve_srv_dns_state);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ctx = state->ctx;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina domains = talloc_zero_array(state, const char *, 3);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (domains == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = ENOMEM;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (state->discovery_domain == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina /* we will use detected domain with SSSD domain as fallback */
77d165f0629966db65753a3aee84a8b4971673afPavel Březina domains[0] = talloc_strdup(domains, ctx->detected_domain);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (domains[0] == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = ENOMEM;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (strcmp(ctx->detected_domain, ctx->sssd_domain) != 0) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina domains[1] = talloc_strdup(domains, ctx->sssd_domain);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (domains[1] == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = ENOMEM;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina } else {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina /* We will use only discovery domain that was provided via plugin
77d165f0629966db65753a3aee84a8b4971673afPavel Březina * interface. We don't have to dup here because it is already on
77d165f0629966db65753a3aee84a8b4971673afPavel Březina * state. */
77d165f0629966db65753a3aee84a8b4971673afPavel Březina domains[0] = state->discovery_domain;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina subreq = fo_discover_srv_send(state, state->ev, ctx->resolv_ctx,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state->service, state->protocol, domains);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (subreq == NULL) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = ENOMEM;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_set_callback(subreq, fo_resolve_srv_dns_done, req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = EAGAIN;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinadone:
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret != EAGAIN) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina talloc_free(domains);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return ret;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina}
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinastatic void fo_resolve_srv_dns_done(struct tevent_req *subreq)
77d165f0629966db65753a3aee84a8b4971673afPavel Březina{
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_resolve_srv_dns_state *state = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *req = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina errno_t ret;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina req = tevent_req_callback_data(subreq, struct tevent_req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state = tevent_req_data(req, struct fo_resolve_srv_dns_state);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina ret = fo_discover_srv_recv(state, subreq, &state->dns_domain,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina &state->servers, &state->num_servers);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina talloc_zfree(subreq);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret != EOK) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina goto done;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinadone:
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (ret != EOK) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_error(req, ret);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina tevent_req_done(req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina}
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březinaerrno_t fo_resolve_srv_dns_recv(TALLOC_CTX *mem_ctx,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct tevent_req *req,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina char **_dns_domain,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_server_info **_primary_servers,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina size_t *_num_primary_servers,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_server_info **_backup_servers,
77d165f0629966db65753a3aee84a8b4971673afPavel Březina size_t *_num_backup_servers)
77d165f0629966db65753a3aee84a8b4971673afPavel Březina{
77d165f0629966db65753a3aee84a8b4971673afPavel Březina struct fo_resolve_srv_dns_state *state = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina state = tevent_req_data(req, struct fo_resolve_srv_dns_state);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina TEVENT_REQ_RETURN_ON_ERROR(req);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (_primary_servers) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina *_primary_servers = talloc_steal(mem_ctx, state->servers);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (_num_primary_servers) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina *_num_primary_servers = state->num_servers;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina /* backup servers are not supported by simple srv lookup */
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (_backup_servers) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina *_backup_servers = NULL;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (_num_backup_servers) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina *_num_backup_servers = 0;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina if (_dns_domain) {
77d165f0629966db65753a3aee84a8b4971673afPavel Březina *_dns_domain = talloc_steal(mem_ctx, state->dns_domain);
77d165f0629966db65753a3aee84a8b4971673afPavel Březina }
77d165f0629966db65753a3aee84a8b4971673afPavel Březina
77d165f0629966db65753a3aee84a8b4971673afPavel Březina return EOK;
77d165f0629966db65753a3aee84a8b4971673afPavel Březina}