diff options
| author | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2009-08-25 15:13:24 +0400 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@rambler-co.ru> | 2009-08-25 15:13:24 +0400 |
| commit | ab8f97db48ceefef5fdf47ea8a5954da635ffa31 (patch) | |
| tree | 41fcd689903bbc215f168d0db7ff3ca697197da4 /src/plugins | |
| parent | 034d3a91d5c60328bd99fc279f2a0ffa89d258d1 (diff) | |
| download | rspamd-ab8f97db48ceefef5fdf47ea8a5954da635ffa31.tar.gz rspamd-ab8f97db48ceefef5fdf47ea8a5954da635ffa31.zip | |
* Migrate fuzzy storage to use UDP instead of TCP
Diffstat (limited to 'src/plugins')
| -rw-r--r-- | src/plugins/fuzzy_check.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/plugins/fuzzy_check.c b/src/plugins/fuzzy_check.c index da3e651a8..cd3641654 100644 --- a/src/plugins/fuzzy_check.c +++ b/src/plugins/fuzzy_check.c @@ -339,7 +339,7 @@ fuzzy_symbol_callback (struct worker_task *task, void *unused) DEFAULT_UPSTREAM_MAXERRORS, part->fuzzy->hash_pipe, sizeof (part->fuzzy->hash_pipe)); if (selected) { - if ((sock = make_tcp_socket (&selected->addr, selected->port, FALSE, TRUE)) == -1) { + if ((sock = make_udp_socket (&selected->addr, selected->port, FALSE, TRUE)) == -1) { msg_warn ("fuzzy_symbol_callback: cannot connect to %s, %d, %s", selected->name, errno, strerror (errno)); } else { @@ -404,7 +404,7 @@ fuzzy_process_handler (struct controller_session *session, f_str_t *in) DEFAULT_UPSTREAM_MAXERRORS, part->fuzzy->hash_pipe, sizeof (part->fuzzy->hash_pipe)); if (selected) { - if ((sock = make_tcp_socket (&selected->addr, selected->port, FALSE, TRUE)) == -1) { + if ((sock = make_udp_socket (&selected->addr, selected->port, FALSE, TRUE)) == -1) { msg_warn ("fuzzy_symbol_callback: cannot connect to %s, %d, %s", selected->name, errno, strerror (errno)); r = snprintf (out_buf, sizeof (out_buf), "no hashes written" CRLF); rspamd_dispatcher_write (session->dispatcher, out_buf, r, FALSE, FALSE); |