Home
last modified time | relevance | path

Searched refs:WebSocketFrame (Results 1 – 25 of 36) sorted by relevance

12

/external/chromium_org/third_party/WebKit/Source/modules/websockets/
DWebSocketPerMessageDeflateTest.cpp49 WebSocketFrame::OpCode opcode = WebSocketFrame::OpCodeText; in TEST()
50 WebSocketFrame f1(opcode, "Hello", 5, WebSocketFrame::Final); in TEST()
51 WebSocketFrame f2(opcode, "Hello", 5, WebSocketFrame::Final); in TEST()
71 WebSocketFrame::OpCode opcode = WebSocketFrame::OpCodeText; in TEST()
72 WebSocketFrame f1(opcode, "Hello", 5, WebSocketFrame::Final); in TEST()
73 WebSocketFrame f2(opcode, "Hello", 5, WebSocketFrame::Final); in TEST()
92 WebSocketFrame::OpCode text = WebSocketFrame::OpCodeText; in TEST()
106 WebSocketFrame frame(text, &payload[0], payload.size(), WebSocketFrame::Final); in TEST()
112 WebSocketFrame::OpCode opcode = !i ? text : WebSocketFrame::OpCodeContinuation; in TEST()
114 WebSocketFrame frame(opcode, &payload[i], 1); in TEST()
[all …]
DWebSocketFrame.cpp49 bool WebSocketFrame::needsExtendedLengthField(size_t payloadLength) in needsExtendedLengthField()
54 WebSocketFrame::ParseFrameResult WebSocketFrame::parseFrame(char* data, size_t dataLength, WebSocke… in parseFrame()
116 frame.opCode = static_cast<WebSocketFrame::OpCode>(opCode); in parseFrame()
128 static void appendFramePayload(const WebSocketFrame& frame, Vector<char>& frameData) in appendFramePayload()
146 void WebSocketFrame::makeFrameData(Vector<char>& frameData) in makeFrameData()
176 WebSocketFrame::WebSocketFrame() in WebSocketFrame() function in WebCore::WebSocketFrame
188 WebSocketFrame::WebSocketFrame(OpCode opCode, const char* payload, size_t payloadLength, Flags flag… in WebSocketFrame() function in WebCore::WebSocketFrame
DMainThreadWebSocketChannel.cpp143 …enqueueRawFrame(WebSocketFrame::OpCodeBinary, static_cast<const char*>(binaryData.data()) + byteOf… in send()
151 enqueueBlobFrame(WebSocketFrame::OpCodeBinary, binaryData); in send()
159 enqueueRawFrame(WebSocketFrame::OpCodeBinary, data, length); in send()
494 enqueueRawFrame(WebSocketFrame::OpCodeClose, buf.data(), buf.size()); in startClosingHandshake()
514 WebSocketFrame frame; in processFrame()
517WebSocketFrame::ParseFrameResult result = WebSocketFrame::parseFrame(m_buffer.data(), m_buffer.siz… in processFrame()
518 if (result == WebSocketFrame::FrameIncomplete) in processFrame()
520 if (result == WebSocketFrame::FrameError) { in processFrame()
539 if (WebSocketFrame::isReservedOpCode(frame.opCode)) { in processFrame()
555 if (WebSocketFrame::isControlOpCode(frame.opCode) && !frame.final) { in processFrame()
[all …]
DNewWebSocketChannelImpl.cpp163WebSocketFrame frame(WebSocketFrame::OpCodeText, data.data(), data.length(), WebSocketFrame::Final… in send()
180WebSocketFrame frame(WebSocketFrame::OpCodeBinary, "", 0, WebSocketFrame::Final | WebSocketFrame::… in send()
194WebSocketFrame frame(WebSocketFrame::OpCodeBinary, static_cast<const char*>(buffer.data()) + byteO… in send()
421WebSocketFrame::OpCode opcode = m_receivingMessageTypeIsText ? WebSocketFrame::OpCodeText : WebSoc… in didReceiveData()
422WebSocketFrame frame(opcode, m_receivingMessageData.data(), m_receivingMessageData.size(), WebSock… in didReceiveData()
DWebSocketFrame.h38 struct WebSocketFrame { struct
60 …static ParseFrameResult parseFrame(char* data, size_t dataLength, WebSocketFrame&, const char*& fr… argument
74 WebSocketFrame(); argument
76 WebSocketFrame(OpCode, const char* payload, size_t payloadLength, Flags = EmptyFlags);
DWebSocketPerMessageDeflate.cpp172 bool WebSocketPerMessageDeflate::deflate(WebSocketFrame& frame) in deflate()
180 if (!WebSocketFrame::isNonControlOpCode(frame.opCode)) in deflate()
183 if ((frame.opCode == WebSocketFrame::OpCodeText || frame.opCode == WebSocketFrame::OpCodeBinary) in deflate()
217 bool WebSocketPerMessageDeflate::inflate(WebSocketFrame& frame) in inflate()
221 if (!WebSocketFrame::isNonControlOpCode(frame.opCode)) { in inflate()
DMainThreadWebSocketChannel.h144 WebSocketFrame::OpCode opCode;
152 void enqueueRawFrame(WebSocketFrame::OpCode, const char* data, size_t dataLength);
153 void enqueueBlobFrame(WebSocketFrame::OpCode, PassRefPtr<BlobDataHandle>);
174 bool sendFrame(WebSocketFrame::OpCode, const char* data, size_t dataLength);
210 WebSocketFrame::OpCode m_continuousFrameOpCode;
DWebSocketPerMessageDeflate.h59 bool deflate(WebSocketFrame&);
71 bool inflate(WebSocketFrame&);
DWebSocketDeflateFramer.cpp174 PassOwnPtr<DeflateResultHolder> WebSocketDeflateFramer::deflate(WebSocketFrame& frame) in deflate()
177 if (!enabled() || !WebSocketFrame::isNonControlOpCode(frame.opCode) || !frame.payloadLength) in deflate()
195 PassOwnPtr<InflateResultHolder> WebSocketDeflateFramer::inflate(WebSocketFrame& frame) in inflate()
202 if (!WebSocketFrame::isNonControlOpCode(frame.opCode)) { in inflate()
DWebSocketDeflateFramer.h98 PassOwnPtr<DeflateResultHolder> deflate(WebSocketFrame&);
100 PassOwnPtr<InflateResultHolder> inflate(WebSocketFrame&);
/external/chromium_org/net/websockets/
Dwebsocket_deflate_stream.h48 virtual int ReadFrames(ScopedVector<WebSocketFrame>* frames,
50 virtual int WriteFrames(ScopedVector<WebSocketFrame>* frames,
70 void OnReadComplete(ScopedVector<WebSocketFrame>* frames,
75 int Deflate(ScopedVector<WebSocketFrame>* frames);
76 void OnMessageStart(const ScopedVector<WebSocketFrame>& frames, size_t index);
78 ScopedVector<WebSocketFrame>* frames_to_write);
80 ScopedVector<WebSocketFrame>* frames,
81 ScopedVector<WebSocketFrame>* frames_to_write);
84 int Inflate(ScopedVector<WebSocketFrame>* frames);
86 int InflateAndReadIfNecessary(ScopedVector<WebSocketFrame>* frames,
Dwebsocket_deflate_stream.cc55 int WebSocketDeflateStream::ReadFrames(ScopedVector<WebSocketFrame>* frames, in ReadFrames()
69 int WebSocketDeflateStream::WriteFrames(ScopedVector<WebSocketFrame>* frames, in WriteFrames()
90 ScopedVector<WebSocketFrame>* frames, in OnReadComplete()
104 int WebSocketDeflateStream::Deflate(ScopedVector<WebSocketFrame>* frames) { in Deflate()
105 ScopedVector<WebSocketFrame> frames_to_write; in Deflate()
108 ScopedVector<WebSocketFrame> frames_of_message; in Deflate()
119 scoped_ptr<WebSocketFrame> frame((*frames)[i]); in Deflate()
172 const ScopedVector<WebSocketFrame>& frames, size_t index) { in OnMessageStart()
173 WebSocketFrame* frame = frames[index]; in OnMessageStart()
196 ScopedVector<WebSocketFrame>* frames_to_write) { in AppendCompressedFrame()
[all …]
Dwebsocket_deflate_stream_test.cc70 std::string ToString(const WebSocketFrame* frame) { in ToString()
74 void AppendTo(ScopedVector<WebSocketFrame>* frames, in AppendTo()
78 scoped_ptr<WebSocketFrame> frame(new WebSocketFrame(opcode)); in AppendTo()
86 void AppendTo(ScopedVector<WebSocketFrame>* frames, in AppendTo()
89 scoped_ptr<WebSocketFrame> frame(new WebSocketFrame(opcode)); in AppendTo()
97 MOCK_METHOD2(ReadFrames, int(ScopedVector<WebSocketFrame>*,
99 MOCK_METHOD2(WriteFrames, int(ScopedVector<WebSocketFrame>*,
126 virtual Result Predict(const ScopedVector<WebSocketFrame>& frames, in Predict()
130 virtual void RecordInputDataFrame(const WebSocketFrame* frame) OVERRIDE { in RecordInputDataFrame()
149 virtual void RecordWrittenDataFrame(const WebSocketFrame* frame) OVERRIDE { in RecordWrittenDataFrame()
[all …]
Dwebsocket_basic_stream.h23 struct WebSocketFrame;
46 virtual int ReadFrames(ScopedVector<WebSocketFrame>* frames,
49 virtual int WriteFrames(ScopedVector<WebSocketFrame>* frames,
81 int HandleReadResult(int result, ScopedVector<WebSocketFrame>* frames);
88 ScopedVector<WebSocketFrame>* frames);
96 scoped_ptr<WebSocketFrame>* frame);
105 scoped_ptr<WebSocketFrame> CreateFrame(
116 void OnReadComplete(ScopedVector<WebSocketFrame>* frames,
Dwebsocket_deflate_predictor.h14 struct WebSocketFrame;
41 virtual Result Predict(const ScopedVector<WebSocketFrame>& frames,
47 virtual void RecordInputDataFrame(const WebSocketFrame* frame) = 0;
53 virtual void RecordWrittenDataFrame(const WebSocketFrame* frame) = 0;
Dwebsocket_deflate_predictor_impl.h16 struct WebSocketFrame;
23 virtual Result Predict(const ScopedVector<WebSocketFrame>& frames,
25 virtual void RecordInputDataFrame(const WebSocketFrame* frame) OVERRIDE;
26 virtual void RecordWrittenDataFrame(const WebSocketFrame* frame) OVERRIDE;
Dwebsocket_basic_stream.cc43 typedef ScopedVector<WebSocketFrame>::const_iterator WebSocketFrameIterator;
49 ScopedVector<WebSocketFrame>* frames) { in CalculateSerializedSizeAndTurnOnMaskBit()
54 WebSocketFrame* frame = *it; in CalculateSerializedSizeAndTurnOnMaskBit()
89 int WebSocketBasicStream::ReadFrames(ScopedVector<WebSocketFrame>* frames, in ReadFrames()
135 int WebSocketBasicStream::WriteFrames(ScopedVector<WebSocketFrame>* frames, in WriteFrames()
149 WebSocketFrame* frame = *it; in WriteFrames()
238 ScopedVector<WebSocketFrame>* frames) { in HandleReadResult()
255 ScopedVector<WebSocketFrame>* frames) { in ConvertChunksToFrames()
257 scoped_ptr<WebSocketFrame> frame; in ConvertChunksToFrames()
276 scoped_ptr<WebSocketFrame>* frame) { in ConvertChunkToFrame()
[all …]
Dwebsocket_deflate_predictor_impl.cc12 const ScopedVector<WebSocketFrame>& frames, in Predict()
18 const WebSocketFrame* frame) {} in RecordInputDataFrame()
21 const WebSocketFrame* frame) {} in RecordWrittenDataFrame()
Dwebsocket_stream.h24 struct WebSocketFrame;
128 virtual int ReadFrames(ScopedVector<WebSocketFrame>* frames,
145 virtual int WriteFrames(ScopedVector<WebSocketFrame>* frames,
Dwebsocket_frame.h95 struct NET_EXPORT_PRIVATE WebSocketFrame { struct
97 explicit WebSocketFrame(WebSocketFrameHeader::OpCode opcode);
98 ~WebSocketFrame();
Dwebsocket_channel_test.cc55 std::ostream& operator<<(std::ostream& os, const WebSocketFrame& frame) { in operator <<()
66 const ScopedVector<WebSocketFrame>& vector) { in operator <<()
69 for (ScopedVector<WebSocketFrame>::const_iterator it = vector.begin(); in operator <<()
83 const ScopedVector<WebSocketFrame>* vector) { in operator <<()
187 virtual int ReadFrames(ScopedVector<WebSocketFrame>* frames, in ReadFrames()
192 virtual int WriteFrames(ScopedVector<WebSocketFrame>* frames, in WriteFrames()
268 ScopedVector<WebSocketFrame> CreateFrameVector( in CreateFrameVector()
270 ScopedVector<WebSocketFrame> result_frames; in CreateFrameVector()
274 scoped_ptr<WebSocketFrame> result_frame( in CreateFrameVector()
275 new WebSocketFrame(source_frame.opcode)); in CreateFrameVector()
[all …]
Dwebsocket_deflate_predictor_impl_test.cc20 ScopedVector<WebSocketFrame> frames; in TEST()
21 frames.push_back(new WebSocketFrame(WebSocketFrameHeader::kOpCodeText)); in TEST()
Dwebsocket_frame.cc60 WebSocketFrame::WebSocketFrame(WebSocketFrameHeader::OpCode opcode) in WebSocketFrame() function in net::WebSocketFrame
63 WebSocketFrame::~WebSocketFrame() {} in ~WebSocketFrame()
Dwebsocket_channel.cc83 void AddFrame(scoped_ptr<WebSocketFrame> chunk);
86 ScopedVector<WebSocketFrame>* frames() { return &frames_; } in frames()
90 ScopedVector<WebSocketFrame> frames_;
98 void WebSocketChannel::SendBuffer::AddFrame(scoped_ptr<WebSocketFrame> frame) { in AddFrame()
415 scoped_ptr<WebSocketFrame> frame(read_frames_[i]); in OnReadDone()
449 ChannelState WebSocketChannel::ProcessFrame(scoped_ptr<WebSocketFrame> frame) { in ProcessFrame()
593 scoped_ptr<WebSocketFrame> frame(new WebSocketFrame(op_code)); in SendIOBuffer()
/external/chromium_org/third_party/WebKit/Source/core/inspector/
DInspectorResourceAgent.h70 struct WebSocketFrame;
126 void didReceiveWebSocketFrame(unsigned long identifier, const WebSocketFrame&);
127 void didSendWebSocketFrame(unsigned long identifier, const WebSocketFrame&);

12