X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Fsrc%2Ftransports%2Fsmtp_socks.c;h=c410eceec8f972317c49c59d818eb3c60ad37534;hb=6b69b71028f15c7ba3157bac955103b764326f60;hp=09273c747485c72c57e33ebf8f7f723cd89c6bd2;hpb=db3f7b6972f3b003c0413b78afcfbe295ffe0b97;p=user%2Fhenk%2Fcode%2Fexim.git diff --git a/src/src/transports/smtp_socks.c b/src/src/transports/smtp_socks.c index 09273c747..c410eceec 100644 --- a/src/src/transports/smtp_socks.c +++ b/src/src/transports/smtp_socks.c @@ -128,7 +128,7 @@ switch(method) #ifdef TCP_QUICKACK (void) setsockopt(fd, IPPROTO_TCP, TCP_QUICKACK, US &off, sizeof(off)); #endif - if (!fd_ready(fd, tmo-time(NULL)) || read(fd, s, 2) != 2) + if (!fd_ready(fd, tmo) || read(fd, s, 2) != 2) return FAIL; HDEBUG(D_transport|D_acl|D_v) debug_printf_indent(" SOCKS<< %02x %02x\n", s[0], s[1]); @@ -160,20 +160,10 @@ socks_opts * sd; socks_opts * lim = &proxies[nproxies]; long rnd, weights; unsigned pri; -static BOOL srandomed = FALSE; if (nproxies == 1) /* shortcut, if we have only 1 server */ return (proxies[0].is_failed ? -1 : 0); -/* init random */ -if (!srandomed) - { - struct timeval tv; - gettimeofday(&tv, NULL); - srandom((unsigned int)(tv.tv_usec/1000)); - srandomed = TRUE; - } - /* scan for highest pri */ for (pri = 0, sd = proxies; sd < lim; sd++) if (!sd->is_failed && sd->priority > pri) @@ -186,11 +176,11 @@ for (weights = 0, sd = proxies; sd < lim; sd++) if (weights == 0) /* all servers failed */ return -1; -for (rnd = random() % weights, i = 0; i < nproxies; i++) +for (rnd = random_number(weights), i = 0; i < nproxies; i++) { sd = &proxies[i]; if (!sd->is_failed && sd->priority == pri) - if ((rnd -= sd->weight) <= 0) + if ((rnd -= sd->weight) < 0) return i; } @@ -230,7 +220,7 @@ const uschar * state; uschar buf[24]; socks_opts proxies[32]; /* max #proxies handled */ unsigned nproxies; -socks_opts * sob; +socks_opts * sob = NULL; unsigned size; blob early_data; @@ -267,6 +257,7 @@ for (nproxies = 0; while ((option = string_nextinlist(&proxy_spec, &subsep, NULL, 0))) socks_option(sob, option); } +if (!sob) return -1; /* Set up the socks protocol method-selection message, for sending on connection */ @@ -319,7 +310,7 @@ HDEBUG(D_transport|D_acl|D_v) debug_printf_indent(" SOCKS>> 05 01 %02x\n", sob- (void) setsockopt(fd, IPPROTO_TCP, TCP_QUICKACK, US &off, sizeof(off)); #endif -if ( !fd_ready(fd, tmo-time(NULL)) +if ( !fd_ready(fd, tmo) || read(fd, buf, 2) != 2 ) goto rcv_err; @@ -368,7 +359,7 @@ if (send(fd, buf, size, 0) < 0) /* expect conn-reply (success, local(ipver, addr, port)) of same length as conn-request, or non-success fail code */ -if ( !fd_ready(fd, tmo-time(NULL)) +if ( !fd_ready(fd, tmo) || (size = read(fd, buf, size)) < 2 ) goto rcv_err;