Changes in uspace/lib/usb/src/pipesio.c [d48fcc0:3954a63b] in mainline

File:

• uspace/lib/usb/src/pipesio.c (modified) (23 diffs)

uspace/lib/usb/src/pipesio.c

@@ -49 +49 @@
 #include <assert.h>
 #include <usbhc_iface.h>
-#include "pipepriv.h"
 
 /** Request an in transfer, no checking of input parameters.
@@ -79 +78 @@
         }
 
-        /* Ensure serialization over the phone. */
-        pipe_start_transaction(pipe);
-
         /*
          * Make call identifying target USB device and type of transfer.
@@ -91 +87 @@
             NULL);
         if (opening_request == 0) {
-                pipe_end_transaction(pipe);
                 return ENOMEM;
         }
@@ -101 +96 @@
         aid_t data_request = async_data_read(pipe->hc_phone, buffer, size,
             &data_request_call);
-
-        /*
-         * Since now on, someone else might access the backing phone
-         * without breaking the transfer IPC protocol.
-         */
-        pipe_end_transaction(pipe);
 
         if (data_request == 0) {
@@ -157 +146 @@
 
         if (buffer == NULL) {
-                return EINVAL;
+                        return EINVAL;
         }
 
@@ -164 +153 @@
         }
 
+        if (!usb_pipe_is_session_started(pipe)) {
+                return EBADF;
+        }
+
         if (pipe->direction != USB_DIRECTION_IN) {
                 return EBADF;
@@ -172 +165 @@
         }
 
+        size_t act_size = 0;
         int rc;
-        rc = pipe_add_ref(pipe);
-        if (rc != EOK) {
-                return rc;
-        }
-
-
-        size_t act_size = 0;
 
         rc = usb_pipe_read_no_checks(pipe, buffer, size, &act_size);
-
-        pipe_drop_ref(pipe);
-
         if (rc != EOK) {
                 return rc;
@@ -226 +210 @@
         }
 
-        /* Ensure serialization over the phone. */
-        pipe_start_transaction(pipe);
-
         /*
          * Make call identifying target USB device and type of transfer.
@@ -238 +219 @@
             NULL);
         if (opening_request == 0) {
-                pipe_end_transaction(pipe);
                 return ENOMEM;
         }
@@ -246 +226 @@
          */
         int rc = async_data_write_start(pipe->hc_phone, buffer, size);
-
-        /*
-         * Since now on, someone else might access the backing phone
-         * without breaking the transfer IPC protocol.
-         */
-        pipe_end_transaction(pipe);
-
         if (rc != EOK) {
                 async_wait_for(opening_request, NULL);
@@ -287 +260 @@
         }
 
+        if (!usb_pipe_is_session_started(pipe)) {
+                return EBADF;
+        }
+
         if (pipe->direction != USB_DIRECTION_OUT) {
                 return EBADF;
@@ -295 +272 @@
         }
 
-        int rc;
-
-        rc = pipe_add_ref(pipe);
-        if (rc != EOK) {
-                return rc;
-        }
-
-        rc = usb_pipe_write_no_check(pipe, buffer, size);
-
-        pipe_drop_ref(pipe);
+        int rc = usb_pipe_write_no_check(pipe, buffer, size);
 
         return rc;
@@ -325 +293 @@
     void *data_buffer, size_t data_buffer_size, size_t *data_transfered_size)
 {
-        /* Ensure serialization over the phone. */
-        pipe_start_transaction(pipe);
-
         /*
          * Make call identifying target USB device and control transfer type.
@@ -346 +311 @@
             setup_buffer, setup_buffer_size);
         if (rc != EOK) {
-                pipe_end_transaction(pipe);
                 async_wait_for(opening_request, NULL);
                 return rc;
@@ -358 +322 @@
             data_buffer, data_buffer_size,
             &data_request_call);
-
-        /*
-         * Since now on, someone else might access the backing phone
-         * without breaking the transfer IPC protocol.
-         */
-        pipe_end_transaction(pipe);
-
-
         if (data_request == 0) {
                 async_wait_for(opening_request, NULL);
@@ -423 +379 @@
         }
 
+        if (!usb_pipe_is_session_started(pipe)) {
+                return EBADF;
+        }
+
         if ((pipe->direction != USB_DIRECTION_BOTH)
             || (pipe->transfer_type != USB_TRANSFER_CONTROL)) {
@@ -428 +388 @@
         }
 
-        int rc;
-
-        rc = pipe_add_ref(pipe);
-        if (rc != EOK) {
-                return rc;
-        }
-
         size_t act_size = 0;
-        rc = usb_pipe_control_read_no_check(pipe,
+        int rc = usb_pipe_control_read_no_check(pipe,
             setup_buffer, setup_buffer_size,
             data_buffer, data_buffer_size, &act_size);
-
-        pipe_drop_ref(pipe);
 
         if (rc != EOK) {
@@ -467 +418 @@
     void *data_buffer, size_t data_buffer_size)
 {
-        /* Ensure serialization over the phone. */
-        pipe_start_transaction(pipe);
-
         /*
          * Make call identifying target USB device and control transfer type.
@@ -480 +428 @@
             NULL);
         if (opening_request == 0) {
-                pipe_end_transaction(pipe);
                 return ENOMEM;
         }
@@ -490 +437 @@
             setup_buffer, setup_buffer_size);
         if (rc != EOK) {
-                pipe_end_transaction(pipe);
                 async_wait_for(opening_request, NULL);
                 return rc;
@@ -501 +447 @@
                 rc = async_data_write_start(pipe->hc_phone,
                     data_buffer, data_buffer_size);
-
-                /* All data sent, pipe can be released. */
-                pipe_end_transaction(pipe);
-
                 if (rc != EOK) {
                         async_wait_for(opening_request, NULL);
                         return rc;
                 }
-        } else {
-                /* No data to send, we can release the pipe for others. */
-                pipe_end_transaction(pipe);
         }
 
@@ -552 +491 @@
         }
 
+        if (!usb_pipe_is_session_started(pipe)) {
+                return EBADF;
+        }
+
         if ((pipe->direction != USB_DIRECTION_BOTH)
             || (pipe->transfer_type != USB_TRANSFER_CONTROL)) {
@@ -557 +500 @@
         }
 
-        int rc;
-
-        rc = pipe_add_ref(pipe);
-        if (rc != EOK) {
-                return rc;
-        }
-
-        rc = usb_pipe_control_write_no_check(pipe,
+        int rc = usb_pipe_control_write_no_check(pipe,
             setup_buffer, setup_buffer_size, data_buffer, data_buffer_size);
-
-        pipe_drop_ref(pipe);
 
         return rc;