summaryrefslogtreecommitdiffstats
path: root/net/spdy/spdy_websocket_stream.h
diff options
context:
space:
mode:
authortoyoshim@chromium.org <toyoshim@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2011-06-27 11:50:29 +0000
committertoyoshim@chromium.org <toyoshim@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2011-06-27 11:50:29 +0000
commit675fa7d9f1c979b04a4606afcc5ad947a64440a7 (patch)
treec296c526db9a221f11e40f2a1af3c2868cca57be /net/spdy/spdy_websocket_stream.h
parentfe487862e3d76fa9d07bc9b9bd645b40e20a289c (diff)
downloadchromium_src-675fa7d9f1c979b04a4606afcc5ad947a64440a7.zip
chromium_src-675fa7d9f1c979b04a4606afcc5ad947a64440a7.tar.gz
chromium_src-675fa7d9f1c979b04a4606afcc5ad947a64440a7.tar.bz2
WebSocket over SPDY: SpdyWebSocketStream
SpdyWebSocketStream implementation. This class will be used by WebSocketJob to enable WebSocket over SPDY support. BUG=42320 TEST=net_unittest --gtest_filter=SpdyWebSocket\* Review URL: http://codereview.chromium.org/7089001 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@90555 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'net/spdy/spdy_websocket_stream.h')
-rw-r--r--net/spdy/spdy_websocket_stream.h99
1 files changed, 99 insertions, 0 deletions
diff --git a/net/spdy/spdy_websocket_stream.h b/net/spdy/spdy_websocket_stream.h
new file mode 100644
index 0000000..59610aa
--- /dev/null
+++ b/net/spdy/spdy_websocket_stream.h
@@ -0,0 +1,99 @@
+// Copyright (c) 2011 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_SPDY_SPDY_WEBSOCKET_STREAM_H_
+#define NET_SPDY_SPDY_WEBSOCKET_STREAM_H_
+#pragma once
+
+#include "base/basictypes.h"
+#include "base/gtest_prod_util.h"
+#include "base/memory/linked_ptr.h"
+#include "base/memory/ref_counted.h"
+#include "base/time.h"
+#include "net/base/completion_callback.h"
+#include "net/base/request_priority.h"
+#include "net/spdy/spdy_framer.h"
+#include "net/spdy/spdy_stream.h"
+
+namespace net {
+
+// The SpdyWebSocketStream is a WebSocket-specific type of stream known to a
+// SpdySession. WebSocket's opening handshake is converted to SPDY's
+// SYN_STREAM/SYN_REPLY. WebSocket frames are encapsulated as SPDY data frames.
+class NET_TEST SpdyWebSocketStream
+ : public SpdyStream::Delegate {
+ public:
+ // Delegate handles asynchronous events.
+ class NET_TEST Delegate {
+ public:
+ // Called when InitializeStream() finishes asynchronously. This delegate is
+ // called if InitializeStream() returns ERR_IO_PENDING. |status| indicates
+ // network error.
+ virtual void OnCreatedSpdyStream(int status) = 0;
+
+ // Called on corresponding to OnSendHeadersComplete() or SPDY's SYN frame
+ // has been sent.
+ virtual void OnSentSpdyHeaders(int status) = 0;
+
+ // Called on corresponding to OnResponseReceived() or SPDY's SYN_STREAM,
+ // SYN_REPLY, or HEADERS frames are received. This callback may be called
+ // multiple times as SPDY's delegate does.
+ virtual int OnReceivedSpdyResponseHeader(
+ const spdy::SpdyHeaderBlock& headers,
+ int status) = 0;
+
+ // Called when data is sent.
+ virtual void OnSentSpdyData(int amount_sent) = 0;
+
+ // Called when data is received.
+ virtual void OnReceivedSpdyData(const char* data, int length) = 0;
+
+ // Called when SpdyStream is closed.
+ virtual void OnCloseSpdyStream() = 0;
+ };
+
+ SpdyWebSocketStream(SpdySession* spdy_session, Delegate* delegate);
+ virtual ~SpdyWebSocketStream();
+
+ // Initializes SPDY stream for the WebSocket.
+ // It might create SPDY stream asynchronously. In this case, this method
+ // returns ERR_IO_PENDING and call OnCreatedSpdyStream delegate with result
+ // after completion. In other cases, delegate does not be called.
+ int InitializeStream(const GURL& url,
+ RequestPriority request_priority,
+ const BoundNetLog& stream_net_log);
+
+ int SendRequest(const linked_ptr<spdy::SpdyHeaderBlock>& headers);
+ int SendData(const char* data, int length);
+ void Close();
+
+ // SpdyStream::Delegate
+ virtual bool OnSendHeadersComplete(int status);
+ virtual int OnSendBody();
+ virtual int OnSendBodyComplete(int status, bool* eof);
+ virtual int OnResponseReceived(const spdy::SpdyHeaderBlock& response,
+ base::Time response_time,
+ int status);
+ virtual void OnDataReceived(const char* data, int length);
+ virtual void OnDataSent(int length);
+ virtual void OnClose(int status);
+ virtual void set_chunk_callback(ChunkCallback* callback);
+
+ private:
+ FRIEND_TEST_ALL_PREFIXES(SpdyWebSocketStreamTest, Basic);
+
+ void OnSpdyStreamCreated(int status);
+
+ scoped_refptr<SpdyStream> stream_;
+ scoped_refptr<SpdySession> spdy_session_;
+ Delegate* delegate_;
+
+ CompletionCallbackImpl<SpdyWebSocketStream> spdy_stream_created_callback_;
+
+ DISALLOW_COPY_AND_ASSIGN(SpdyWebSocketStream);
+};
+
+} // namespace net
+
+#endif // NET_SPDY_SPDY_WEBSOCKET_STREAM_H_