X-Git-Url: https://git.exim.org/exim.git/blobdiff_plain/ac0dcd3f05a8821d7ce042646472be1995a08042..1ccd5f670a432f98e94b384dd169a1a760dced9a:/src/src/ip.c diff --git a/src/src/ip.c b/src/src/ip.c index 258ab5c23..eb01229e6 100644 --- a/src/src/ip.c +++ b/src/src/ip.c @@ -236,22 +236,26 @@ if (fastopen) { if ((rc = sendto(sock, fastopen->data, fastopen->len, MSG_FASTOPEN | MSG_DONTWAIT, s_ptr, s_len)) >= 0) + /* seen for with-data, experimental TFO option, with-cookie case */ { - DEBUG(D_transport|D_v) - debug_printf("TCP_FASTOPEN mode connection, with data\n"); - tcp_out_fastopen = TRUE; + DEBUG(D_transport|D_v) debug_printf("TFO mode connection attempt, %s data\n", + fastopen->len > 0 ? "with" : "no"); + tcp_out_fastopen = fastopen->len > 0 ? 2 : 1; } else if (errno == EINPROGRESS) /* expected for nonready peer */ - { + /* seen for no-data, proper TFO option, both cookie-request and with-cookie cases */ + /* apparently no visibility of the diffference at this point */ + /* with netwk delay, post-conn tcp_info sees unacked 1 for R, 2 for C; code in smtp_out.c */ + /* ? older Experimental TFO option behaviour ? */ + { /* queue unsent data */ if (!fastopen->data) { - DEBUG(D_transport|D_v) - debug_printf("TCP_FASTOPEN mode connection, no data\n"); - tcp_out_fastopen = TRUE; + tcp_out_fastopen = 1; /* we tried; unknown if useful yet */ rc = 0; } else if ( (rc = send(sock, fastopen->data, fastopen->len, 0)) < 0 - && errno == EINPROGRESS) /* expected for nonready peer */ + && errno == EINPROGRESS /* expected for nonready peer */ + ) rc = 0; } else if(errno == EOPNOTSUPP) @@ -312,23 +316,22 @@ Arguments: address the remote address, in text form portlo,porthi the remote port range timeout a timeout - connhost if not NULL, host_item filled in with connection details + connhost if not NULL, host_item to be filled in with connection details errstr pointer for allocated string on error -XXX could add early-data support + fastopen with SOCK_STREAM, if non-null, request TCP Fast Open. + Additionally, optional early-data to send Return: socket fd, or -1 on failure (having allocated an error string) */ int ip_connectedsocket(int type, const uschar * hostname, int portlo, int porthi, - int timeout, host_item * connhost, uschar ** errstr) + int timeout, host_item * connhost, uschar ** errstr, const blob * fastopen) { int namelen, port; host_item shost; host_item *h; int af = 0, fd, fd4 = -1, fd6 = -1; -blob * fastopen = tcp_fastopen_ok && type == SOCK_STREAM - ? &tcp_fastopen_nodata : NULL; shost.next = NULL; shost.address = NULL; @@ -406,6 +409,7 @@ bad: } +/*XXX TFO? */ int ip_tcpsocket(const uschar * hostport, uschar ** errstr, int tmo) { @@ -426,7 +430,7 @@ if (scan != 3) } return ip_connectedsocket(SOCK_STREAM, hostname, portlow, porthigh, - tmo, NULL, errstr); + tmo, NULL, errstr, NULL); } int