RCSID("$Id$")
#define _LIBRADIUS 1
-#include <assert.h>
#include <time.h>
#include <math.h>
#include <freeradius-devel/libradius.h>
# include <collectd/client.h>
#endif
+#define RS_ASSERT(_x) if (!(_x) && !fr_assert(_x)) exit(1)
+
static rs_t *conf;
static struct timeval start_pcap = {0, 0};
static char timestr[50];
inet_ntop(packet->dst_ipaddr.af, &packet->dst_ipaddr.ipaddr, dst, sizeof(dst));
status_str = fr_int2str(rs_events, status, NULL);
- assert(status_str);
+ RS_ASSERT(status_str);
len = snprintf(p, s, "%s,%" PRIu64 ",%s,", status_str, count, timestr);
p += len;
char const *status_str;
status_str = fr_int2str(rs_events, status, NULL);
- assert(status_str);
+ RS_ASSERT(status_str);
len = snprintf(p, s, "** %s ** ", status_str);
p += len;
static int _request_free(rs_request_t *request)
{
+ bool ret;
+
/*
* If were attempting to cleanup the request, and it's no longer in the request_tree
* something has gone very badly wrong.
*/
if (request->in_request_tree) {
- assert(rbtree_deletebydata(request_tree, request));
+ ret = rbtree_deletebydata(request_tree, request);
+ RS_ASSERT(ret);
}
if (request->in_link_tree) {
- assert(rbtree_deletebydata(link_tree, request));
+ ret = rbtree_deletebydata(link_tree, request);
+ RS_ASSERT(ret);
}
if (request->event) {
- assert(fr_event_delete(events, &request->event));
+ ret = fr_event_delete(events, &request->event);
+ RS_ASSERT(ret);
}
rad_free(&request->packet);
RADIUS_PACKET *packet = request->packet;
uint64_t count = request->id;
- assert(request->stats_req);
- assert(!request->rt_rsp || request->stats_rsp);
- assert(packet);
+ RS_ASSERT(request->stats_req);
+ RS_ASSERT(!request->rt_rsp || request->stats_rsp);
+ RS_ASSERT(packet);
/*
* Don't pollute stats or print spurious messages as radsniff closes.
original->expect = talloc_steal(original, search.expect);
if (search.link_vps) {
+ bool ret;
vp_cursor_t cursor;
VALUE_PAIR *vp;
original->link_vps = search.link_vps;
/* We should never have conflicts */
- assert(rbtree_insert(link_tree, original));
+ ret = rbtree_insert(link_tree, original);
+ RS_ASSERT(ret);
original->in_link_tree = true;
}
}
if (!original->in_request_tree) {
+ bool ret;
+
/* We should never have conflicts */
- assert(rbtree_insert(request_tree, original));
+ ret = rbtree_insert(request_tree, original);
+ RS_ASSERT(ret);
original->in_request_tree = true;
}
{
int rcode;
- assert(a->link_vps);
- assert(b->link_vps);
+ RS_ASSERT(a->link_vps);
+ RS_ASSERT(b->link_vps);
rcode = (int) a->expect->code - (int) b->expect->code;
if (rcode != 0) return rcode;
rs_tv_add_ms(&now, RS_SOCKET_REOPEN_DELAY, &when);
if (!fr_event_insert(list, rs_collectd_reopen, list, &when, &event)) {
ERROR("Failed inserting re-open event");
- assert(0);
+ RS_ASSERT(0);
}
}
#endif
talloc_set_log_stderr();
conf = talloc_zero(NULL, rs_t);
- if (!fr_assert(conf)) {
- exit (1);
- }
+ RS_ASSERT(conf);
/*
* We don't really want probes taking down machines
}
}
- assert(out->link_type >= 0);
+ RS_ASSERT(out->link_type >= 0);
if (fr_pcap_open(out) < 0) {
ERROR("Failed opening pcap output (%s): %s", out->name, fr_strerror());