.consume = notify_consume,
};
-#define NOTIFY_LOG(priority, zone, remote, fmt, ...) \
+#define NOTIFY_OUT_LOG(priority, zone, remote, fmt, ...) \
ns_log(priority, zone, LOG_OPERATION_NOTIFY, LOG_DIRECTION_OUT, remote, \
fmt, ## __VA_ARGS__)
int ret = knot_requestor_exec(&requestor, req, timeout);
if (ret == KNOT_EOK && knot_pkt_ext_rcode(req->resp) == 0) {
- NOTIFY_LOG(LOG_INFO, zone->name, dst,
- "serial %u", knot_soa_serial(soa->rrs.rdata));
+ NOTIFY_OUT_LOG(LOG_INFO, zone->name, dst,
+ "serial %u", knot_soa_serial(soa->rrs.rdata));
} else if (knot_pkt_ext_rcode(req->resp) == 0) {
- NOTIFY_LOG(LOG_WARNING, zone->name, dst,
- "failed (%s)", knot_strerror(ret));
+ NOTIFY_OUT_LOG(LOG_WARNING, zone->name, dst,
+ "failed (%s)", knot_strerror(ret));
} else {
- NOTIFY_LOG(LOG_WARNING, zone->name, dst,
- "server responded with error '%s'",
- knot_pkt_ext_rcode_name(req->resp));
+ NOTIFY_OUT_LOG(LOG_WARNING, zone->name, dst,
+ "server responded with error '%s'",
+ knot_pkt_ext_rcode_name(req->resp));
}
knot_request_free(req, NULL);
return KNOT_STATE_FAIL;
}
- AXFRIN_LOG(LOG_INFO, data->zone->name, data->remote, "starting");
+ AXFRIN_LOG(LOG_INFO, data->zone->name, data->remote, "started");
xfr_stats_begin(&data->stats);
data->change_size = 0;
}
return KNOT_STATE_FAIL;
}
- IXFRIN_LOG(LOG_INFO, data->zone->name, data->remote, "starting");
+ IXFRIN_LOG(LOG_INFO, data->zone->name, data->remote, "started");
xfr_stats_begin(&data->stats);
data->change_size = 0;
}
#include "libdnssec/random.h"
#include "libknot/libknot.h"
-#define NOTIFY_LOG(priority, qdata, fmt...) \
+#define NOTIFY_IN_LOG(priority, qdata, fmt...) \
ns_log(priority, knot_pkt_qname(qdata->query), LOG_OPERATION_NOTIFY, \
LOG_DIRECTION_IN, qdata->params->remote, fmt)
case KNOT_RCODE_NOTAUTH: /* Not authorized, already logged. */
break;
default: /* Other errors. */
- NOTIFY_LOG(LOG_DEBUG, qdata, "invalid query");
+ NOTIFY_IN_LOG(LOG_DEBUG, qdata, "invalid query");
break;
}
return state;
if (soa->type == KNOT_RRTYPE_SOA) {
uint32_t zone_serial, serial = knot_soa_serial(soa->rrs.rdata);
(void)slave_zone_serial(zone, conf(), &zone_serial);
- NOTIFY_LOG(LOG_INFO, qdata, "received, serial %u", serial);
+ NOTIFY_IN_LOG(LOG_INFO, qdata, "serial %u", serial);
if (serial_equal(serial, zone_serial)) {
// NOTIFY serial == zone serial => ignore, keep timers
return KNOT_STATE_DONE;
}
} else { /* Complain, but accept N/A record. */
- NOTIFY_LOG(LOG_NOTICE, qdata, "received, bad record in answer section");
+ NOTIFY_IN_LOG(LOG_NOTICE, qdata, "bad record in answer section");
}
} else {
- NOTIFY_LOG(LOG_INFO, qdata, "received, serial none");
+ NOTIFY_IN_LOG(LOG_INFO, qdata, "serial none");
}
/* Incoming NOTIFY expires REFRESH timer and renews EXPIRE timer. */