Added test_long_write.

Author: DavidEGrayson

manual_tests/CMakeLists.txt

@@ -1,3 +1,4 @@
 add_subdirectory(test_async_in)
 add_subdirectory(test_long_read)
+add_subdirectory(test_long_write)
 add_subdirectory(test_transitions)

manual_tests/test_long_read/test_long_read.cpp

@@ -20,6 +20,7 @@ void long_read(libusbp::generic_handle & handle)
     size_t transferred;
 
     printf("Reading %d bytes...\n", (unsigned int)transfer_size);
+    fflush(stdout);
     handle.read_pipe(endpoint_address, buffer, sizeof(buffer), &transferred);
     if (transferred == transfer_size)
     {
@@ -30,6 +31,7 @@ void long_read(libusbp::generic_handle & handle)
         printf("Transferred only %d bytes out of %d.\n",
             (unsigned int)transferred, (unsigned int)transfer_size);
     }
+    fflush(stdout);
 }
 
 void long_control_read(libusbp::generic_handle & handle)
@@ -38,6 +40,7 @@ void long_control_read(libusbp::generic_handle & handle)
     size_t transferred;
 
     printf("Performing a slow control read...\n");
+    fflush(stdout);
     handle.control_transfer(0xC0, 0x91, 10000, 5, buffer, sizeof(buffer), &transferred);
     if (transferred == 5)
     {
@@ -48,6 +51,7 @@ void long_control_read(libusbp::generic_handle & handle)
         printf("Transferred only %d bytes out of %d.\n",
             (unsigned int)transferred, (unsigned int)sizeof(buffer));
     }
+    fflush(stdout);
 }
 
 int main_with_exceptions()

manual_tests/test_long_write/CMakeLists.txt

@@ -0,0 +1,9 @@
+use_cxx11()
+
+add_executable(test_long_write test_long_write.cpp)
+
+include_directories (
+  "${CMAKE_SOURCE_DIR}/include"
+)
+
+target_link_libraries(test_long_write usbp)

manual_tests/test_long_write/test_long_write.cpp

@@ -0,0 +1,70 @@
+/* Tests what happens if we do a synchronous write that takes a long time to
+ * complete.  This can be used to check that pressing Ctrl+C is able to
+ * interrupt the write. */
+
+#include <libusbp.hpp>
+#include <stdio.h>
+#include <iostream>
+
+const uint16_t vendor_id = 0x1FFB;
+const uint16_t product_id = 0xDA01;
+const uint8_t interface_number = 0;
+const bool composite = true;
+const uint8_t endpoint_address = 0x03;
+const size_t packet_size = 32;
+const size_t transfer_size = packet_size * 4;
+
+void long_write(libusbp::generic_handle & handle)
+{
+    // First packet causes a delay of 4 seconds (0x0FA0 ms)
+    uint8_t buffer[transfer_size] = { 0xDE, 0xA0, 0x0F };
+    size_t transferred;
+
+    printf("Writing...\n");
+    fflush(stdout);
+    handle.write_pipe(endpoint_address, buffer, sizeof(buffer), &transferred);
+    if (transferred == transfer_size)
+    {
+        printf("Transfer successful.\n");
+    }
+    else
+    {
+        printf("Transferred only %d bytes out of %d.\n",
+            (unsigned int)transferred, (unsigned int)transfer_size);
+    }
+}
+
+int main_with_exceptions()
+{
+    libusbp::device device = libusbp::find_device_with_vid_pid(
+        vendor_id, product_id);
+    if (!device)
+    {
+        std::cerr << "Device not found." << std::endl;
+        return 1;
+    }
+
+    libusbp::generic_interface gi(device, interface_number, composite);
+    libusbp::generic_handle handle(gi);
+
+    long_write(handle);
+
+    return 0;
+}
+
+int main(int argc, char ** argv)
+{
+    // Suppress unused parameter warnings.
+    (void)argc;
+    (void)argv;
+
+    try
+    {
+        return main_with_exceptions();
+    }
+    catch(const std::exception & error)
+    {
+        std::cerr << "Error: " << error.what() << std::endl;
+    }
+    return 1;
+}