Merge "Fix typo in parseint.untouched_on_failure test"
diff --git a/adb/client/line_printer.cpp b/adb/client/line_printer.cpp
index 9758526..4dc2d28 100644
--- a/adb/client/line_printer.cpp
+++ b/adb/client/line_printer.cpp
@@ -67,7 +67,11 @@
void LinePrinter::Print(string to_print, LineType type) {
if (!smart_terminal_) {
- Out(to_print + "\n");
+ if (type == LineType::INFO) {
+ info_line_ = to_print + "\n";
+ } else {
+ Out(to_print + "\n");
+ }
return;
}
@@ -123,6 +127,11 @@
}
void LinePrinter::KeepInfoLine() {
- if (!have_blank_line_) Out("\n");
- have_blank_line_ = true;
+ if (smart_terminal_) {
+ if (!have_blank_line_) Out("\n");
+ have_blank_line_ = true;
+ } else {
+ Out(info_line_);
+ info_line_.clear();
+ }
}
diff --git a/adb/client/line_printer.h b/adb/client/line_printer.h
index 42345e2..4c4c7c6 100644
--- a/adb/client/line_printer.h
+++ b/adb/client/line_printer.h
@@ -42,6 +42,9 @@
/// Whether the caret is at the beginning of a blank line.
bool have_blank_line_;
+ /// The last printed info line when printing to a dumb terminal.
+ std::string info_line_;
+
#ifdef _WIN32
void* console_;
#endif
diff --git a/adb/client/usb_windows.cpp b/adb/client/usb_windows.cpp
index e928377..00aeb9b 100644
--- a/adb/client/usb_windows.cpp
+++ b/adb/client/usb_windows.cpp
@@ -357,7 +357,8 @@
if (handle->zero_mask && (len & handle->zero_mask) == 0) {
// Send a zero length packet
- if (!AdbWriteEndpointSync(handle->adb_write_pipe, (void*)data, 0, &written, time_out)) {
+ unsigned long dummy;
+ if (!AdbWriteEndpointSync(handle->adb_write_pipe, (void*)data, 0, &dummy, time_out)) {
D("AdbWriteEndpointSync of zero length packet failed: %s",
android::base::SystemErrorCodeToString(GetLastError()).c_str());
err = EIO;
diff --git a/adb/test_device.py b/adb/test_device.py
index 42aadc4..20f224a 100644
--- a/adb/test_device.py
+++ b/adb/test_device.py
@@ -1302,6 +1302,37 @@
self.assertEqual(length, len(stdout) - 4)
self.assertEqual(stdout, "\0" * length + "foo\n")
+ def test_zero_packet(self):
+ """Test for http://b/113070258
+
+ Make sure that we don't blow up when sending USB transfers that line up
+ exactly with the USB packet size.
+ """
+
+ local_port = int(self.device.forward("tcp:0", "tcp:12345"))
+ try:
+ for size in [512, 1024]:
+ def listener():
+ cmd = ["echo foo | nc -l -p 12345; echo done"]
+ rc, stdout, stderr = self.device.shell_nocheck(cmd)
+
+ thread = threading.Thread(target=listener)
+ thread.start()
+
+ # Wait a bit to let the shell command start.
+ time.sleep(0.25)
+
+ sock = socket.create_connection(("localhost", local_port))
+ with contextlib.closing(sock):
+ bytesWritten = sock.send("a" * size)
+ self.assertEqual(size, bytesWritten)
+ readBytes = sock.recv(4096)
+ self.assertEqual("foo\n", readBytes)
+
+ thread.join()
+ finally:
+ self.device.forward_remove("tcp:{}".format(local_port))
+
def main():
random.seed(0)