Index: net/tools/quic/quic_spdy_server_stream.cc |
diff --git a/net/tools/quic/quic_spdy_server_stream.cc b/net/tools/quic/quic_spdy_server_stream.cc |
deleted file mode 100644 |
index cf85933c6d124ee5b1d627ee0900f1f3b8c73cee..0000000000000000000000000000000000000000 |
--- a/net/tools/quic/quic_spdy_server_stream.cc |
+++ /dev/null |
@@ -1,143 +0,0 @@ |
-// Copyright (c) 2012 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "net/tools/quic/quic_spdy_server_stream.h" |
- |
-#include "base/memory/singleton.h" |
-#include "net/quic/quic_session.h" |
-#include "net/spdy/spdy_framer.h" |
-#include "net/tools/quic/quic_in_memory_cache.h" |
-#include "net/tools/quic/spdy_utils.h" |
- |
-using base::StringPiece; |
-using std::string; |
- |
-namespace net { |
-namespace tools { |
- |
-static const size_t kHeaderBufInitialSize = 4096; |
- |
-QuicSpdyServerStream::QuicSpdyServerStream(QuicStreamId id, |
- QuicSession* session) |
- : QuicDataStream(id, session), |
- read_buf_(new GrowableIOBuffer()), |
- request_headers_received_(false) { |
-} |
- |
-QuicSpdyServerStream::~QuicSpdyServerStream() { |
-} |
- |
-uint32 QuicSpdyServerStream::ProcessData(const char* data, uint32 data_len) { |
- uint32 total_bytes_processed = 0; |
- |
- // Are we still reading the request headers. |
- if (!request_headers_received_) { |
- // Grow the read buffer if necessary. |
- if (read_buf_->RemainingCapacity() < (int)data_len) { |
- read_buf_->SetCapacity(read_buf_->capacity() + kHeaderBufInitialSize); |
- } |
- memcpy(read_buf_->data(), data, data_len); |
- read_buf_->set_offset(read_buf_->offset() + data_len); |
- ParseRequestHeaders(); |
- } else { |
- body_.append(data + total_bytes_processed, |
- data_len - total_bytes_processed); |
- } |
- return data_len; |
-} |
- |
-void QuicSpdyServerStream::OnFinRead() { |
- ReliableQuicStream::OnFinRead(); |
- if (write_side_closed() || fin_buffered()) { |
- return; |
- } |
- |
- if (!request_headers_received_) { |
- SendErrorResponse(); // We're not done reading headers. |
- } else if ((headers_.content_length_status() == |
- BalsaHeadersEnums::VALID_CONTENT_LENGTH) && |
- body_.size() != headers_.content_length()) { |
- SendErrorResponse(); // Invalid content length |
- } else { |
- SendResponse(); |
- } |
-} |
- |
-void QuicSpdyServerStream::ParseRequestHeaders() { |
- size_t read_buf_len = static_cast<size_t>(read_buf_->offset()); |
- SpdyFramer framer(SPDY3); |
- SpdyHeaderBlock headers; |
- char* data = read_buf_->StartOfBuffer(); |
- size_t len = framer.ParseHeaderBlockInBuffer(data, read_buf_->offset(), |
- &headers); |
- if (len == 0) { |
- return; |
- } |
- |
- if (!SpdyUtils::FillBalsaRequestHeaders(headers, &headers_)) { |
- SendErrorResponse(); |
- return; |
- } |
- |
- size_t delta = read_buf_len - len; |
- if (delta > 0) { |
- body_.append(data + len, delta); |
- } |
- |
- request_headers_received_ = true; |
-} |
- |
-void QuicSpdyServerStream::SendResponse() { |
- // Find response in cache. If not found, send error response. |
- const QuicInMemoryCache::Response* response = |
- QuicInMemoryCache::GetInstance()->GetResponse(headers_); |
- if (response == nullptr) { |
- SendErrorResponse(); |
- return; |
- } |
- |
- if (response->response_type() == QuicInMemoryCache::CLOSE_CONNECTION) { |
- DVLOG(1) << "Special response: closing connection."; |
- CloseConnection(QUIC_NO_ERROR); |
- return; |
- } |
- |
- if (response->response_type() == QuicInMemoryCache::IGNORE_REQUEST) { |
- DVLOG(1) << "Special response: ignoring request."; |
- return; |
- } |
- |
- DVLOG(1) << "Sending response for stream " << id(); |
- SendHeadersAndBody(response->headers(), response->body()); |
-} |
- |
-void QuicSpdyServerStream::SendErrorResponse() { |
- DVLOG(1) << "Sending error response for stream " << id(); |
- BalsaHeaders headers; |
- headers.SetResponseFirstlineFromStringPieces( |
- "HTTP/1.1", "500", "Server Error"); |
- headers.ReplaceOrAppendHeader("content-length", "3"); |
- SendHeadersAndBody(headers, "bad"); |
-} |
- |
-void QuicSpdyServerStream::SendHeadersAndBody( |
- const BalsaHeaders& response_headers, |
- StringPiece body) { |
- // We only support SPDY and HTTP, and neither handles bidirectional streaming. |
- if (!read_side_closed()) { |
- CloseReadSide(); |
- } |
- |
- SpdyHeaderBlock header_block = |
- SpdyUtils::ResponseHeadersToSpdyHeaders(response_headers); |
- |
- WriteHeaders(header_block, body.empty(), nullptr); |
- |
- if (!body.empty()) { |
- WriteOrBufferData(body, true, nullptr); |
- } |
-} |
- |
-} // namespace tools |
-} // namespace net |