| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/quic/quic_per_connection_packet_writer.h" | 5 #include "net/tools/quic/quic_simple_per_connection_packet_writer.h" |
| 6 | 6 |
| 7 #include "net/quic/quic_server_packet_writer.h" | 7 #include "net/tools/quic/quic_simple_server_packet_writer.h" |
| 8 | 8 |
| 9 namespace net { | 9 namespace net { |
| 10 namespace tools { |
| 10 | 11 |
| 11 QuicPerConnectionPacketWriter::QuicPerConnectionPacketWriter( | 12 QuicSimplePerConnectionPacketWriter::QuicSimplePerConnectionPacketWriter( |
| 12 QuicServerPacketWriter* shared_writer, | 13 QuicSimpleServerPacketWriter* shared_writer, |
| 13 QuicConnection* connection) | 14 QuicConnection* connection) |
| 14 : shared_writer_(shared_writer), | 15 : shared_writer_(shared_writer), |
| 15 connection_(connection), | 16 connection_(connection), |
| 16 weak_factory_(this){ | 17 weak_factory_(this){ |
| 17 } | 18 } |
| 18 | 19 |
| 19 QuicPerConnectionPacketWriter::~QuicPerConnectionPacketWriter() { | 20 QuicSimplePerConnectionPacketWriter::~QuicSimplePerConnectionPacketWriter() { |
| 20 } | 21 } |
| 21 | 22 |
| 22 QuicPacketWriter* QuicPerConnectionPacketWriter::shared_writer() const { | 23 QuicPacketWriter* QuicSimplePerConnectionPacketWriter::shared_writer() const { |
| 23 return shared_writer_; | 24 return shared_writer_; |
| 24 } | 25 } |
| 25 | 26 |
| 26 WriteResult QuicPerConnectionPacketWriter::WritePacket( | 27 WriteResult QuicSimplePerConnectionPacketWriter::WritePacket( |
| 27 const char* buffer, | 28 const char* buffer, |
| 28 size_t buf_len, | 29 size_t buf_len, |
| 29 const IPAddressNumber& self_address, | 30 const IPAddressNumber& self_address, |
| 30 const IPEndPoint& peer_address) { | 31 const IPEndPoint& peer_address) { |
| 31 return shared_writer_->WritePacketWithCallback( | 32 return shared_writer_->WritePacketWithCallback( |
| 32 buffer, | 33 buffer, |
| 33 buf_len, | 34 buf_len, |
| 34 self_address, | 35 self_address, |
| 35 peer_address, | 36 peer_address, |
| 36 base::Bind(&QuicPerConnectionPacketWriter::OnWriteComplete, | 37 base::Bind(&QuicSimplePerConnectionPacketWriter::OnWriteComplete, |
| 37 weak_factory_.GetWeakPtr())); | 38 weak_factory_.GetWeakPtr())); |
| 38 } | 39 } |
| 39 | 40 |
| 40 bool QuicPerConnectionPacketWriter::IsWriteBlockedDataBuffered() const { | 41 bool QuicSimplePerConnectionPacketWriter::IsWriteBlockedDataBuffered() const { |
| 41 return shared_writer_->IsWriteBlockedDataBuffered(); | 42 return shared_writer_->IsWriteBlockedDataBuffered(); |
| 42 } | 43 } |
| 43 | 44 |
| 44 bool QuicPerConnectionPacketWriter::IsWriteBlocked() const { | 45 bool QuicSimplePerConnectionPacketWriter::IsWriteBlocked() const { |
| 45 return shared_writer_->IsWriteBlocked(); | 46 return shared_writer_->IsWriteBlocked(); |
| 46 } | 47 } |
| 47 | 48 |
| 48 void QuicPerConnectionPacketWriter::SetWritable() { | 49 void QuicSimplePerConnectionPacketWriter::SetWritable() { |
| 49 shared_writer_->SetWritable(); | 50 shared_writer_->SetWritable(); |
| 50 } | 51 } |
| 51 | 52 |
| 52 void QuicPerConnectionPacketWriter::OnWriteComplete(WriteResult result) { | 53 void QuicSimplePerConnectionPacketWriter::OnWriteComplete(WriteResult result) { |
| 53 if (result.status == WRITE_STATUS_ERROR) { | 54 if (result.status == WRITE_STATUS_ERROR) { |
| 54 connection_->OnWriteError(result.error_code); | 55 connection_->OnWriteError(result.error_code); |
| 55 } | 56 } |
| 56 } | 57 } |
| 57 | 58 |
| 59 } // namespace tools |
| 58 } // namespace net | 60 } // namespace net |
| OLD | NEW |