1 files changed, 67 insertions, 66 deletions

diff --git a/cpukit/posix/src/aio_cancel.c b/cpukit/posix/src/aio_cancel.c
index eba231db1e..e47ba6f3e4 100644
--- a/cpukit/posix/src/aio_cancel.c
+++ b/cpukit/posix/src/aio_cancel.c
@@ -43,84 +43,85 @@ int aio_cancel(int fildes, struct aiocb  *aiocbp)
   
   pthread_mutex_lock (&aio_request_queue.mutex);
 
-  if (aiocbp == NULL)
-    {
-      if (fcntl (fildes, F_GETFL) < 0) {
-        pthread_mutex_unlock(&aio_request_queue.mutex);
-	rtems_set_errno_and_return_minus_one (EBADF);
+  if (fcntl (fildes, F_GETFD) < 0) {
+    pthread_mutex_unlock(&aio_request_queue.mutex);
+    rtems_set_errno_and_return_minus_one (EBADF);
+  }
+
+  /* if aiocbp is NULL remove all request for given file descriptor */
+  if (aiocbp == NULL) {
+    AIO_printf ("Cancel all requests\n");        
+         
+    r_chain = rtems_aio_search_fd (&aio_request_queue.work_req, fildes, 0);
+    if (r_chain == NULL) {
+      AIO_printf ("Request chain not on [WQ]\n");
+
+      if (!rtems_chain_is_empty (&aio_request_queue.idle_req)) {
+        r_chain = rtems_aio_search_fd (&aio_request_queue.idle_req, fildes, 0);
+        if (r_chain == NULL) {
+          pthread_mutex_unlock(&aio_request_queue.mutex);
+          return AIO_ALLDONE;
+        }
+
+        AIO_printf ("Request chain on [IQ]\n");
+
+        rtems_chain_extract (&r_chain->next_fd);        
+        rtems_aio_remove_fd (r_chain);
+        pthread_mutex_destroy (&r_chain->mutex);
+        pthread_cond_destroy (&r_chain->mutex);
+        free (r_chain);
+
+        pthread_mutex_unlock (&aio_request_queue.mutex);
+        return AIO_CANCELED;
       }
 
-      r_chain = rtems_aio_search_fd (&aio_request_queue.work_req,
-				     fildes,
-				     0);
-      if (r_chain == NULL)
-	{
-	  if (!rtems_chain_is_empty (&aio_request_queue.idle_req))
-	    {
-	      r_chain = rtems_aio_search_fd (&aio_request_queue.idle_req,
-					     fildes,
-					     0);
-	      if (r_chain == NULL) {
-	        pthread_mutex_unlock(&aio_request_queue.mutex);
-		return AIO_ALLDONE;
-              }
-
-	      rtems_chain_extract (&r_chain->next_fd);	
-	      rtems_aio_remove_fd (r_chain);
-	      pthread_mutex_destroy (&r_chain->mutex);
-	      pthread_cond_destroy (&r_chain->mutex);
-	      free (r_chain);
-
-	      pthread_mutex_unlock (&aio_request_queue.mutex);
-	      return AIO_CANCELED;
-	    }
-
-	  pthread_mutex_unlock (&aio_request_queue.mutex);
-	  return AIO_ALLDONE;
-	}
+      pthread_mutex_unlock (&aio_request_queue.mutex);
+      return AIO_ALLDONE;
+    }
 
-      pthread_mutex_lock (&r_chain->mutex);
-      rtems_chain_extract (&r_chain->next_fd);
-      rtems_aio_remove_fd (r_chain);
-      pthread_mutex_unlock (&r_chain->mutex);
+    AIO_printf ("Request chain on [WQ]\n");
+
+    pthread_mutex_lock (&r_chain->mutex);
+    rtems_chain_extract (&r_chain->next_fd);
+    rtems_aio_remove_fd (r_chain);
+    pthread_mutex_unlock (&r_chain->mutex);
+    pthread_mutex_unlock (&aio_request_queue.mutex);
+    return AIO_CANCELED;
+  } else {
+    AIO_printf ("Cancel request\n");
+
+    if (aiocbp->aio_fildes != fildes) {
       pthread_mutex_unlock (&aio_request_queue.mutex);
-      return AIO_CANCELED;
+      rtems_set_errno_and_return_minus_one (EINVAL);
     }
-  else 
-    {
-      if (aiocbp->aio_fildes != fildes) {
-	  pthread_mutex_unlock (&aio_request_queue.mutex);
-	  rtems_set_errno_and_return_minus_one (EINVAL);
-	}
       
-      r_chain = rtems_aio_search_fd (&aio_request_queue.work_req,
-				     fildes,
-				     0);
-      if (r_chain == NULL)
-	if (!rtems_chain_is_empty (&aio_request_queue.idle_req))
-	  {
-	    r_chain = rtems_aio_search_fd (&aio_request_queue.idle_req,
-					   fildes,
-					   0);
-	    if (r_chain == NULL)
-	      { 
-		pthread_mutex_unlock (&aio_request_queue.mutex);
-		rtems_set_errno_and_return_minus_one (EINVAL);
-	      }      
-
-	    result = rtems_aio_remove_req (&r_chain->perfd, aiocbp);
-	    pthread_mutex_unlock (&aio_request_queue.mutex);
-	    return result;
-
-	  }
+    r_chain = rtems_aio_search_fd (&aio_request_queue.work_req, fildes, 0);
+    if (r_chain == NULL) {
+      if (!rtems_chain_is_empty (&aio_request_queue.idle_req)) {
+        r_chain = rtems_aio_search_fd (&aio_request_queue.idle_req, fildes, 0);
+        if (r_chain == NULL) { 
+          pthread_mutex_unlock (&aio_request_queue.mutex);
+          rtems_set_errno_and_return_minus_one (EINVAL);
+        }      
+           
+        AIO_printf ("Request on [IQ]\n");                     
+   
+        result = rtems_aio_remove_req (&r_chain->perfd, aiocbp);
+        pthread_mutex_unlock (&aio_request_queue.mutex);
+        return result;
+      } else {
+        pthread_mutex_unlock (&aio_request_queue.mutex);
+        return AIO_ALLDONE;
+      }
+
+      AIO_printf ("Request on [WQ]\n");
       
       pthread_mutex_lock (&r_chain->mutex);
       result = rtems_aio_remove_req (&r_chain->perfd, aiocbp);
       pthread_mutex_unlock (&r_chain->mutex);
       pthread_mutex_unlock (&aio_request_queue.mutex);
       return result;
-   
     }
-  
+  }
   return AIO_ALLDONE;
 }