accept "reload" command via OMAPI
This commit is contained in:
David Lawrence
@@ -0,0 +1,202 @@
|
||||
/*
|
||||
* Copyright (C) 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: omapi.c,v 1.1 2000/01/31 15:17:59 tale Exp $ */
|
||||
|
||||
/*
|
||||
* Principal Author: DCL
|
||||
*/
|
||||
|
||||
#include <stdlib.h>
|
||||
#include <stdarg.h>
|
||||
|
||||
#include <isc/assertions.h>
|
||||
#include <isc/util.h>
|
||||
|
||||
#include <named/globals.h>
|
||||
#include <named/log.h>
|
||||
#include <named/omapi.h>
|
||||
#include <named/server.h>
|
||||
|
||||
/*
|
||||
* The control_object structure is used for receiving commands that
|
||||
* request the server to perform some action, but that do not set or
|
||||
* get any state.
|
||||
*/
|
||||
typedef struct control_object {
|
||||
OMAPI_OBJECT_PREAMBLE;
|
||||
} control_object_t;
|
||||
|
||||
static control_object_t control;
|
||||
static omapi_objecttype_t *control_type;
|
||||
|
||||
#undef REGION_FMT
|
||||
/*
|
||||
* Ok, kind of gross. Sorry. A little.
|
||||
*/
|
||||
#define REGION_FMT(r) (int)(r)->length, (r)->base
|
||||
|
||||
/*
|
||||
* This is the function that is called when an incoming OMAPI_OP_OPEN
|
||||
* message is received with either the create or update option set.
|
||||
* It is called once for each name/value pair in the message's object
|
||||
* value list.
|
||||
*/
|
||||
static isc_result_t
|
||||
control_setvalue(omapi_object_t *handle, omapi_string_t *name,
|
||||
omapi_data_t *value)
|
||||
{
|
||||
isc_region_t region;
|
||||
isc_result_t result;
|
||||
|
||||
INSIST(handle == (omapi_object_t *)&control);
|
||||
|
||||
omapi_string_totext(name, ®ion);
|
||||
|
||||
isc_log_write(ns_g_lctx, NS_LOGCATEGORY_GENERAL,
|
||||
NS_LOGMODULE_OMAPI, ISC_LOG_DEBUG(1),
|
||||
"control_setvalue: '%.*s' control command received\n",
|
||||
REGION_FMT(®ion));
|
||||
|
||||
/*
|
||||
* Compare the 'name' parameter against all known control commands.
|
||||
*/
|
||||
if (omapi_string_strcmp(name, NS_OMAPI_COMMAND_RELOAD) == 0) {
|
||||
if (omapi_data_getint(value) != 0)
|
||||
ns_server_reloadwanted(ns_g_server);
|
||||
|
||||
result = ISC_R_SUCCESS;
|
||||
|
||||
} else if (omapi_string_strcmp(name,
|
||||
NS_OMAPI_COMMAND_RELOADCONFIG) == 0 ||
|
||||
omapi_string_strcmp(name,
|
||||
NS_OMAPI_COMMAND_RELOADZONES) == 0) {
|
||||
isc_log_write(ns_g_lctx, NS_LOGCATEGORY_GENERAL,
|
||||
NS_LOGMODULE_OMAPI, ISC_LOG_WARNING,
|
||||
"control_setvalue: '%.*s' not yet implemented\n",
|
||||
REGION_FMT(®ion));
|
||||
result = ISC_R_NOTIMPLEMENTED;
|
||||
|
||||
} else {
|
||||
isc_log_write(ns_g_lctx, NS_LOGCATEGORY_GENERAL,
|
||||
NS_LOGMODULE_OMAPI, ISC_LOG_WARNING,
|
||||
"control_setvalue: unknown name: '%.*s'\n",
|
||||
REGION_FMT(®ion));
|
||||
result = omapi_object_passsetvalue(handle, name, value);
|
||||
}
|
||||
|
||||
return (result);
|
||||
}
|
||||
|
||||
/*
|
||||
* This is the function that is called by the library's internal
|
||||
* message_process function when an incoming OMAPI_OP_OPEN message is received.
|
||||
* It is supposed to look up the object in the server that corresponds to the
|
||||
* key data (name/value pair(s)) in 'key'.
|
||||
*/
|
||||
static isc_result_t
|
||||
control_lookup(omapi_object_t **control_object, omapi_object_t *key) {
|
||||
/*
|
||||
* There is only one control object so no key is needed to look it up.
|
||||
*/
|
||||
UNUSED(key);
|
||||
|
||||
omapi_object_reference(control_object, (omapi_object_t *)&control);
|
||||
|
||||
return (ISC_R_SUCCESS);
|
||||
}
|
||||
|
||||
/*
|
||||
* This function is called when the server is sending a reply to a client
|
||||
* that opened an object of its type. It needs to output all published
|
||||
* name/value pairs for the object, and will typically also put the data
|
||||
* for any inner objects (but in this program, there will be no inner
|
||||
* objects). The handle parameter is an object of the type registered
|
||||
* in ns_omapi_listen.
|
||||
*/
|
||||
static isc_result_t
|
||||
control_stuffvalues(omapi_object_t *connection, omapi_object_t *handle) {
|
||||
/*
|
||||
* Currently the server has no values to publish, but it needs
|
||||
* to publish something for its OMAPI_OP_UPDATE function to work
|
||||
* when received by the client.
|
||||
*/
|
||||
return (omapi_object_passstuffvalues(connection, handle));
|
||||
}
|
||||
|
||||
isc_result_t
|
||||
ns_omapi_listen(isc_mem_t *mctx, omapi_object_t **managerp) {
|
||||
omapi_object_t *manager = NULL;
|
||||
isc_result_t result;
|
||||
|
||||
REQUIRE(managerp != NULL && *managerp == NULL);
|
||||
|
||||
result = omapi_lib_init(mctx);
|
||||
if (result != ISC_R_SUCCESS)
|
||||
goto free_omapi;
|
||||
|
||||
/*
|
||||
* Register the control_object. NS_OMAPI_CONTROL is what a client
|
||||
* would need to specify as a value for the value of "type" in
|
||||
* a message when contacting the server to perform a control function.
|
||||
*/
|
||||
result = omapi_object_register(&control_type, NS_OMAPI_CONTROL,
|
||||
control_setvalue,
|
||||
NULL, /* getvalue */
|
||||
NULL, /* destroy */
|
||||
NULL, /* signalhandler */
|
||||
control_stuffvalues,
|
||||
control_lookup,
|
||||
NULL, /* create */
|
||||
NULL); /* remove */
|
||||
if (result != ISC_R_SUCCESS)
|
||||
goto free_manager;
|
||||
|
||||
/*
|
||||
* Initialize the static control object.
|
||||
*/
|
||||
control.refcnt = 1;
|
||||
control.type = control_type;
|
||||
|
||||
/*
|
||||
* Create a generic object to be the manager for handling
|
||||
* incoming server connections.
|
||||
*/
|
||||
result = omapi_object_create(&manager, NULL, 0);
|
||||
if (result != ISC_R_SUCCESS)
|
||||
goto free_manager;
|
||||
|
||||
/*
|
||||
* Start listening for connections. The second parameter is the
|
||||
* port to listen on; 0 means the default OMAPI port.
|
||||
*/
|
||||
result = omapi_protocol_listen(manager, 0, 1);
|
||||
if (result != ISC_R_SUCCESS)
|
||||
goto free_manager;
|
||||
|
||||
*managerp = manager;
|
||||
|
||||
return (ISC_R_SUCCESS);
|
||||
|
||||
free_manager:
|
||||
omapi_object_dereference(&manager);
|
||||
|
||||
free_omapi:
|
||||
omapi_lib_destroy();
|
||||
|
||||
return (result);
|
||||
}
|
||||
Reference in New Issue
Block a user