| Index: net/spdy/spdy_stream_test_util.cc
|
| diff --git a/net/spdy/spdy_stream_test_util.cc b/net/spdy/spdy_stream_test_util.cc
|
| deleted file mode 100644
|
| index 4cd526467763385c8a9ff9ae196c2416480571e3..0000000000000000000000000000000000000000
|
| --- a/net/spdy/spdy_stream_test_util.cc
|
| +++ /dev/null
|
| @@ -1,161 +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/spdy/spdy_stream_test_util.h"
|
| -
|
| -#include <cstddef>
|
| -
|
| -#include "base/stl_util.h"
|
| -#include "net/base/completion_callback.h"
|
| -#include "net/spdy/spdy_stream.h"
|
| -#include "testing/gtest/include/gtest/gtest.h"
|
| -
|
| -namespace net {
|
| -
|
| -namespace test {
|
| -
|
| -ClosingDelegate::ClosingDelegate(
|
| - const base::WeakPtr<SpdyStream>& stream) : stream_(stream) {
|
| - DCHECK(stream_);
|
| -}
|
| -
|
| -ClosingDelegate::~ClosingDelegate() {}
|
| -
|
| -void ClosingDelegate::OnRequestHeadersSent() {}
|
| -
|
| -SpdyResponseHeadersStatus ClosingDelegate::OnResponseHeadersUpdated(
|
| - const SpdyHeaderBlock& response_headers) {
|
| - return RESPONSE_HEADERS_ARE_COMPLETE;
|
| -}
|
| -
|
| -void ClosingDelegate::OnDataReceived(scoped_ptr<SpdyBuffer> buffer) {}
|
| -
|
| -void ClosingDelegate::OnDataSent() {}
|
| -
|
| -void ClosingDelegate::OnClose(int status) {
|
| - DCHECK(stream_);
|
| - stream_->Close();
|
| - // The |stream_| may still be alive (if it is our delegate).
|
| -}
|
| -
|
| -StreamDelegateBase::StreamDelegateBase(
|
| - const base::WeakPtr<SpdyStream>& stream)
|
| - : stream_(stream),
|
| - stream_id_(0),
|
| - send_headers_completed_(false) {
|
| -}
|
| -
|
| -StreamDelegateBase::~StreamDelegateBase() {
|
| -}
|
| -
|
| -void StreamDelegateBase::OnRequestHeadersSent() {
|
| - stream_id_ = stream_->stream_id();
|
| - EXPECT_NE(stream_id_, 0u);
|
| - send_headers_completed_ = true;
|
| -}
|
| -
|
| -SpdyResponseHeadersStatus StreamDelegateBase::OnResponseHeadersUpdated(
|
| - const SpdyHeaderBlock& response_headers) {
|
| - EXPECT_EQ(stream_->type() != SPDY_PUSH_STREAM, send_headers_completed_);
|
| - response_headers_ = response_headers;
|
| - return RESPONSE_HEADERS_ARE_COMPLETE;
|
| -}
|
| -
|
| -void StreamDelegateBase::OnDataReceived(scoped_ptr<SpdyBuffer> buffer) {
|
| - if (buffer)
|
| - received_data_queue_.Enqueue(buffer.Pass());
|
| -}
|
| -
|
| -void StreamDelegateBase::OnDataSent() {}
|
| -
|
| -void StreamDelegateBase::OnClose(int status) {
|
| - if (!stream_.get())
|
| - return;
|
| - stream_id_ = stream_->stream_id();
|
| - stream_.reset();
|
| - callback_.callback().Run(status);
|
| -}
|
| -
|
| -int StreamDelegateBase::WaitForClose() {
|
| - int result = callback_.WaitForResult();
|
| - EXPECT_TRUE(!stream_.get());
|
| - return result;
|
| -}
|
| -
|
| -std::string StreamDelegateBase::TakeReceivedData() {
|
| - size_t len = received_data_queue_.GetTotalSize();
|
| - std::string received_data(len, '\0');
|
| - if (len > 0) {
|
| - EXPECT_EQ(
|
| - len,
|
| - received_data_queue_.Dequeue(string_as_array(&received_data), len));
|
| - }
|
| - return received_data;
|
| -}
|
| -
|
| -std::string StreamDelegateBase::GetResponseHeaderValue(
|
| - const std::string& name) const {
|
| - SpdyHeaderBlock::const_iterator it = response_headers_.find(name);
|
| - return (it == response_headers_.end()) ? std::string() : it->second;
|
| -}
|
| -
|
| -StreamDelegateDoNothing::StreamDelegateDoNothing(
|
| - const base::WeakPtr<SpdyStream>& stream)
|
| - : StreamDelegateBase(stream) {}
|
| -
|
| -StreamDelegateDoNothing::~StreamDelegateDoNothing() {
|
| -}
|
| -
|
| -StreamDelegateSendImmediate::StreamDelegateSendImmediate(
|
| - const base::WeakPtr<SpdyStream>& stream,
|
| - base::StringPiece data)
|
| - : StreamDelegateBase(stream),
|
| - data_(data) {}
|
| -
|
| -StreamDelegateSendImmediate::~StreamDelegateSendImmediate() {
|
| -}
|
| -
|
| -SpdyResponseHeadersStatus StreamDelegateSendImmediate::OnResponseHeadersUpdated(
|
| - const SpdyHeaderBlock& response_headers) {
|
| - SpdyResponseHeadersStatus status =
|
| - StreamDelegateBase::OnResponseHeadersUpdated(response_headers);
|
| - if (data_.data()) {
|
| - scoped_refptr<StringIOBuffer> buf(new StringIOBuffer(data_.as_string()));
|
| - stream()->SendData(buf.get(), buf->size(), MORE_DATA_TO_SEND);
|
| - }
|
| - return status;
|
| -}
|
| -
|
| -StreamDelegateWithBody::StreamDelegateWithBody(
|
| - const base::WeakPtr<SpdyStream>& stream,
|
| - base::StringPiece data)
|
| - : StreamDelegateBase(stream),
|
| - buf_(new StringIOBuffer(data.as_string())) {}
|
| -
|
| -StreamDelegateWithBody::~StreamDelegateWithBody() {
|
| -}
|
| -
|
| -void StreamDelegateWithBody::OnRequestHeadersSent() {
|
| - StreamDelegateBase::OnRequestHeadersSent();
|
| - stream()->SendData(buf_.get(), buf_->size(), NO_MORE_DATA_TO_SEND);
|
| -}
|
| -
|
| -StreamDelegateCloseOnHeaders::StreamDelegateCloseOnHeaders(
|
| - const base::WeakPtr<SpdyStream>& stream)
|
| - : StreamDelegateBase(stream) {
|
| -}
|
| -
|
| -StreamDelegateCloseOnHeaders::~StreamDelegateCloseOnHeaders() {
|
| -}
|
| -
|
| -SpdyResponseHeadersStatus
|
| -StreamDelegateCloseOnHeaders::OnResponseHeadersUpdated(
|
| - const SpdyHeaderBlock& response_headers) {
|
| - stream()->Cancel();
|
| - return RESPONSE_HEADERS_ARE_COMPLETE;
|
| -}
|
| -
|
| -} // namespace test
|
| -
|
| -} // namespace net
|
|
|