clones/unbound
1
0
Fork 0
mirror of https://github.com/NLnetLabs/unbound.git synced 2024-09-21 14:47:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

test program for bg lookups.

Browse Source 
git-svn-id: file:///svn/unbound/trunk@887 be551aaa-1e26-0410-a405-d3ace91eadb9
This commit is contained in:
Wouter Wijngaards 2008-01-22 16:28:41 +00:00
parent 3adebc8721
commit a18af6d1e1
4 changed files with 179 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
Makefile.in
View File

@ -90,12 +90,15 @@ SIGNIT_SRC=testcode/signit.c smallapp/worker_cb.c $(COMMON_SRC)
SIGNIT_OBJ=$(addprefix $(BUILD),$(SIGNIT_SRC:.c=.o)) $(COMPAT_OBJ)
MEMSTATS_SRC=testcode/memstats.c smallapp/worker_cb.c $(COMMON_SRC)
MEMSTATS_OBJ=$(addprefix $(BUILD),$(MEMSTATS_SRC:.c=.o)) $(COMPAT_OBJ)
ASYNCLOOK_SRC=testcode/asynclook.c
ASYNCLOOK_OBJ=$(addprefix $(BUILD),$(ASYNCLOOK_SRC:.c=.o)) $(COMPAT_OBJ)
LIBUNBOUND_SRC=$(patsubst $(srcdir)/%,%, \
$(wildcard $(srcdir)/libunbound/*.c) $(COMMON_SRC))
LIBUNBOUND_OBJ=$(addprefix $(BUILD),$(LIBUNBOUND_SRC:.c=.o)) $(COMPAT_OBJ)
ALL_SRC=$(COMMON_SRC) $(UNITTEST_SRC) $(DAEMON_SRC) \
$(TESTBOUND_SRC) $(LOCKVERIFY_SRC) $(PKTVIEW_SRC) $(SIGNIT_SRC) \
$(MEMSTATS_SRC) $(CHECKCONF_SRC) $(LIBUNBOUND_SRC) $(HOST_SRC)
$(MEMSTATS_SRC) $(CHECKCONF_SRC) $(LIBUNBOUND_SRC) $(HOST_SRC) \
$(ASYNCLOOK_SRC)
ALL_OBJ=$(addprefix $(BUILD),$(ALL_SRC:.c=.o) \
$(addprefix compat/,$(LIBOBJS))) $(COMPAT_OBJ)
@ -114,7 +117,7 @@ $(BUILD)%.o: $(srcdir)/%.c
all: $(COMMON_OBJ) unbound unbound-checkconf lib unbound-host
tests: all unittest testbound lock-verify pktview signit memstats
tests: all unittest testbound lock-verify pktview signit memstats asynclook
test: tests
bash testcode/do-tests.sh
@ -170,6 +173,10 @@ memstats: $(MEMSTATS_OBJ) $(ldnslib)
$(INFO) Link $@
$Q$(LINK) -o $@ $(sort $(MEMSTATS_OBJ)) $(LIBS)
asynclook: $(ASYNCLOOK_OBJ) $(ldnslib) libunbound.la
$(INFO) Link $@
$Q$(LINK) -o $@ $(sort $(ASYNCLOOK_OBJ)) $(LIBS) -L. -L.libs -lunbound
#testcode/ldns-testpkts.c: $(ldnsdir)/examples/ldns-testpkts.c \
# $(ldnsdir)/examples/ldns-testpkts.h
# cp $(ldnsdir)/examples/ldns-testpkts.c testcode/ldns-testpkts.c

2
doc/Changelog
View File

@ -3,6 +3,8 @@
- fix link testbound.
- fixup exit bug in mini_event.
- background worker query enter and result functions.
- bg query test application asynclook, it looks up multiple
hostaddresses (A records) at the same time.
21 January 2008: Wouter
- libworker work, netevent raw commpoints, write_msg, serialize.

5
libunbound/worker.c
View File

@ -190,6 +190,7 @@ libworker_handle_control_cmd(struct comm_point* c, void* arg,
if(r==-1) /* nothing to read now, try later */
return 0;
log_info("bg got cmd %d", (int)context_serial_getcmd(buf, len));
switch(context_serial_getcmd(buf, len)) {
default:
case UB_LIBCMD_ANSWER:
@ -221,6 +222,8 @@ libworker_handle_result_write(struct comm_point* c, void* arg,
comm_point_stop_listening(c);
return 0;
}
log_info("bg write msg %d", (int)context_serial_getcmd(
item->buf, item->len));
r = libworker_write_msg(c->fd, item->buf, item->len, 1);
if(r == -1)
return 0; /* try again later */
@ -250,6 +253,8 @@ libworker_dobg(void* arg)
struct ub_val_ctx* ctx = (struct ub_val_ctx*)arg;
struct libworker* w = libworker_setup(ctx);
log_thread_set(&w->thread_num);
log_info("start bg"); /* @@@ DEBUG */
/*verbosity=3; @@@ DEBUG */
if(!w) {
log_err("libunbound bg worker init failed, nomem");
return NULL;

163
testcode/asynclook.c Normal file
View File

@ -0,0 +1,163 @@
/*
* testcode/asynclook.c - debug program perform async libunbound queries.
*
* Copyright (c) 2008, NLnet Labs. All rights reserved.
*
* This software is open source.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
*
* Redistributions in binary form must reproduce the above copyright notice,
* this list of conditions and the following disclaimer in the documentation
* and/or other materials provided with the distribution.
*
* Neither the name of the NLNET LABS nor the names of its contributors may
* be used to endorse or promote products derived from this software without
* specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
* TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
* PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*/
/**
* \file
*
* This program shows the results from several background lookups,
* while printing time in the foreground.
*/
#include "config.h"
#include "libunbound/unbound.h"
/**
* result list for the lookups
*/
struct lookinfo {
/** name to look up */
char* qname;
/** tracking number that can be used to cancel the query */
int async_id;
/** error code from libunbound */
int err;
/** result from lookup */
struct ub_val_result* result;
};
/** global variable to see how many queries we have left */
static int num_wait = 0;
/** usage information for asynclook */
void usage(char* argv[])
{
printf("usage: %s name ...\n", argv[0]);
printf("names are looked up at the same time, asynchronously.\n");
exit(1);
}
/** this is a function of type ub_val_callback_t */
void lookup_is_done(void* mydata, int err, struct ub_val_result* result)
{
/* cast mydata back to the correct type */
struct lookinfo* info = (struct lookinfo*)mydata;
fprintf(stderr, "name %s resolved\n", info->qname);
info->err = err;
info->result = result;
/* one less to wait for */
num_wait--;
}
/** main program for asynclook */
int main(int argc, char** argv)
{
struct ub_val_ctx* ctx;
struct lookinfo* lookups;
int i, r;
if(argc == 1) {
usage(argv);
}
argc--;
argv++;
/* allocate array for results. */
lookups = (struct lookinfo*)calloc((size_t)argc,
sizeof(struct lookinfo));
if(!lookups) {
printf("out of memory\n");
return 1;
}
/* create context */
ctx = ub_val_ctx_create();
if(!ctx) {
printf("could not create context, %s", strerror(errno));
return 1;
}
/* perform asyncronous calls */
num_wait = argc;
for(i=0; i<argc; i++) {
if(strcmp(argv[i], "-d") == 0) {
ub_val_ctx_debuglevel(ctx, 3);
continue;
}
fprintf(stderr, "start lookup %s\n", argv[i]);
lookups[i].qname = argv[i];
r = ub_val_resolve_async(ctx, argv[i], LDNS_RR_TYPE_A,
LDNS_RR_CLASS_IN, &lookups[i], &lookup_is_done,
&lookups[i].async_id);
}
/* wait while the hostnames are looked up. Do something useful here */
for(i=0; i<1000; i++) {
usleep(100000);
printf("%g seconds passed\n", 0.1*(double)i);
r = ub_val_ctx_process(ctx);
if(r != 0) {
printf("ub_val_ctx_process error: %s\n",
ub_val_strerror(r));
return 1;
}
if(num_wait == 0)
break;
}
if(i>=999) {
printf("timed out\n");
return 0;
}
printf("lookup complete\n");
/* print lookup results */
for(i=0; i<argc; i++) {
char buf[100];
if(lookups[i].err)
printf("%s: error %s\n", lookups[i].qname,
ub_val_strerror(lookups[i].err));
else if(lookups[i].result->rcode != 0)
printf("%s: DNS error %d\n", lookups[i].qname,
lookups[i].result->rcode);
else if(!lookups[i].result->havedata)
printf("%s: no data %s\n", lookups[i].qname,
lookups[i].result->nxdomain?"(no such host)":
"(no IP4 address)");
else printf("%s: %s\n", lookups[i].qname,
inet_ntop(AF_INET, lookups[i].result->data[0],
buf, (socklen_t)sizeof(buf)));
}
ub_val_ctx_delete(ctx);
free(lookups);
return 0;
}