OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2011 Google Inc. All rights reserved. | 2 * Copyright (C) 2011 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions are | 5 * modification, are permitted provided that the following conditions are |
6 * met: | 6 * met: |
7 * | 7 * |
8 * * Redistributions of source code must retain the above copyright | 8 * * Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
10 * * Redistributions in binary form must reproduce the above | 10 * * Redistributions in binary form must reproduce the above |
(...skipping 26 matching lines...) Expand all Loading... |
37 #include "modules/websockets/WebSocketChannel.h" | 37 #include "modules/websockets/WebSocketChannel.h" |
38 #include "modules/websockets/WebSocketChannelClient.h" | 38 #include "modules/websockets/WebSocketChannelClient.h" |
39 #include "platform/Timer.h" | 39 #include "platform/Timer.h" |
40 #include "platform/heap/Handle.h" | 40 #include "platform/heap/Handle.h" |
41 #include "platform/weborigin/KURL.h" | 41 #include "platform/weborigin/KURL.h" |
42 #include "wtf/Deque.h" | 42 #include "wtf/Deque.h" |
43 #include "wtf/Forward.h" | 43 #include "wtf/Forward.h" |
44 #include "wtf/RefCounted.h" | 44 #include "wtf/RefCounted.h" |
45 #include "wtf/text/AtomicStringHash.h" | 45 #include "wtf/text/AtomicStringHash.h" |
46 | 46 |
47 namespace WebCore { | 47 namespace blink { |
48 | 48 |
49 class Blob; | 49 class Blob; |
50 class ExceptionState; | 50 class ExceptionState; |
51 | 51 |
52 class DOMWebSocket : public RefCountedWillBeRefCountedGarbageCollected<DOMWebSoc
ket>, public EventTargetWithInlineData, public ActiveDOMObject, public WebSocket
ChannelClient { | 52 class DOMWebSocket : public RefCountedWillBeRefCountedGarbageCollected<DOMWebSoc
ket>, public EventTargetWithInlineData, public ActiveDOMObject, public WebSocket
ChannelClient { |
53 REFCOUNTED_EVENT_TARGET(DOMWebSocket); | 53 REFCOUNTED_EVENT_TARGET(DOMWebSocket); |
54 WILL_BE_USING_GARBAGE_COLLECTED_MIXIN(DOMWebSocket); | 54 WILL_BE_USING_GARBAGE_COLLECTED_MIXIN(DOMWebSocket); |
55 public: | 55 public: |
56 static const char* subprotocolSeperator(); | 56 static const char* subprotocolSeperator(); |
57 // DOMWebSocket instances must be used with a wrapper since this class's | 57 // DOMWebSocket instances must be used with a wrapper since this class's |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
123 virtual void didClose(ClosingHandshakeCompletionStatus, unsigned short code,
const String& reason) OVERRIDE; | 123 virtual void didClose(ClosingHandshakeCompletionStatus, unsigned short code,
const String& reason) OVERRIDE; |
124 | 124 |
125 virtual void trace(Visitor*) OVERRIDE; | 125 virtual void trace(Visitor*) OVERRIDE; |
126 | 126 |
127 static bool isValidSubprotocolString(const String&); | 127 static bool isValidSubprotocolString(const String&); |
128 | 128 |
129 protected: | 129 protected: |
130 explicit DOMWebSocket(ExecutionContext*); | 130 explicit DOMWebSocket(ExecutionContext*); |
131 | 131 |
132 private: | 132 private: |
133 // FIXME: This should inherit WebCore::EventQueue. | 133 // FIXME: This should inherit blink::EventQueue. |
134 class EventQueue FINAL : public RefCountedWillBeGarbageCollectedFinalized<Ev
entQueue> { | 134 class EventQueue FINAL : public RefCountedWillBeGarbageCollectedFinalized<Ev
entQueue> { |
135 public: | 135 public: |
136 static PassRefPtrWillBeRawPtr<EventQueue> create(EventTarget* target) | 136 static PassRefPtrWillBeRawPtr<EventQueue> create(EventTarget* target) |
137 { | 137 { |
138 return adoptRefWillBeNoop(new EventQueue(target)); | 138 return adoptRefWillBeNoop(new EventQueue(target)); |
139 } | 139 } |
140 ~EventQueue(); | 140 ~EventQueue(); |
141 | 141 |
142 // Dispatches the event if this queue is active. | 142 // Dispatches the event if this queue is active. |
143 // Queues the event if this queue is suspended. | 143 // Queues the event if this queue is suspended. |
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
226 unsigned long m_bufferedAmountAfterClose; | 226 unsigned long m_bufferedAmountAfterClose; |
227 BinaryType m_binaryType; | 227 BinaryType m_binaryType; |
228 // The subprotocol the server selected. | 228 // The subprotocol the server selected. |
229 String m_subprotocol; | 229 String m_subprotocol; |
230 String m_extensions; | 230 String m_extensions; |
231 | 231 |
232 RefPtrWillBeMember<EventQueue> m_eventQueue; | 232 RefPtrWillBeMember<EventQueue> m_eventQueue; |
233 Timer<DOMWebSocket> m_bufferedAmountConsumeTimer; | 233 Timer<DOMWebSocket> m_bufferedAmountConsumeTimer; |
234 }; | 234 }; |
235 | 235 |
236 } // namespace WebCore | 236 } // namespace blink |
237 | 237 |
238 #endif // DOMWebSocket_h | 238 #endif // DOMWebSocket_h |
OLD | NEW |