Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1230)

Unified Diff: net/socket/buffered_write_stream_socket.h

Issue 275953002: Remove HTTP pipelining support. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Merge Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: net/socket/buffered_write_stream_socket.h
diff --git a/net/socket/buffered_write_stream_socket.h b/net/socket/buffered_write_stream_socket.h
index 8eb94f3efd03cfd4db293c7c6fd1bf592837215c..e69de29bb2d1d6434b8b29ae775ad8c2e48c5391 100644
--- a/net/socket/buffered_write_stream_socket.h
+++ b/net/socket/buffered_write_stream_socket.h
@@ -1,83 +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.
-
-#ifndef NET_SOCKET_BUFFERED_WRITE_STREAM_SOCKET_H_
-#define NET_SOCKET_BUFFERED_WRITE_STREAM_SOCKET_H_
-
-#include "base/basictypes.h"
-#include "base/memory/scoped_ptr.h"
-#include "base/memory/weak_ptr.h"
-#include "net/base/net_log.h"
-#include "net/socket/stream_socket.h"
-
-namespace base {
-class TimeDelta;
-}
-
-namespace net {
-
-class AddressList;
-class GrowableIOBuffer;
-class IPEndPoint;
-
-// A StreamSocket decorator. All functions are passed through to the wrapped
-// socket, except for Write().
-//
-// Writes are buffered locally so that multiple Write()s to this class are
-// issued as only one Write() to the wrapped socket. This is useful to force
-// multiple requests to be issued in a single packet, as is needed to trigger
-// edge cases in HTTP pipelining.
-//
-// Note that the Write() always returns synchronously. It will either buffer the
-// entire input or return the most recently reported error.
-//
-// There are no bounds on the local buffer size. Use carefully.
-class NET_EXPORT_PRIVATE BufferedWriteStreamSocket : public StreamSocket {
- public:
- explicit BufferedWriteStreamSocket(scoped_ptr<StreamSocket> socket_to_wrap);
- virtual ~BufferedWriteStreamSocket();
-
- // Socket interface
- virtual int Read(IOBuffer* buf, int buf_len,
- const CompletionCallback& callback) OVERRIDE;
- virtual int Write(IOBuffer* buf, int buf_len,
- const CompletionCallback& callback) OVERRIDE;
- virtual int SetReceiveBufferSize(int32 size) OVERRIDE;
- virtual int SetSendBufferSize(int32 size) OVERRIDE;
-
- // StreamSocket interface
- virtual int Connect(const CompletionCallback& callback) OVERRIDE;
- virtual void Disconnect() OVERRIDE;
- virtual bool IsConnected() const OVERRIDE;
- virtual bool IsConnectedAndIdle() const OVERRIDE;
- virtual int GetPeerAddress(IPEndPoint* address) const OVERRIDE;
- virtual int GetLocalAddress(IPEndPoint* address) const OVERRIDE;
- virtual const BoundNetLog& NetLog() const OVERRIDE;
- virtual void SetSubresourceSpeculation() OVERRIDE;
- virtual void SetOmniboxSpeculation() OVERRIDE;
- virtual bool WasEverUsed() const OVERRIDE;
- virtual bool UsingTCPFastOpen() const OVERRIDE;
- virtual bool WasNpnNegotiated() const OVERRIDE;
- virtual NextProto GetNegotiatedProtocol() const OVERRIDE;
- virtual bool GetSSLInfo(SSLInfo* ssl_info) OVERRIDE;
-
- private:
- void DoDelayedWrite();
- void OnIOComplete(int result);
-
- scoped_ptr<StreamSocket> wrapped_socket_;
- scoped_refptr<GrowableIOBuffer> io_buffer_;
- scoped_refptr<GrowableIOBuffer> backup_buffer_;
- bool callback_pending_;
- bool wrapped_write_in_progress_;
- int error_;
-
- base::WeakPtrFactory<BufferedWriteStreamSocket> weak_factory_;
-
- DISALLOW_COPY_AND_ASSIGN(BufferedWriteStreamSocket);
-};
-
-} // namespace net
-
-#endif // NET_SOCKET_STREAM_SOCKET_H_

Powered by Google App Engine
This is Rietveld 408576698