Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(510)

Side by Side Diff: device/usb/usb_device_handle_unittest.cc

Issue 543893002: Random fixes through Chrome for scoped_reftpr T* removal. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 6 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 "base/bind.h" 5 #include "base/bind.h"
6 #include "base/message_loop/message_loop.h" 6 #include "base/message_loop/message_loop.h"
7 #include "base/run_loop.h" 7 #include "base/run_loop.h"
8 #include "base/strings/utf_string_conversions.h" 8 #include "base/strings/utf_string_conversions.h"
9 #include "device/test/usb_test_gadget.h" 9 #include "device/test/usb_test_gadget.h"
10 #include "device/usb/usb_device.h" 10 #include "device/usb/usb_device.h"
(...skipping 12 matching lines...) Expand all
23 } 23 }
24 24
25 message_loop_.reset(new base::MessageLoopForIO); 25 message_loop_.reset(new base::MessageLoopForIO);
26 26
27 gadget_ = UsbTestGadget::Claim(); 27 gadget_ = UsbTestGadget::Claim();
28 ASSERT_TRUE(gadget_.get()); 28 ASSERT_TRUE(gadget_.get());
29 29
30 ASSERT_TRUE(gadget_->SetType(UsbTestGadget::ECHO)); 30 ASSERT_TRUE(gadget_->SetType(UsbTestGadget::ECHO));
31 31
32 handle_ = gadget_->GetDevice()->Open(); 32 handle_ = gadget_->GetDevice()->Open();
33 ASSERT_TRUE(handle_); 33 ASSERT_TRUE(handle_.get());
34 } 34 }
35 35
36 virtual void TearDown() { 36 virtual void TearDown() {
37 if (handle_) { 37 if (handle_.get()) {
38 handle_->Close(); 38 handle_->Close();
39 } 39 }
40 gadget_.reset(NULL); 40 gadget_.reset(NULL);
41 message_loop_.reset(NULL); 41 message_loop_.reset(NULL);
42 } 42 }
43 43
44 protected: 44 protected:
45 scoped_refptr<UsbDeviceHandle> handle_; 45 scoped_refptr<UsbDeviceHandle> handle_;
46 46
47 private: 47 private:
(...skipping 22 matching lines...) Expand all
70 size_t transferred() const { return transferred_; } 70 size_t transferred() const { return transferred_; }
71 71
72 private: 72 private:
73 const UsbTransferCallback callback_; 73 const UsbTransferCallback callback_;
74 base::RunLoop run_loop_; 74 base::RunLoop run_loop_;
75 UsbTransferStatus status_; 75 UsbTransferStatus status_;
76 size_t transferred_; 76 size_t transferred_;
77 }; 77 };
78 78
79 TEST_F(UsbDeviceHandleTest, InterruptTransfer) { 79 TEST_F(UsbDeviceHandleTest, InterruptTransfer) {
80 if (!handle_) { 80 if (!handle_.get()) {
81 return; 81 return;
82 } 82 }
83 83
84 scoped_refptr<net::IOBufferWithSize> in_buffer(new net::IOBufferWithSize(64)); 84 scoped_refptr<net::IOBufferWithSize> in_buffer(new net::IOBufferWithSize(64));
85 TestCompletionCallback in_completion; 85 TestCompletionCallback in_completion;
86 handle_->InterruptTransfer(USB_DIRECTION_INBOUND, 86 handle_->InterruptTransfer(USB_DIRECTION_INBOUND,
87 0x81, 87 0x81,
88 in_buffer, 88 in_buffer.get(),
89 in_buffer->size(), 89 in_buffer->size(),
90 5000, // 5 second timeout 90 5000, // 5 second timeout
91 in_completion.callback()); 91 in_completion.callback());
92 92
93 scoped_refptr<net::IOBufferWithSize> out_buffer( 93 scoped_refptr<net::IOBufferWithSize> out_buffer(
94 new net::IOBufferWithSize(in_buffer->size())); 94 new net::IOBufferWithSize(in_buffer->size()));
95 TestCompletionCallback out_completion; 95 TestCompletionCallback out_completion;
96 for (int i = 0; i < out_buffer->size(); ++i) { 96 for (int i = 0; i < out_buffer->size(); ++i) {
97 out_buffer->data()[i] = i; 97 out_buffer->data()[i] = i;
98 } 98 }
99 99
100 handle_->InterruptTransfer(USB_DIRECTION_OUTBOUND, 100 handle_->InterruptTransfer(USB_DIRECTION_OUTBOUND,
101 0x01, 101 0x01,
102 out_buffer, 102 out_buffer.get(),
103 out_buffer->size(), 103 out_buffer->size(),
104 5000, // 5 second timeout 104 5000, // 5 second timeout
105 out_completion.callback()); 105 out_completion.callback());
106 out_completion.WaitForResult(); 106 out_completion.WaitForResult();
107 ASSERT_EQ(USB_TRANSFER_COMPLETED, out_completion.status()); 107 ASSERT_EQ(USB_TRANSFER_COMPLETED, out_completion.status());
108 ASSERT_EQ(static_cast<size_t>(out_buffer->size()), 108 ASSERT_EQ(static_cast<size_t>(out_buffer->size()),
109 out_completion.transferred()); 109 out_completion.transferred());
110 110
111 in_completion.WaitForResult(); 111 in_completion.WaitForResult();
112 ASSERT_EQ(USB_TRANSFER_COMPLETED, in_completion.status()); 112 ASSERT_EQ(USB_TRANSFER_COMPLETED, in_completion.status());
113 ASSERT_EQ(static_cast<size_t>(in_buffer->size()), 113 ASSERT_EQ(static_cast<size_t>(in_buffer->size()),
114 in_completion.transferred()); 114 in_completion.transferred());
115 for (int i = 0; i < in_buffer->size(); ++i) { 115 for (int i = 0; i < in_buffer->size(); ++i) {
116 ASSERT_EQ(out_buffer->data()[i], in_buffer->data()[i]); 116 ASSERT_EQ(out_buffer->data()[i], in_buffer->data()[i]);
117 } 117 }
118 } 118 }
119 119
120 TEST_F(UsbDeviceHandleTest, BulkTransfer) { 120 TEST_F(UsbDeviceHandleTest, BulkTransfer) {
121 if (!handle_) { 121 if (!handle_.get()) {
122 return; 122 return;
123 } 123 }
124 124
125 scoped_refptr<net::IOBufferWithSize> in_buffer( 125 scoped_refptr<net::IOBufferWithSize> in_buffer(
126 new net::IOBufferWithSize(512)); 126 new net::IOBufferWithSize(512));
127 TestCompletionCallback in_completion; 127 TestCompletionCallback in_completion;
128 handle_->BulkTransfer(USB_DIRECTION_INBOUND, 128 handle_->BulkTransfer(USB_DIRECTION_INBOUND,
129 0x81, 129 0x81,
130 in_buffer, 130 in_buffer.get(),
131 in_buffer->size(), 131 in_buffer->size(),
132 5000, // 5 second timeout 132 5000, // 5 second timeout
133 in_completion.callback()); 133 in_completion.callback());
134 134
135 scoped_refptr<net::IOBufferWithSize> out_buffer( 135 scoped_refptr<net::IOBufferWithSize> out_buffer(
136 new net::IOBufferWithSize(in_buffer->size())); 136 new net::IOBufferWithSize(in_buffer->size()));
137 TestCompletionCallback out_completion; 137 TestCompletionCallback out_completion;
138 for (int i = 0; i < out_buffer->size(); ++i) { 138 for (int i = 0; i < out_buffer->size(); ++i) {
139 out_buffer->data()[i] = i; 139 out_buffer->data()[i] = i;
140 } 140 }
141 141
142 handle_->BulkTransfer(USB_DIRECTION_OUTBOUND, 142 handle_->BulkTransfer(USB_DIRECTION_OUTBOUND,
143 0x01, 143 0x01,
144 out_buffer, 144 out_buffer.get(),
145 out_buffer->size(), 145 out_buffer->size(),
146 5000, // 5 second timeout 146 5000, // 5 second timeout
147 out_completion.callback()); 147 out_completion.callback());
148 out_completion.WaitForResult(); 148 out_completion.WaitForResult();
149 ASSERT_EQ(USB_TRANSFER_COMPLETED, out_completion.status()); 149 ASSERT_EQ(USB_TRANSFER_COMPLETED, out_completion.status());
150 ASSERT_EQ(static_cast<size_t>(out_buffer->size()), 150 ASSERT_EQ(static_cast<size_t>(out_buffer->size()),
151 out_completion.transferred()); 151 out_completion.transferred());
152 152
153 in_completion.WaitForResult(); 153 in_completion.WaitForResult();
154 ASSERT_EQ(USB_TRANSFER_COMPLETED, in_completion.status()); 154 ASSERT_EQ(USB_TRANSFER_COMPLETED, in_completion.status());
155 ASSERT_EQ(static_cast<size_t>(in_buffer->size()), 155 ASSERT_EQ(static_cast<size_t>(in_buffer->size()),
156 in_completion.transferred()); 156 in_completion.transferred());
157 for (int i = 0; i < in_buffer->size(); ++i) { 157 for (int i = 0; i < in_buffer->size(); ++i) {
158 ASSERT_EQ(out_buffer->data()[i], in_buffer->data()[i]); 158 ASSERT_EQ(out_buffer->data()[i], in_buffer->data()[i]);
159 } 159 }
160 } 160 }
161 161
162 } // namespace 162 } // namespace
163 163
164 } // namespace device 164 } // namespace device
OLDNEW
« no previous file with comments | « components/variations/variations_seed_processor.cc ('k') | gpu/command_buffer/service/in_process_command_buffer.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698