| /external/chromium_org/net/websockets/ |
| websocket_deflate_predictor.h | 14 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;
|
| websocket_deflate_predictor_impl.h | 16 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;
|
| websocket_deflate_predictor_impl.cc | 12 const ScopedVector<WebSocketFrame>& frames,
18 const WebSocketFrame* frame) {}
21 const WebSocketFrame* frame) {}
|
| websocket_deflate_stream.h | 49 virtual int ReadFrames(ScopedVector<WebSocketFrame>* frames,
51 virtual int WriteFrames(ScopedVector<WebSocketFrame>* frames,
72 void OnReadComplete(ScopedVector<WebSocketFrame>* frames,
77 int Deflate(ScopedVector<WebSocketFrame>* frames);
78 void OnMessageStart(const ScopedVector<WebSocketFrame>& frames, size_t index);
80 ScopedVector<WebSocketFrame>* frames_to_write);
82 ScopedVector<WebSocketFrame>* frames,
83 ScopedVector<WebSocketFrame>* frames_to_write);
86 int Inflate(ScopedVector<WebSocketFrame>* frames);
88 int InflateAndReadIfNecessary(ScopedVector<WebSocketFrame>* frames
[all...] |
| websocket_deflate_predictor_impl_test.cc | 20 ScopedVector<WebSocketFrame> frames;
21 frames.push_back(new WebSocketFrame(WebSocketFrameHeader::kOpCodeText));
|
| websocket_basic_stream.h | 23 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,
|
| websocket_deflate_stream.cc | 58 int WebSocketDeflateStream::ReadFrames(ScopedVector<WebSocketFrame>* frames,
74 int WebSocketDeflateStream::WriteFrames(ScopedVector<WebSocketFrame>* frames,
95 ScopedVector<WebSocketFrame>* frames,
109 int WebSocketDeflateStream::Deflate(ScopedVector<WebSocketFrame>* frames) {
110 ScopedVector<WebSocketFrame> frames_to_write;
113 ScopedVector<WebSocketFrame> frames_of_message;
124 scoped_ptr<WebSocketFrame> frame((*frames)[i]);
177 const ScopedVector<WebSocketFrame>& frames, size_t index) {
178 WebSocketFrame* frame = frames[index];
201 ScopedVector<WebSocketFrame>* frames_to_write)
[all...] |
| websocket_deflate_stream_test.cc | 70 std::string ToString(const WebSocketFrame* frame) {
74 void AppendTo(ScopedVector<WebSocketFrame>* frames,
78 scoped_ptr<WebSocketFrame> frame(new WebSocketFrame(opcode));
86 void AppendTo(ScopedVector<WebSocketFrame>* frames,
89 scoped_ptr<WebSocketFrame> frame(new WebSocketFrame(opcode));
97 MOCK_METHOD2(ReadFrames, int(ScopedVector<WebSocketFrame>*,
99 MOCK_METHOD2(WriteFrames, int(ScopedVector<WebSocketFrame>*,
126 virtual Result Predict(const ScopedVector<WebSocketFrame>& frames
[all...] |
| websocket_frame.h | 95 struct NET_EXPORT_PRIVATE WebSocketFrame {
97 explicit WebSocketFrame(WebSocketFrameHeader::OpCode opcode);
98 ~WebSocketFrame();
117 // boundaries and can use the WebSocketFrame type declared above.
|
| websocket_stream.h | 31 struct WebSocketFrame;
155 virtual int ReadFrames(ScopedVector<WebSocketFrame>* frames,
172 virtual int WriteFrames(ScopedVector<WebSocketFrame>* frames,
|
| websocket_basic_stream.cc | 43 typedef ScopedVector<WebSocketFrame>::const_iterator WebSocketFrameIterator;
49 ScopedVector<WebSocketFrame>* frames) {
54 WebSocketFrame* frame = *it;
89 int WebSocketBasicStream::ReadFrames(ScopedVector<WebSocketFrame>* frames,
135 int WebSocketBasicStream::WriteFrames(ScopedVector<WebSocketFrame>* frames,
149 WebSocketFrame* frame = *it;
240 ScopedVector<WebSocketFrame>* frames) {
257 ScopedVector<WebSocketFrame>* frames) {
259 scoped_ptr<WebSocketFrame> frame;
278 scoped_ptr<WebSocketFrame>* frame)
[all...] |
| websocket_frame.cc | 60 WebSocketFrame::WebSocketFrame(WebSocketFrameHeader::OpCode opcode)
63 WebSocketFrame::~WebSocketFrame() {}
|
| /external/chromium_org/third_party/WebKit/Source/modules/websockets/ |
| WebSocketPerMessageDeflateTest.cpp | 49 WebSocketFrame::OpCode opcode = WebSocketFrame::OpCodeText;
50 WebSocketFrame f1(opcode, "Hello", 5, WebSocketFrame::Final);
51 WebSocketFrame f2(opcode, "Hello", 5, WebSocketFrame::Final);
71 WebSocketFrame::OpCode opcode = WebSocketFrame::OpCodeText;
72 WebSocketFrame f1(opcode, "Hello", 5, WebSocketFrame::Final)
[all...] |
| WebSocketPerMessageDeflate.h | 36 #include "modules/websockets/WebSocketFrame.h"
59 bool deflate(WebSocketFrame&);
71 bool inflate(WebSocketFrame&);
|
| WebSocketFrame.h | 38 struct WebSocketFrame {
60 static ParseFrameResult parseFrame(char* data, size_t dataLength, WebSocketFrame&, const char*& frameEnd, String& errorString); // May modify part of data to unmask the frame.
74 WebSocketFrame();
76 WebSocketFrame(OpCode, const char* payload, size_t payloadLength, Flags = EmptyFlags);
|
| MainThreadWebSocketChannel.h | 39 #include "modules/websockets/WebSocketFrame.h"
105 FramingOverhead(WebSocketFrame::OpCode opcode, size_t frameDataSize, size_t originalPayloadLength)
112 WebSocketFrame::OpCode opcode() const { return m_opcode; }
117 WebSocketFrame::OpCode m_opcode;
156 WebSocketFrame::OpCode opCode;
164 void enqueueRawFrame(WebSocketFrame::OpCode, const char* data, size_t dataLength);
165 void enqueueVector(WebSocketFrame::OpCode, PassOwnPtr<Vector<char> >);
166 void enqueueBlobFrame(WebSocketFrame::OpCode, PassRefPtr<BlobDataHandle>);
187 bool sendFrame(WebSocketFrame::OpCode, const char* data, size_t dataLength);
222 WebSocketFrame::OpCode m_continuousFrameOpCode
[all...] |
| WebSocketFrame.cpp | 25 #include "modules/websockets/WebSocketFrame.h"
36 // Do not mistake these constants for the flags given to the WebSocketFrame constructor.
49 bool WebSocketFrame::needsExtendedLengthField(size_t payloadLength)
54 WebSocketFrame::ParseFrameResult WebSocketFrame::parseFrame(char* data, size_t dataLength, WebSocketFrame& frame, const char*& frameEnd, String& errorString)
116 frame.opCode = static_cast<WebSocketFrame::OpCode>(opCode);
128 static void appendFramePayload(const WebSocketFrame& frame, Vector<char>& frameData)
146 void WebSocketFrame::makeFrameData(Vector<char>& frameData)
176 WebSocketFrame::WebSocketFrame(
[all...] |
| WebSocketPerMessageDeflate.cpp | 172 bool WebSocketPerMessageDeflate::deflate(WebSocketFrame& frame)
180 if (!WebSocketFrame::isNonControlOpCode(frame.opCode))
183 if ((frame.opCode == WebSocketFrame::OpCodeText || frame.opCode == WebSocketFrame::OpCodeBinary)
217 bool WebSocketPerMessageDeflate::inflate(WebSocketFrame& frame)
221 if (!WebSocketFrame::isNonControlOpCode(frame.opCode)) {
|
| MainThreadWebSocketChannel.cpp | 142 enqueueRawFrame(WebSocketFrame::OpCodeBinary, static_cast<const char*>(binaryData.data()) + byteOffset, byteLength);
150 enqueueBlobFrame(WebSocketFrame::OpCodeBinary, binaryData);
158 enqueueVector(WebSocketFrame::OpCodeBinary, data);
346 if (m_client && WebSocketFrame::isNonControlOpCode(frame.opcode())) {
525 enqueueRawFrame(WebSocketFrame::OpCodeClose, buf.data(), buf.size());
545 WebSocketFrame frame;
548 WebSocketFrame::ParseFrameResult result = WebSocketFrame::parseFrame(m_buffer.data(), m_buffer.size(), frame, frameEnd, errorString);
549 if (result == WebSocketFrame::FrameIncomplete)
551 if (result == WebSocketFrame::FrameError)
[all...] |
| WebSocketDeflateFramer.h | 36 #include "modules/websockets/WebSocketFrame.h"
98 PassOwnPtr<DeflateResultHolder> deflate(WebSocketFrame&);
100 PassOwnPtr<InflateResultHolder> inflate(WebSocketFrame&);
|
| WebSocketDeflateFramer.cpp | 174 PassOwnPtr<DeflateResultHolder> WebSocketDeflateFramer::deflate(WebSocketFrame& frame)
177 if (!enabled() || !WebSocketFrame::isNonControlOpCode(frame.opCode) || !frame.payloadLength)
195 PassOwnPtr<InflateResultHolder> WebSocketDeflateFramer::inflate(WebSocketFrame& frame)
202 if (!WebSocketFrame::isNonControlOpCode(frame.opCode)) {
|
| /external/nanohttpd/websocket/src/main/java/fi/iki/elonen/samples/echo/ |
| DebugWebSocket.java | 5 import fi.iki.elonen.WebSocketFrame;
22 protected void onPong(WebSocketFrame pongFrame) {
29 protected void onMessage(WebSocketFrame messageFrame) {
39 protected void onClose(WebSocketFrame.CloseCode code, String reason, boolean initiatedByRemote) {
53 protected void handleWebsocketFrame(WebSocketFrame frame) throws IOException {
61 public synchronized void sendFrame(WebSocketFrame frame) throws IOException {
|
| /external/nanohttpd/websocket/src/main/java/fi/iki/elonen/ |
| WebSocket.java | 3 import fi.iki.elonen.WebSocketFrame.CloseCode;
4 import fi.iki.elonen.WebSocketFrame.CloseFrame;
5 import fi.iki.elonen.WebSocketFrame.OpCode;
23 protected WebSocketFrame.OpCode continuousOpCode = null;
25 protected List<WebSocketFrame> continuousFrames = new LinkedList<WebSocketFrame>();
66 handleWebsocketFrame(WebSocketFrame.read(in));
81 protected void handleWebsocketFrame(WebSocketFrame frame) throws IOException {
85 sendFrame(new WebSocketFrame(OpCode.Pong, true, frame.getBinaryPayload()));
99 protected void handleCloseFrame(WebSocketFrame frame) throws IOException
[all...] |
| WebSocketFrame.java | 16 public class WebSocketFrame {
26 private WebSocketFrame(OpCode opCode, boolean fin) {
31 public WebSocketFrame(OpCode opCode, boolean fin, byte[] payload, byte[] maskingKey) {
37 public WebSocketFrame(OpCode opCode, boolean fin, byte[] payload) {
41 public WebSocketFrame(OpCode opCode, boolean fin, String payload, byte[] maskingKey) throws CharacterCodingException {
47 public WebSocketFrame(OpCode opCode, boolean fin, String payload) throws CharacterCodingException {
51 public WebSocketFrame(WebSocketFrame clone) {
58 public WebSocketFrame(OpCode opCode, List<WebSocketFrame> fragments) throws WebSocketException
[all...] |
| WebSocketException.java | 3 import fi.iki.elonen.WebSocketFrame.CloseCode;
|
