[Feature] Override DNS requests limits for SPF and DKIM

1 files changed, 12 insertions, 12 deletions

diff --git a/src/libserver/spf.c b/src/libserver/spf.c
index 052e024e0..7f404efb4 100644
--- a/src/libserver/spf.c
+++ b/src/libserver/spf.c
@@ -561,14 +561,14 @@ spf_record_dns_callback (struct rdns_reply *reply, gpointer arg)
 						/* Now resolve A record for this MX */
 						msg_debug_spf ("resolve %s after resolving of MX",
 								elt_data->content.mx.name);
-						if (make_dns_request_task (task,
+						if (make_dns_request_task_forced (task,
 								spf_record_dns_callback, (void *) cb,
 								RDNS_REQUEST_A,
 								elt_data->content.mx.name)) {
 							cb->rec->requests_inflight++;
 						}
 
-						if (make_dns_request_task (task,
+						if (make_dns_request_task_forced (task,
 								spf_record_dns_callback, (void *) cb,
 								RDNS_REQUEST_AAAA,
 								elt_data->content.mx.name)) {
@@ -590,13 +590,13 @@ spf_record_dns_callback (struct rdns_reply *reply, gpointer arg)
 								elt_data->content.ptr.name)) {
 							msg_debug_spf ("resolve %s after resolving of PTR",
 									elt_data->content.ptr.name);
-							if (make_dns_request_task (task,
+							if (make_dns_request_task_forced (task,
 									spf_record_dns_callback, (void *) cb,
 									RDNS_REQUEST_A,
 									elt_data->content.ptr.name)) {
 								cb->rec->requests_inflight++;
 							}
-							if (make_dns_request_task (task,
+							if (make_dns_request_task_forced (task,
 									spf_record_dns_callback, (void *) cb,
 									RDNS_REQUEST_AAAA,
 									elt_data->content.ptr.name)) {
@@ -875,11 +875,11 @@ parse_spf_a (struct spf_record *rec,
 	cb->resolved = resolved;
 	msg_debug_spf ("resolve a %s", host);
 
-	if (make_dns_request_task (task,
+	if (make_dns_request_task_forced (task,
 			spf_record_dns_callback, (void *) cb, RDNS_REQUEST_A, host)) {
 		rec->requests_inflight++;
 
-		if (make_dns_request_task (task,
+		if (make_dns_request_task_forced (task,
 				spf_record_dns_callback, (void *) cb, RDNS_REQUEST_AAAA, host)) {
 			rec->requests_inflight++;
 		}
@@ -921,7 +921,7 @@ parse_spf_ptr (struct spf_record *rec,
 
 	rspamd_mempool_add_destructor (task->task_pool, free, ptr);
 	msg_debug_spf ("resolve ptr %s for %s", ptr, host);
-	if (make_dns_request_task (task,
+	if (make_dns_request_task_forced (task,
 			spf_record_dns_callback, (void *) cb, RDNS_REQUEST_PTR, ptr)) {
 		rec->requests_inflight++;
 
@@ -955,7 +955,7 @@ parse_spf_mx (struct spf_record *rec,
 	cb->resolved = resolved;
 
 	msg_debug_spf ("resolve mx for %s", host);
-	if (make_dns_request_task (task,
+	if (make_dns_request_task_forced (task,
 			spf_record_dns_callback, (void *) cb, RDNS_REQUEST_MX, host)) {
 		rec->requests_inflight++;
 
@@ -1108,7 +1108,7 @@ parse_spf_include (struct spf_record *rec, struct spf_addr *addr)
 	addr->flags |= RSPAMD_SPF_FLAG_REFRENCE;
 	msg_debug_spf ("resolve include %s", domain);
 
-	if (make_dns_request_task (task,
+	if (make_dns_request_task_forced (task,
 			spf_record_dns_callback, (void *) cb, RDNS_REQUEST_TXT, domain)) {
 		rec->requests_inflight++;
 
@@ -1160,7 +1160,7 @@ parse_spf_redirect (struct spf_record *rec,
 	cb->resolved = rspamd_spf_new_addr_list (rec, domain);
 	msg_debug_spf ("resolve redirect %s", domain);
 
-	if (make_dns_request_task (task,
+	if (make_dns_request_task_forced (task,
 			spf_record_dns_callback, (void *) cb, RDNS_REQUEST_TXT, domain)) {
 		rec->requests_inflight++;
 
@@ -1197,7 +1197,7 @@ parse_spf_exists (struct spf_record *rec, struct spf_addr *addr)
 	cb->resolved = resolved;
 
 	msg_debug_spf ("resolve exists %s", host);
-	if (make_dns_request_task (task,
+	if (make_dns_request_task_forced (task,
 			spf_record_dns_callback, (void *) cb, RDNS_REQUEST_A, host)) {
 		rec->requests_inflight++;
 
@@ -1808,7 +1808,7 @@ resolve_spf (struct rspamd_task *task, spf_cb_t callback)
 		return FALSE;
 	}
 
-	if (make_dns_request_task (task,
+	if (make_dns_request_task_forced (task,
 			spf_dns_callback,
 			(void *) rec, RDNS_REQUEST_TXT, rec->sender_domain)) {
 		rec->requests_inflight++;