Cross Reference: /external/chromium_org/net/websockets/websocket_deflate

Lines Matching refs:frames
58 int WebSocketDeflateStream::ReadFrames(ScopedVector<WebSocketFrame>* frames,
61       frames,
64                  base::Unretained(frames),
69   DCHECK(!frames->empty());
71   return InflateAndReadIfNecessary(frames, callback);
74 int WebSocketDeflateStream::WriteFrames(ScopedVector<WebSocketFrame>* frames,
76   int result = Deflate(frames);
79   if (frames->empty())
81   return stream_->WriteFrames(frames, callback);
95     ScopedVector<WebSocketFrame>* frames,
99     frames->clear();
104   int r = InflateAndReadIfNecessary(frames, callback);
109 int WebSocketDeflateStream::Deflate(ScopedVector<WebSocketFrame>* frames) {
111   // Store frames of the currently processed message if writing_state_ equals to
114   for (size_t i = 0; i < frames->size(); ++i) {
115     DCHECK(!(*frames)[i]->header.reserved1);
116     if (!WebSocketFrameHeader::IsKnownDataOpCode((*frames)[i]->header.opcode)) {
117       frames_to_write.push_back((*frames)[i]);
118       (*frames)[i] = NULL;
122       OnMessageStart(*frames, i);
124     scoped_ptr<WebSocketFrame> frame((*frames)[i]);
125     (*frames)[i] = NULL;
173   frames->swap(frames_to_write);
178     const ScopedVector<WebSocketFrame>& frames, size_t index) {
179   WebSocketFrame* frame = frames[index];
184       predictor_->Predict(frames, index);
227     ScopedVector<WebSocketFrame>* frames,
229   DCHECK(!frames->empty());
241   for (size_t i = 0; i < frames->size(); ++i) {
242     WebSocketFrame* frame = (*frames)[i];
243     // Asserts checking that frames represent one whole data message.
248     DCHECK_EQ(i == frames->size() - 1, frame->header.final);
253     // Compression is not effective. Use the original frames.
254     for (size_t i = 0; i < frames->size(); ++i) {
255       WebSocketFrame* frame = (*frames)[i];
258       (*frames)[i] = NULL;
260     frames->weak_clear();
264   compressed->header.CopyFrom((*frames)[0]->header);
276 int WebSocketDeflateStream::Inflate(ScopedVector<WebSocketFrame>* frames) {
279   frames->swap(frames_passed);
328       // TODO(yhirano): Many frames can be generated by the inflater and
363   frames->swap(frames_to_output);
364   return frames->empty() ? ERR_IO_PENDING : OK;
368     ScopedVector<WebSocketFrame>* frames,
370   int result = Inflate(frames);
372     DCHECK(frames->empty());
375         frames,
378                    base::Unretained(frames),
383     DCHECK(!frames->empty());
385     result = Inflate(frames);
388     frames->clear();