aboutsummaryrefslogtreecommitdiffstats
path: root/src/libutil
diff options
context:
space:
mode:
authorVsevolod Stakhov <vsevolod@highsecure.ru>2014-10-31 12:14:32 +0000
committerVsevolod Stakhov <vsevolod@highsecure.ru>2014-10-31 12:14:32 +0000
commit0ed9dcd1e64f921eb6682cfdb9948384d8bdb8bb (patch)
treefe20cf1dd651aa38027c03bd66a94fe0674a83e6 /src/libutil
parentfcc328517c4440e13b086691ff57874db5816885 (diff)
downloadrspamd-0ed9dcd1e64f921eb6682cfdb9948384d8bdb8bb.tar.gz
rspamd-0ed9dcd1e64f921eb6682cfdb9948384d8bdb8bb.zip
Fix some issues in the upstream code.
Diffstat (limited to 'src/libutil')
-rw-r--r--src/libutil/upstream.c23
1 files changed, 14 insertions, 9 deletions
diff --git a/src/libutil/upstream.c b/src/libutil/upstream.c
index 595b6cd0b..070ff3858 100644
--- a/src/libutil/upstream.c
+++ b/src/libutil/upstream.c
@@ -197,11 +197,11 @@ rspamd_upstream_set_inactive (struct upstream_list *ls, struct upstream *up)
REF_RETAIN (up);
rdns_make_request_full (res, rspamd_upstream_dns_cb, up,
default_dns_timeout, default_dns_retransmits,
- RDNS_REQUEST_A, up->name);
+ 1, up->name, RDNS_REQUEST_A);
REF_RETAIN (up);
rdns_make_request_full (res, rspamd_upstream_dns_cb, up,
default_dns_timeout, default_dns_retransmits,
- RDNS_REQUEST_AAAA, up->name);
+ 1, up->name, RDNS_REQUEST_AAAA);
}
}
@@ -229,7 +229,7 @@ void
rspamd_upstream_fail (struct upstream *up)
{
struct timeval tv;
- gdouble error_rate, max_error_rate;
+ gdouble error_rate, max_error_rate, msec_last, msec_cur;
rspamd_mutex_lock (up->lock);
if (g_atomic_int_compare_and_exchange (&up->errors, 0, 1)) {
@@ -242,12 +242,16 @@ rspamd_upstream_fail (struct upstream *up)
gettimeofday (&tv, NULL);
- error_rate = ((gdouble)up->errors) / (tv.tv_sec - up->tv.tv_sec);
- max_error_rate = (gdouble)default_max_errors / (gdouble)default_error_time;
+ msec_last = tv_to_msec (&up->tv) / 1000.;
+ msec_cur = tv_to_msec (&tv) / 1000.;
+ if (msec_cur > msec_last) {
+ error_rate = ((gdouble)up->errors) / (msec_cur - msec_last);
+ max_error_rate = (gdouble)default_max_errors / (gdouble)default_error_time;
- if (error_rate > max_error_rate) {
- /* Remove upstream from the active list */
- rspamd_upstream_set_inactive (up->ls, up);
+ if (error_rate > max_error_rate) {
+ /* Remove upstream from the active list */
+ rspamd_upstream_set_inactive (up->ls, up);
+ }
}
rspamd_mutex_unlock (up->lock);
}
@@ -331,6 +335,7 @@ rspamd_upstreams_add_upstream (struct upstream_list *ups,
g_ptr_array_add (ups->ups, up);
up->ud = data;
up->cur_weight = up->weight;
+ up->ls = ups;
REF_INIT_RETAIN (up, rspamd_upstream_dtor);
up->lock = rspamd_mutex_new ();
@@ -424,7 +429,7 @@ rspamd_upstream_restore_cb (gpointer elt, gpointer ls)
g_ptr_array_add (ups->alive, up);
up->active_idx = ups->alive->len - 1;
- rspamd_mutex_lock (up->lock);
+ rspamd_mutex_unlock (up->lock);
/* For revive event */
REF_RELEASE (up);
}