Lines Matching full:writer
250 // Note that we may not use every byte of the writer in this case.
290 QuicDataWriter writer(packet_size);
293 if (!AppendPacketHeader(header, &writer)) {
301 if (!AppendTypeByte(frame, last_frame_in_packet, &writer)) {
307 writer.WritePadding();
311 *frame.stream_frame, last_frame_in_packet, &writer)) {
317 header, *frame.ack_frame, &writer)) {
323 *frame.congestion_feedback_frame, &writer)) {
328 if (!AppendRstStreamFramePayload(*frame.rst_stream_frame, &writer)) {
334 *frame.connection_close_frame, &writer)) {
339 if (!AppendGoAwayFramePayload(*frame.goaway_frame, &writer)) {
350 const size_t len = writer.length();
355 writer.take(), len, true, header.public_header.guid_length,
376 QuicDataWriter writer(len);
379 if (!AppendPacketHeader(header, &writer)) {
383 if (!writer.WriteBytes(fec.redundancy.data(), fec.redundancy.length())) {
390 QuicPacket::NewFecPacket(writer.take(), len, true,
402 QuicDataWriter writer(len);
407 if (!writer.WriteUInt8(flags)) {
411 if (!writer.WriteUInt64(packet.public_header.guid)) {
415 if (!writer.WriteUInt64(packet.nonce_proof)) {
421 &writer)) {
425 return new QuicEncryptedPacket(writer.take(), len, true);
433 QuicDataWriter writer(len);
438 if (!writer.WriteUInt8(flags)) {
442 if (!writer.WriteUInt64(header.guid)) {
447 if (!writer.WriteUInt32(QuicVersionToQuicTag(supported_versions[i]))) {
452 return new QuicEncryptedPacket(writer.take(), len, true);
595 QuicDataWriter* writer) {
611 if (!writer->WriteUInt8(public_flags | PACKET_PUBLIC_FLAGS_0BYTE_GUID)) {
616 if (!writer->WriteUInt8(public_flags | PACKET_PUBLIC_FLAGS_1BYTE_GUID)) {
619 if (!writer->WriteUInt8(header.public_header.guid & k1ByteGuidMask)) {
624 if (!writer->WriteUInt8(public_flags | PACKET_PUBLIC_FLAGS_4BYTE_GUID)) {
627 if (!writer->WriteUInt32(header.public_header.guid & k4ByteGuidMask)) {
632 if (!writer->WriteUInt8(public_flags | PACKET_PUBLIC_FLAGS_8BYTE_GUID)) {
635 if (!writer->WriteUInt64(header.public_header.guid)) {
644 writer->WriteUInt32(QuicVersionToQuicTag(quic_version_));
648 header.packet_sequence_number, writer)) {
662 if (!writer->WriteUInt8(private_flags)) {
675 if (!writer->WriteBytes(&first_fec_protected_packet_offset, 1)) {
1674 QuicDataWriter* writer) {
1713 return writer->WriteUInt8(type_byte);
1720 QuicDataWriter* writer) {
1722 if (writer->capacity() - writer->length() <
1728 return writer->WriteUInt8(
1732 return writer->WriteUInt16(
1736 return writer->WriteUInt32(
1740 return writer->WriteUInt48(
1752 QuicDataWriter* writer) {
1753 if (!writer->WriteBytes(&frame.stream_id, GetStreamIdSize(frame.stream_id))) {
1756 if (!writer->WriteBytes(&frame.offset, GetStreamOffsetSize(frame.offset))) {
1760 if (!writer->WriteUInt16(frame.data.TotalBufferSize())) {
1765 if (!writer->WriteIOVector(frame.data)) {
1803 QuicDataWriter* writer) {
1812 size_t available_range_bytes = writer->capacity() - writer->length() -
1844 if (!writer->WriteUInt8(type_byte)) {
1850 if (!writer->WriteUInt8(frame.sent_info.entropy_hash)) {
1858 least_unacked_delta, writer)) {
1881 if (!writer->WriteUInt8(ack_entropy_hash)) {
1886 ack_largest_observed, writer)) {
1898 if (!writer->WriteUFloat16(delta_time_largest_observed_us)) {
1908 if (!writer->WriteBytes(&num_missing_ranges, 1)) {
1919 missing_delta, writer)) {
1923 ack_iter->second, writer)) {
1937 QuicDataWriter* writer) {
1938 if (!writer->WriteBytes(&frame.type, 1)) {
1946 if (!writer->WriteUInt16(
1959 if (!writer->WriteBytes(&num_received_packets, 1)) {
1968 lowest_sequence, writer)) {
1973 if (!writer->WriteUInt64(
1984 if (!writer->WriteUInt16(static_cast<uint16>(sequence_delta))) {
1990 if (!writer->WriteBytes(&time_delta_us, sizeof(time_delta_us))) {
2000 if (!writer->WriteUInt32(fix_rate.bitrate.ToBytesPerSecond())) {
2010 if (!writer->WriteUInt16(tcp.accumulated_number_of_lost_packets)) {
2013 if (!writer->WriteUInt16(receive_window)) {
2027 QuicDataWriter* writer) {
2028 if (!writer->WriteUInt32(frame.stream_id)) {
2033 if (!writer->WriteUInt32(error_code)) {
2037 if (!writer->WriteStringPiece16(frame.error_details)) {
2045 QuicDataWriter* writer) {
2047 if (!writer->WriteUInt32(error_code)) {
2050 if (!writer->WriteStringPiece16(frame.error_details)) {
2057 QuicDataWriter* writer) {
2059 if (!writer->WriteUInt32(error_code)) {
2063 if (!writer->WriteUInt32(stream_id)) {
2066 if (!writer->WriteStringPiece16(frame.reason_phrase)) {
