dispatch_test.c revision 15a44745412679c30a6d022733925af70a38b715
/*
* Copyright (C) 1998-2000 Internet Software Consortium.
*
* Permission to use, copy, modify, and distribute this software for any
* purpose with or without fee is hereby granted, provided that the above
* copyright notice and this permission notice appear in all copies.
*
* THE SOFTWARE IS PROVIDED "AS IS" AND INTERNET SOFTWARE CONSORTIUM
* DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE INCLUDING ALL
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL
* INTERNET SOFTWARE CONSORTIUM BE LIABLE FOR ANY SPECIAL, DIRECT,
* INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING
* FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT,
* NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION
* WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
/* $Id: dispatch_test.c,v 1.45 2000/07/27 09:37:52 tale Exp $ */
#include <config.h>
#include <stdlib.h>
#include <unistd.h>
#include <dns/dispatch.h>
#include <dns/rdatalist.h>
#include <dns/rdataset.h>
#define NCLIENTS 16
typedef struct {
unsigned int client_number;
int count;
unsigned char render_buffer[1024];
} clictx_t;
isc_task_t *t0;
unsigned int client_count = 0;
/*
* Forward declarations.
*/
void
static isc_result_t
unsigned char text[8192];
int result;
if (result != ISC_R_SUCCESS)
return (result);
(char *)isc_buffer_base(&textbuf));
return (ISC_R_SUCCESS);
}
static void
hex_dump(isc_buffer_t *b) {
unsigned int len;
isc_region_t r;
isc_buffer_remainingregion(b, &r);
printf("Buffer %p: used region base %p, length %d",
if (len % 16 == 0)
printf("\n");
}
printf("\n");
}
static inline void
if (result != ISC_R_SUCCESS) {
exit(1);
}
}
static void
(void)task;
printf("Send done (SUCCESS)\n");
return;
}
printf("--- removing response (FAILURE)\n");
}
static void
unsigned char namebuf[255];
#ifdef ISC_PLATFORM_HAVESALEN
#endif
&target);
sizeof(cli->render_buffer));
printf("--- adding response\n");
client_count++;
}
void
unsigned int cnt;
(void)task;
printf("App: Got response (id %d). Result: %s\n",
printf("--- ERROR, shutting down response slot\n");
printf("--- shutting down dispatcher\n");
printf("--- removing response\n");
INSIST(client_count > 0);
client_count--;
cnt = client_count;
if (cnt == 0)
return;
}
printf("--- shutting down dispatcher\n");
printf("--- removing response\n");
INSIST(client_count > 0);
client_count--;
cnt = client_count;
if (cnt == 0)
}
static void
unsigned int cnt;
printf("App: Got request. Result: %s\n",
printf("Got error, terminating CLIENT %p resp %p\n",
INSIST(client_count > 0);
client_count--;
cnt = client_count;
if (cnt == 0)
return;
}
printf("App: Client %p(%u) ready, count == %d.\n",
case 4:
printf("--- starting DNS lookup\n");
break;
case 2:
printf("--- removing request\n");
printf("--- adding request\n");
== ISC_R_SUCCESS);
break;
default:
break;
}
}
int
unsigned int i;
unsigned int attrs;
/*
* EVERYTHING needs a memory context.
*/
/*
* The task manager is independent (other than memory context).
*/
dispatchmgr = NULL;
== ISC_R_SUCCESS);
/*
* Get or create a dispatch context.
*/
attrs = 0;
== ISC_R_SUCCESS);
for (i = 0 ; i < NCLIENTS ; i++)
clients[i].client_number = i;
for (i = 0 ; i < 2 ; i++) {
&clients[i],
== ISC_R_SUCCESS);
client_count++;
}
isc_app_run();
sleep(2);
sleep(2);
sleep(2);
sleep(2);
sleep(2);
sleep(2);
return (0);
}