1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
/*
* Copyright (C) 2011-2012 Reto Guadagnini
* Hochschule fuer Technik Rapperswil
*
* 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 2 of the License, or (at your
* option) any later version. See <http://www.fsf.org/copyleft/gpl.txt>.
*
* 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.
*/
#include <unbound.h>
#include <errno.h>
#include <ldns/ldns.h>
#include <string.h>
#include <library.h>
#include <utils/debug.h>
#include "unbound_resolver.h"
#include "unbound_response.h"
typedef struct private_resolver_t private_resolver_t;
/**
* private data of a unbound_resolver_t object.
*/
struct private_resolver_t {
/**
* Public data
*/
resolver_t public;
/**
* private unbound resolver handle (unbound context)
*/
struct ub_ctx *ctx;
};
/**
* query method implementation
*/
METHOD(resolver_t, query, resolver_response_t*,
private_resolver_t *this, char *domain, rr_class_t rr_class,
rr_type_t rr_type)
{
unbound_response_t *response = NULL;
struct ub_result *result = NULL;
int ub_retval;
ub_retval = ub_resolve(this->ctx, domain, rr_type, rr_class, &result);
if (ub_retval)
{
DBG1(DBG_LIB, "unbound resolver error: %s", ub_strerror(ub_retval));
ub_resolve_free(result);
return NULL;
}
response = unbound_response_create_frm_libub_response(result);
if (!response)
{
DBG1(DBG_LIB, "unbound_resolver: Could not create response.");
ub_resolve_free(result);
return NULL;
}
ub_resolve_free(result);
return (resolver_response_t*)response;
}
/**
* destroy method implementation
*/
METHOD(resolver_t, destroy, void,
private_resolver_t *this)
{
ub_ctx_delete(this->ctx);
free(this);
}
/*
* Described in header.
*/
resolver_t *unbound_resolver_create(char *resolv_conf, char *ta_file)
{
private_resolver_t *this;
int ub_retval = 0;
INIT(this,
.public = {
.query = _query,
.destroy = _destroy,
},
);
DBG1(DBG_LIB, "creating an unbound_resolver instance");
this->ctx = ub_ctx_create();
if (!this->ctx)
{
DBG1(DBG_LIB, "failed to create an unbound resolver context");
_destroy(this);
return NULL;
}
ub_retval = ub_ctx_resolvconf(this->ctx, resolv_conf);
if (ub_retval)
{
DBG1(DBG_LIB, "failed to read the resolver configuration file. "
"Unbound error: %s. errno says: %s", ub_strerror(ub_retval),
strerror(errno));
_destroy(this);
return NULL;
}
ub_retval = ub_ctx_add_ta_file(this->ctx, ta_file);
if (ub_retval)
{
DBG1(DBG_LIB, "failed to load trusted anchors from file %s. "
"Unbound error: %s. errno says: %s",
ta_file, ub_strerror(ub_retval), strerror(errno));
}
DBG1(DBG_LIB, "unbound resolver instance created");
return &this->public;
}
|
