| 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 "extensions/browser/api/cast_channel/cast_transport.h" | 5 #include "extensions/browser/api/cast_channel/cast_transport.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/format_macros.h" | 10 #include "base/format_macros.h" |
| (...skipping 14 matching lines...) Expand all Loading... |
| 25 namespace core_api { | 25 namespace core_api { |
| 26 namespace cast_channel { | 26 namespace cast_channel { |
| 27 | 27 |
| 28 CastTransport::CastTransport(CastSocketInterface* socket, | 28 CastTransport::CastTransport(CastSocketInterface* socket, |
| 29 Delegate* read_delegate, | 29 Delegate* read_delegate, |
| 30 scoped_refptr<Logger> logger) | 30 scoped_refptr<Logger> logger) |
| 31 : socket_(socket), | 31 : socket_(socket), |
| 32 read_delegate_(read_delegate), | 32 read_delegate_(read_delegate), |
| 33 write_state_(WRITE_STATE_NONE), | 33 write_state_(WRITE_STATE_NONE), |
| 34 read_state_(READ_STATE_NONE), | 34 read_state_(READ_STATE_NONE), |
| 35 error_state_(CHANNEL_ERROR_NONE), |
| 35 logger_(logger) { | 36 logger_(logger) { |
| 36 DCHECK(socket); | 37 DCHECK(socket); |
| 37 DCHECK(read_delegate); | 38 DCHECK(read_delegate); |
| 38 | 39 |
| 39 // Buffer is reused across messages to minimize unnecessary buffer | 40 // Buffer is reused across messages to minimize unnecessary buffer |
| 40 // [re]allocations. | 41 // [re]allocations. |
| 41 read_buffer_ = new net::GrowableIOBuffer(); | 42 read_buffer_ = new net::GrowableIOBuffer(); |
| 42 read_buffer_->SetCapacity(MessageFramer::MessageHeader::max_message_size()); | 43 read_buffer_->SetCapacity(MessageFramer::MessageHeader::max_message_size()); |
| 43 framer_.reset(new MessageFramer(read_buffer_)); | 44 framer_.reset(new MessageFramer(read_buffer_)); |
| 44 } | 45 } |
| (...skipping 392 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 437 int CastTransport::DoReadError(int result) { | 438 int CastTransport::DoReadError(int result) { |
| 438 VLOG_WITH_CONNECTION(2) << "DoReadError"; | 439 VLOG_WITH_CONNECTION(2) << "DoReadError"; |
| 439 DCHECK_NE(CHANNEL_ERROR_NONE, error_state_); | 440 DCHECK_NE(CHANNEL_ERROR_NONE, error_state_); |
| 440 DCHECK_LE(result, 0); | 441 DCHECK_LE(result, 0); |
| 441 return net::ERR_FAILED; | 442 return net::ERR_FAILED; |
| 442 } | 443 } |
| 443 | 444 |
| 444 } // namespace cast_channel | 445 } // namespace cast_channel |
| 445 } // namespace core_api | 446 } // namespace core_api |
| 446 } // namespace extensions | 447 } // namespace extensions |
| OLD | NEW |