Repository: trafficserver
Updated Branches:
  refs/heads/master 23406cedf -> 626c79e39


TS-2791: Write ready isn't needed in spdy


Project: http://git-wip-us.apache.org/repos/asf/trafficserver/repo
Commit: http://git-wip-us.apache.org/repos/asf/trafficserver/commit/626c79e3
Tree: http://git-wip-us.apache.org/repos/asf/trafficserver/tree/626c79e3
Diff: http://git-wip-us.apache.org/repos/asf/trafficserver/diff/626c79e3

Branch: refs/heads/master
Commit: 626c79e39c446fa3bfa08db542f19b123457cc0e
Parents: 23406ce
Author: Brian Geffon <[email protected]>
Authored: Thu Jul 17 11:43:33 2014 -0700
Committer: Brian Geffon <[email protected]>
Committed: Thu Jul 17 11:43:33 2014 -0700

----------------------------------------------------------------------
 proxy/FetchSM.cc | 18 ++++--------------
 1 file changed, 4 insertions(+), 14 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/trafficserver/blob/626c79e3/proxy/FetchSM.cc
----------------------------------------------------------------------
diff --git a/proxy/FetchSM.cc b/proxy/FetchSM.cc
index 56ab827..c8bf84d 100644
--- a/proxy/FetchSM.cc
+++ b/proxy/FetchSM.cc
@@ -533,25 +533,15 @@ FetchSM::ext_lanuch()
 void
 FetchSM::ext_write_data(const void *data, size_t len)
 {
-  bool writeReady = header_done;
-
-  if (writeReady && (fetch_flags & TS_FETCH_FLAGS_NEWLOCK)) {
+  if (fetch_flags & TS_FETCH_FLAGS_NEWLOCK) {
     MUTEX_TAKE_LOCK(mutex, this_ethread());
   }
-
   req_buffer->write(data, len);
 
-  //
-  // Before header_done, FetchSM may not
-  // be initialized.
-  //
-  if (writeReady) {
-    Debug(DEBUG_TAG, "[%s] re-enabling write_vio, header_done %u", 
__FUNCTION__, header_done);
-    write_vio->reenable();
-    fetch_handler(TS_EVENT_VCONN_WRITE_READY, write_vio);
-  }
+  Debug(DEBUG_TAG, "[%s] re-enabling write_vio, header_done %u", __FUNCTION__, 
header_done);
+  write_vio->reenable();
 
-  if (writeReady && (fetch_flags & TS_FETCH_FLAGS_NEWLOCK)) {
+  if (fetch_flags & TS_FETCH_FLAGS_NEWLOCK) {
     MUTEX_UNTAKE_LOCK(mutex, this_ethread());
   }
 }

Reply via email to