signconf_task.c
Go to the documentation of this file.
/*
* Copyright (c) 2011 Surfnet
* Copyright (c) 2011 .SE (The Internet Infrastructure Foundation).
* Copyright (c) 2011 OpenDNSSEC AB (svb)
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. 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.
*
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``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 AUTHOR 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.
*
*/
#include "signconf/signconf_xml.h"
#include "duration.h"
#include "log.h"
#include "file.h"
#include "signconf/signconf_task.h"
static const char *module_str = "signconf_cmd";
static time_t
perform(task_type* task, char const *zonename, void *userdata, void *context)
{
(void)userdata;
int ret;
char cmd[1024];
db_connection_t* dbconn = (db_connection_t*) context;
ods_log_info("[%s] performing signconf for zone %s", module_str,
zonename);
/* exports all that have "needswriting set */
ret = signconf_export_zone(zonename, dbconn);
if (ret == SIGNCONF_EXPORT_NO_CHANGE) {
ods_log_info("[%s] signconf done, no change", module_str);
return schedule_SUCCESS;
}
if (ret != SIGNCONF_EXPORT_OK) {
ods_log_error("[%s] signconf failed", module_str);
/* YBS reschedule backoff? */
return schedule_SUCCESS;
}
ods_log_info("[%s] signconf done for zone %s, notifying signer",
module_str, zonename);
/* TODO: do this better, connect directly or use execve() */
if (snprintf(cmd, sizeof(cmd), "%s %s", SIGNER_CLI_UPDATE, zonename) >= (int)sizeof(cmd)
|| system(cmd))
{
ods_log_error("[%s] unable to notify signer of signconf changes for zone %s!",
module_str, zonename);
}
return schedule_SUCCESS;
}
void
signconf_task_flush_zone(engine_type *engine, db_connection_t *dbconn,
const char* zonename)
{
task_type* task = task_create(strdup(zonename), TASK_CLASS_ENFORCER,
TASK_TYPE_SIGNCONF, perform, NULL, NULL, time_now());
(void) schedule_task(engine->taskq, task, 1, 0);
}
void
signconf_task_flush_policy(engine_type *engine, db_connection_t *dbconn,
policy_t const *policy)
{
zone_db_t const *zone;
zone_list_db_t *zonelist;
ods_log_assert(policy);
zonelist = zone_list_db_new_get_by_policy_id(dbconn, policy_id(policy));
if (!zonelist) {
ods_log_error("[%s] Can't fetch zones for policy %s from database",
module_str, policy_name(policy));
return;
}
while ((zone = zone_list_db_next(zonelist))) {
signconf_task_flush_zone(engine, dbconn, zone_db_name(zone));
}
zone_list_db_free(zonelist);
}
void
signconf_task_flush_all(engine_type *engine, db_connection_t *dbconn)
{
zone_list_db_t *zonelist;
zone_db_t const *zone;
zonelist = zone_list_db_new(dbconn);
if (!zonelist) {
ods_log_error("[%s] Can't fetch zones from database", module_str);
return;
}
if (zone_list_db_get(zonelist)) { /* fetch all */
ods_log_error("[%s] Can't fetch zones from database", module_str);
zone_list_db_free(zonelist);
return;
}
while ((zone = zone_list_db_next(zonelist))) {
signconf_task_flush_zone(engine, dbconn, zone_db_name(zone));
}
zone_list_db_free(zonelist);
}
policy_name
const char * policy_name(const policy_t *policy)
Definition policy.c:813
policy_id
const db_value_t * policy_id(const policy_t *policy)
Definition policy.c:805
signconf_task_flush_policy
void signconf_task_flush_policy(engine_type *engine, db_connection_t *dbconn, policy_t const *policy)
Definition signconf_task.c:85
signconf_task_flush_zone
void signconf_task_flush_zone(engine_type *engine, db_connection_t *dbconn, const char *zonename)
Definition signconf_task.c:76
signconf_task_flush_all
void signconf_task_flush_all(engine_type *engine, db_connection_t *dbconn)
Definition signconf_task.c:106
signconf_task.h
signconf_export_zone
int signconf_export_zone(char const *zonename, db_connection_t *dbconn)
Definition signconf_xml.c:57
signconf_xml.h
SIGNCONF_EXPORT_NO_CHANGE
#define SIGNCONF_EXPORT_NO_CHANGE
Definition signconf_xml.h:64
SIGNCONF_EXPORT_OK
#define SIGNCONF_EXPORT_OK
Definition signconf_xml.h:40
db_connection
Definition db_connection.h:46
engine_struct
Definition engine.h:47
engine_struct::taskq
schedule_type * taskq
Definition engine.h:60
policy
Definition policy.h:60
zone_db
Definition zone_db.h:46
zone_list_db
Definition zone_db.h:466
zone_db_name
const char * zone_db_name(const zone_db_t *zone)
Definition zone_db.c:782
zone_list_db_new_get_by_policy_id
zone_list_db_t * zone_list_db_new_get_by_policy_id(const db_connection_t *connection, const db_value_t *policy_id)
Definition zone_db.c:2524
zone_list_db_new
zone_list_db_t * zone_list_db_new(const db_connection_t *connection)
Definition zone_db.c:1946
zone_list_db_get
int zone_list_db_get(zone_list_db_t *zone_list)
Definition zone_db.c:2363
zone_list_db_next
const zone_db_t * zone_list_db_next(zone_list_db_t *zone_list)
Definition zone_db.c:2603
zone_list_db_free
void zone_list_db_free(zone_list_db_t *zone_list)
Definition zone_db.c:1989