| Index: chrome/browser/devtools/device/usb/android_usb_device.cc
|
| diff --git a/chrome/browser/devtools/device/usb/android_usb_device.cc b/chrome/browser/devtools/device/usb/android_usb_device.cc
|
| index 0d6c2bdb84c9d46d0e5b338050b3e5d1dd358cfc..fd40fadec07c42c22ec33f83f23d62f1a2c467c0 100644
|
| --- a/chrome/browser/devtools/device/usb/android_usb_device.cc
|
| +++ b/chrome/browser/devtools/device/usb/android_usb_device.cc
|
| @@ -400,20 +400,22 @@ void AndroidUsbDevice::Queue(scoped_refptr<AdbMessage> message) {
|
| header.push_back(body_length);
|
| header.push_back(Checksum(message->body));
|
| header.push_back(message->command ^ 0xffffffff);
|
| - scoped_refptr<net::IOBuffer> header_buffer = new net::IOBuffer(kHeaderSize);
|
| + scoped_refptr<net::IOBufferWithSize> header_buffer =
|
| + new net::IOBufferWithSize(kHeaderSize);
|
| memcpy(header_buffer.get()->data(), &header[0], kHeaderSize);
|
| - outgoing_queue_.push(std::make_pair(header_buffer, kHeaderSize));
|
| + outgoing_queue_.push(header_buffer);
|
|
|
| // Queue body.
|
| if (!message->body.empty()) {
|
| - scoped_refptr<net::IOBuffer> body_buffer = new net::IOBuffer(body_length);
|
| + scoped_refptr<net::IOBufferWithSize> body_buffer =
|
| + new net::IOBufferWithSize(body_length);
|
| memcpy(body_buffer->data(), message->body.data(), message->body.length());
|
| if (append_zero)
|
| body_buffer->data()[body_length - 1] = 0;
|
| - outgoing_queue_.push(std::make_pair(body_buffer, body_length));
|
| + outgoing_queue_.push(body_buffer);
|
| if (zero_mask_ && (body_length & zero_mask_) == 0) {
|
| // Send a zero length packet.
|
| - outgoing_queue_.push(std::make_pair(body_buffer, 0));
|
| + outgoing_queue_.push(new net::IOBufferWithSize(0));
|
| }
|
| }
|
| ProcessOutgoing();
|
| @@ -427,10 +429,10 @@ void AndroidUsbDevice::ProcessOutgoing() {
|
|
|
| BulkMessage message = outgoing_queue_.front();
|
| outgoing_queue_.pop();
|
| - DumpMessage(true, message.first->data(), message.second);
|
| + DumpMessage(true, message->data(), message->size());
|
| usb_handle_->BulkTransfer(
|
| usb_service::USB_DIRECTION_OUTBOUND, outbound_address_,
|
| - message.first, message.second, kUsbTimeout,
|
| + message, message->size(), kUsbTimeout,
|
| base::Bind(&AndroidUsbDevice::OutgoingMessageSent,
|
| weak_factory_.GetWeakPtr()));
|
| }
|
|
|