From de154f65f63a9762078eb7f990e270b9f1476282 Mon Sep 17 00:00:00 2001 From: Mark Andrews Date: Thu, 28 Dec 2000 01:29:09 +0000 Subject: [PATCH] Ensure that ns_client_*() are only called from the client's task. --- bin/named/update.c | 52 ++++++++++++++++++++++++++++---------- lib/dns/include/dns/zone.h | 7 ++--- lib/dns/zone.c | 4 +-- 3 files changed, 45 insertions(+), 18 deletions(-) diff --git a/bin/named/update.c b/bin/named/update.c index 0510ded98a..12fa6a9819 100644 --- a/bin/named/update.c +++ b/bin/named/update.c @@ -15,7 +15,7 @@ * WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. */ -/* $Id: update.c,v 1.78 2000/12/16 00:58:01 gson Exp $ */ +/* $Id: update.c,v 1.79 2000/12/28 01:29:09 marka Exp $ */ #include @@ -147,7 +147,7 @@ struct update_event { ISC_EVENT_COMMON(update_event_t); dns_zone_t *zone; isc_result_t result; - + dns_message_t *answer; }; /**************************************************************************/ @@ -158,6 +158,7 @@ struct update_event { static void update_action(isc_task_t *task, isc_event_t *event); static void updatedone_action(isc_task_t *task, isc_event_t *event); static isc_result_t send_forward_event(ns_client_t *client, dns_zone_t *zone); +static void forward_done(isc_task_t *task, isc_event_t *event); /**************************************************************************/ /* @@ -2472,19 +2473,44 @@ updatedone_action(isc_task_t *task, isc_event_t *event) { */ static void -forward_fail(ns_client_t *client, isc_result_t result) { - UNUSED(result); +forward_fail(isc_task_t *task, isc_event_t *event) { + ns_client_t *client = (ns_client_t *)event->ev_arg; + + UNUSED(task); + respond(client, DNS_R_SERVFAIL); + ns_client_detach(&client); + isc_event_free((isc_event_t **)&event); } + static void forward_callback(void *arg, isc_result_t result, dns_message_t *answer) { - ns_client_t *client = arg; + update_event_t *uev = arg; + ns_client_t *client = uev->ev_arg; - if (result != ISC_R_SUCCESS) - forward_fail(client, result); - else - ns_client_sendraw(client, answer); + if (result != ISC_R_SUCCESS) { + INSIST(answer == NULL); + uev->ev_type = DNS_EVENT_UPDATEDONE; + uev->ev_action = forward_fail; + } else { + uev->ev_type = DNS_EVENT_UPDATEDONE; + uev->ev_action = forward_done; + uev->answer = answer; + } + isc_task_send(client->task, (isc_event_t**)&uev); +} + +static void +forward_done(isc_task_t *task, isc_event_t *event) { + update_event_t *uev = (update_event_t *) event; + ns_client_t *client = (ns_client_t *)event->ev_arg; + + UNUSED(task); + + ns_client_sendraw(client, uev->answer); + dns_message_destroy(&uev->answer); + isc_event_free((isc_event_t **)&event); ns_client_detach(&client); } @@ -2496,13 +2522,13 @@ forward_action(isc_task_t *task, isc_event_t *event) { isc_result_t result; result = dns_zone_forwardupdate(zone, client->message, - forward_callback, client); + forward_callback, event); if (result != ISC_R_SUCCESS) { - forward_fail(client, result); - ns_client_detach(&client); + uev->ev_type = DNS_EVENT_UPDATEDONE; + uev->ev_action = forward_fail; + isc_task_send(client->task, &event); } dns_zone_detach(&zone); - isc_event_free(&event); isc_task_detach(&task); } diff --git a/lib/dns/include/dns/zone.h b/lib/dns/include/dns/zone.h index 00cd967c39..7baf03124f 100644 --- a/lib/dns/include/dns/zone.h +++ b/lib/dns/include/dns/zone.h @@ -15,7 +15,7 @@ * WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. */ -/* $Id: zone.h,v 1.94 2000/12/13 00:15:39 tale Exp $ */ +/* $Id: zone.h,v 1.95 2000/12/28 01:29:08 marka Exp $ */ #ifndef DNS_ZONE_H #define DNS_ZONE_H 1 @@ -1047,8 +1047,9 @@ dns_zone_forwardupdate(dns_zone_t *zone, dns_message_t *msg, * Forward 'msg' to each master in turn until we get an answer or we * have exausted the list of masters. 'callback' will be called with * ISC_R_SUCCESS if we get an answer and the returned message will be - * passed, otherwise a non ISC_R_SUCCESS result code will be passed and - * msg will be NULL. + * passed as 'answer_message', otherwise a non ISC_R_SUCCESS result code + * will be passed and answer_message will be NULL. The callback function + * is responsible for destroying 'answer_message'. * (callback)(callback_arg, result, answer_message); * * Require: diff --git a/lib/dns/zone.c b/lib/dns/zone.c index 59a4c8337e..cfab686eff 100644 --- a/lib/dns/zone.c +++ b/lib/dns/zone.c @@ -15,7 +15,7 @@ * WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. */ -/* $Id: zone.c,v 1.282 2000/12/22 05:55:20 marka Exp $ */ +/* $Id: zone.c,v 1.283 2000/12/28 01:29:06 marka Exp $ */ #include @@ -5014,7 +5014,7 @@ forward_callback(isc_task_t *task, isc_event_t *event) { /* call callback */ (forward->callback)(forward->callback_arg, ISC_R_SUCCESS, msg); - dns_message_destroy(&msg); + msg = NULL; dns_request_destroy(&forward->request); forward_destroy(forward); isc_event_free(&event);