Lines Matching refs:frame
124 scoped_ptr<WebSocketFrame> frame((*frames)[i]);
126 predictor_->RecordInputDataFrame(frame.get());
129 if (frame->header.final)
131 predictor_->RecordWrittenDataFrame(frame.get());
132 frames_to_write.push_back(frame.release());
135 if (frame->data.get() &&
136 !deflater_.AddBytes(frame->data->data(),
137 frame->header.payload_length)) {
142 if (frame->header.final && !deflater_.Finish()) {
150 frame->header.final) {
151 int result = AppendCompressedFrame(frame->header, &frames_to_write);
155 if (frame->header.final)
159 bool final = frame->header.final;
160 frames_of_message.push_back(frame.release());
179 WebSocketFrame* frame = frames[index];
180 current_writing_opcode_ = frame->header.opcode;
242 WebSocketFrame* frame = (*frames)[i];
244 DCHECK(WebSocketFrameHeader::IsKnownDataOpCode(frame->header.opcode));
247 frame->header.opcode);
248 DCHECK_EQ(i == frames->size() - 1, frame->header.final);
249 original_payload_length += frame->header.payload_length;
255 WebSocketFrame* frame = (*frames)[i];
256 frames_to_write->push_back(frame);
257 predictor_->RecordWrittenDataFrame(frame);
281 scoped_ptr<WebSocketFrame> frame(frames_passed[i]);
283 DVLOG(3) << "Input frame: opcode=" << frame->header.opcode
284 << " final=" << frame->header.final
285 << " reserved1=" << frame->header.reserved1
286 << " payload_length=" << frame->header.payload_length;
288 if (!WebSocketFrameHeader::IsKnownDataOpCode(frame->header.opcode)) {
289 frames_to_output.push_back(frame.release());
294 if (frame->header.reserved1)
298 current_reading_opcode_ = frame->header.opcode;
300 if (frame->header.reserved1) {
302 << "Receiving a non-first frame with RSV1 flag set.";
308 if (frame->header.final)
311 frames_to_output.push_back(frame.release());
314 if (frame->data.get() &&
315 !inflater_.AddBytes(frame->data->data(),
316 frame->header.payload_length)) {
321 if (frame->header.final) {
333 frame->header.final) {
338 bool is_final = !inflater_.CurrentOutputSize() && frame->header.final;
344 inflated->header.CopyFrom(frame->header);
350 DVLOG(3) << "Inflated frame: opcode=" << inflated->header.opcode
359 if (frame->header.final)
