This is an automated email from the ASF dual-hosted git repository.
oknet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/trafficserver.git
The following commit(s) were added to refs/heads/master by this push:
new 800f69e fix 100-continue
800f69e is described below
commit 800f69e71d144d9ef0870b7c6d7286eb2991bb7d
Author: scw00 <[email protected]>
AuthorDate: Wed May 17 09:03:32 2017 +0800
fix 100-continue
---
proxy/hdrs/HTTP.h | 11 ++++++-----
proxy/http/HttpSM.cc | 25 ++++++++++++++++++++++---
2 files changed, 28 insertions(+), 8 deletions(-)
diff --git a/proxy/hdrs/HTTP.h b/proxy/hdrs/HTTP.h
index b4eb236..bfa48ab 100644
--- a/proxy/hdrs/HTTP.h
+++ b/proxy/hdrs/HTTP.h
@@ -486,11 +486,12 @@ public:
HTTPHdrImpl *m_http = nullptr;
// This is all cached data and so is mutable.
mutable URL m_url_cached;
- mutable MIMEField *m_host_mime = nullptr;
- mutable int m_host_length = 0; ///< Length of hostname.
- mutable int m_port = 0; ///< Target port.
- mutable bool m_target_cached = false; ///< Whether host name and port are
cached.
- mutable bool m_target_in_url = false; ///< Whether host name and port are
in the URL.
+ mutable MIMEField *m_host_mime = nullptr;
+ mutable int m_host_length = 0; ///< Length of hostname.
+ mutable int m_port = 0; ///< Target port.
+ mutable bool m_target_cached = false; ///< Whether host name and
port are cached.
+ mutable bool m_target_in_url = false; ///< Whether host name and
port are in the URL.
+ mutable bool m_100_continue_required = false; ///< Whether 100_continue is
in the Expect header.
/// Set if the port was effectively specified in the header.
/// @c true if the target (in the URL or the HOST field) also specified
/// a port. That is, @c true if whatever source had the target host
diff --git a/proxy/http/HttpSM.cc b/proxy/http/HttpSM.cc
index c3b57ad..9f62c57 100644
--- a/proxy/http/HttpSM.cc
+++ b/proxy/http/HttpSM.cc
@@ -715,9 +715,11 @@ HttpSM::state_read_client_request_header(int event, void
*data)
ua_entry->write_buffer = new_MIOBuffer(alloc_index);
IOBufferReader *buf_start = ua_entry->write_buffer->alloc_reader();
+ t_state.hdr_info.client_request.m_100_continue_required = true;
+
DebugSM("http_seq", "send 100 Continue response to client");
- int64_t nbytes =
ua_entry->write_buffer->write(str_100_continue_response,
len_100_continue_response);
- ua_session->do_io_write(netvc, nbytes, buf_start);
+ int64_t nbytes =
ua_entry->write_buffer->write(str_100_continue_response,
len_100_continue_response);
+ ua_entry->write_vio = ua_session->do_io_write(this, nbytes, buf_start);
}
}
@@ -811,7 +813,7 @@ HttpSM::state_watch_for_client_abort(int event, void *data)
{
STATE_ENTER(&HttpSM::state_watch_for_client_abort, event);
- ink_assert(ua_entry->read_vio == (VIO *)data);
+ ink_assert(ua_entry->read_vio == (VIO *)data || ua_entry->write_vio == (VIO
*)data);
ink_assert(ua_entry->vc == ua_session);
switch (event) {
@@ -874,6 +876,20 @@ HttpSM::state_watch_for_client_abort(int event, void *data)
// Ignore. Could be a pipelined request. We'll get to it
// when we finish the current transaction
break;
+ case VC_EVENT_WRITE_READY:
+ // 100-continue handler
+ ink_assert(t_state.hdr_info.client_request.m_100_continue_required);
+ ua_entry->write_vio->reenable();
+ break;
+ case VC_EVENT_WRITE_COMPLETE:
+ // 100-continue handler
+ ink_assert(t_state.hdr_info.client_request.m_100_continue_required);
+ if (ua_entry->write_buffer) {
+ ink_assert(ua_entry->write_vio && !ua_entry->write_vio->ntodo());
+ free_MIOBuffer(ua_entry->write_buffer);
+ ua_entry->write_buffer = nullptr;
+ }
+ break;
default:
ink_release_assert(0);
break;
@@ -3357,6 +3373,9 @@ HttpSM::tunnel_handler_post_ua(int event,
HttpTunnelProducer *p)
// send back 408 request timeout
alloc_index = buffer_size_to_index(len_408_request_timeout_response +
t_state.internal_msg_buffer_size);
if (ua_entry->write_buffer) {
+ if (t_state.hdr_info.client_request.m_100_continue_required) {
+ ink_assert(ua_entry->write_vio && !ua_entry->write_vio->ntodo());
+ }
free_MIOBuffer(ua_entry->write_buffer);
ua_entry->write_buffer = nullptr;
}
--
To stop receiving notification emails like this one, please contact
['"[email protected]" <[email protected]>'].
