/*HEADER******************************************************************
**************************************************************************
*** 
*** Copyright (c) 2001-2002 ARC International.
*** All rights reserved                                          
***                                                              
*** This software embodies materials and concepts which are      
*** confidential to ARC International and is made
*** available solely pursuant to the terms of a written license   
*** agreement with ARC International             
***
*** File: hostapi.c
***
*** Comments:      
***   This file contains the USB Host API specific functions.
***                                                               
**************************************************************************
*END*********************************************************************/
#ifdef __USB_OS_MQX__
#include "mqx.h"
#include "bsp.h"
#else
#include "types.h"
#include "vusb11.h"
#include "usb.h"
#include "hostapi.h"
#endif
#include "usbprv.h"
#include "usbhprv.h"

#ifndef __USB_OS_MQX__
USB_HOST_STATE_STRUCT_PTR usb_host_state_struct_ptr;
#endif

/*FUNCTION*-------------------------------------------------------------
*
*  Function Name  : _usb_host_init
*  Returned Value : error or USB_OK
*  Comments       :
*        Initializes the USB hardware and installs the USB 
*  interrupt handler
*END*-----------------------------------------------------------------*/

uint_8 _usb_host_init
   (
      /* [IN] device number */
      uint_8                  device_number,
      
      /* [IN] maximum number of Pipes */
      uint_8                  max_pipe_num,
      
      /* [OUT] the USB host handle */
      _usb_host_handle _PTR_  handle
   )
{ /* Body */
   uint_8 error;

#ifdef __USB_OS_MQX__
   USB_HOST_STATE_STRUCT_PTR usb_host_state_struct_ptr;
   
   USB_CALLBACK_FUNCTIONS_STRUCT_PTR call_back_table_ptr;
#endif

   /* Initialize the USB interface. */   
   usb_host_state_struct_ptr = (USB_HOST_STATE_STRUCT_PTR)
      USB_memalloc(sizeof(USB_HOST_STATE_STRUCT));
   
   if (usb_host_state_struct_ptr == NULL) {
      return USBERR_ALLOC_STATE;
   } /* Endif */
   
   USB_memzero(usb_host_state_struct_ptr, sizeof(USB_HOST_STATE_STRUCT));
   
   usb_host_state_struct_ptr->MAX_PIPES = max_pipe_num;
   usb_host_state_struct_ptr->DEV_NUM = device_number;
   
   /* Allocate the USB Host Pipe Descriptors */   
   usb_host_state_struct_ptr->PIPE_DESCRIPTOR_BASE_PTR = 
      (PIPE_DESCRIPTOR_STRUCT_PTR)USB_memalloc\
         (((sizeof(PIPE_DESCRIPTOR_STRUCT)) *  max_pipe_num));
   
   if (usb_host_state_struct_ptr->PIPE_DESCRIPTOR_BASE_PTR == NULL) {
      return USBERR_ALLOC_PIPE_DESCR;
   } /* Endif */
   
   USB_memzero(usb_host_state_struct_ptr->PIPE_DESCRIPTOR_BASE_PTR, 
      ((sizeof(PIPE_DESCRIPTOR_STRUCT)) *  max_pipe_num));

#ifdef __USB_OS_MQX__
   call_back_table_ptr = (USB_CALLBACK_FUNCTIONS_STRUCT_PTR)
      _mqx_get_io_component_handle(IO_USB_COMPONENT);
      
   
   usb_host_state_struct_ptr->CALLBACK_STRUCT_PTR = 
      (call_back_table_ptr + device_number);
      
   if (!usb_host_state_struct_ptr->CALLBACK_STRUCT_PTR) {
      return USBERR_DRIVER_NOT_INSTALLED;
   } /* Endif */
#endif
      
   /* Initialize the pipe queue heads and tails to -1 - indicating that 
   ** the queue is empty 
   */
   usb_host_state_struct_ptr->CURRENT_ISO_HEAD = -1;
   usb_host_state_struct_ptr->CURRENT_ISO_TAIL = -1;
   usb_host_state_struct_ptr->CURRENT_INTR_HEAD = -1;
   usb_host_state_struct_ptr->CURRENT_INTR_TAIL = -1;
   usb_host_state_struct_ptr->CURRENT_CTRL_HEAD = -1;
   usb_host_state_struct_ptr->CURRENT_CTRL_TAIL = -1;
   usb_host_state_struct_ptr->CURRENT_BULK_HEAD = -1;
   usb_host_state_struct_ptr->CURRENT_BULK_TAIL = -1;

#ifdef __USB_OS_MQX__   
   error = 
      ((USB_CALLBACK_FUNCTIONS_STRUCT_PTR)usb_host_state_struct_ptr->\
      CALLBACK_STRUCT_PTR)->HOST_INIT(usb_host_state_struct_ptr);
#else
   error = _usb_hci_vusb11_init(usb_host_state_struct_ptr);
#endif
   
   if (error) {
      return error;
   } /* Endif */
   
   *handle = usb_host_state_struct_ptr;
   
   return USB_OK;

} /* Endbody */

/*FUNCTION*----------------------------------------------------------------
* 
* Function Name  : _usb_host_register_service
* Returned Value : USB_OK or error code
* Comments       :
*     Registers a callback routine for a specified event or pipe.
* 
*END*--------------------------------------------------------------------*/
uint_8 _usb_host_register_service
   (
      /* [IN] Handle to the USB device */
      _usb_host_handle         handle,
      
      /* [IN] type of event or endpoint number to service */
      uint_8                   type,
      
      /* [IN] Pointer to the service's callback function */
      void(_CODE_PTR_ service)(pointer, uint_32)
   )
{ /* Body */
   USB_HOST_STATE_STRUCT_PTR           usb_host_ptr;
   USB_SERVICE_STRUCT_PTR              service_ptr;
   USB_SERVICE_STRUCT_PTR _PTR_        search_ptr;
   
   usb_host_ptr = (USB_HOST_STATE_STRUCT_PTR)handle;
   
   /* Needs mutual exclusion */
   USB_lock();
   
   /* Search for an existing entry for type */
   for (search_ptr = &usb_host_ptr->SERVICE_HEAD_PTR;
      *search_ptr;
      search_ptr = &(*search_ptr)->NEXT) 
   {
      if ((*search_ptr)->TYPE == type) {
         /* Found an existing entry */
         USB_unlock();
         return USBERR_OPEN_SERVICE;
      } /* Endif */
   } /* Endfor */
   
   /* No existing entry found - create a new one */
   service_ptr = (USB_SERVICE_STRUCT_PTR)USB_memalloc\
      (sizeof(USB_SERVICE_STRUCT));
   
   if (!service_ptr) {
      USB_unlock();
      return USBERR_ALLOC_SERVICE;
   } /* Endif */
   
   service_ptr->TYPE = type;
   service_ptr->SERVICE = service;
   service_ptr->NEXT = NULL;
   *search_ptr = service_ptr;
   
   USB_unlock();
   
   return USB_OK;
} /* EndBody */

/*FUNCTION*----------------------------------------------------------------
* 
* Function Name  : _usb_host_call_service
* Returned Value : USB_OK or error code
* Comments       :
*     Calls the appropriate service for the specified type, if one is
*     registered.
* 
*END*--------------------------------------------------------------------*/
uint_8 _usb_host_call_service
   (
      /* [IN] Handle to the USB device */
      _usb_host_handle handle,

      /* [IN] Type of service or endpoint */
      uint_8           type,
      
      /* [IN] Number of bytes in transmission */
      uint_32          length
   )
{ /* Body */
   USB_HOST_STATE_STRUCT_PTR           usb_host_ptr;
   USB_SERVICE_STRUCT_PTR              service_ptr;
   
   usb_host_ptr = (USB_HOST_STATE_STRUCT_PTR)handle;
   /* Needs mutual exclusion */
   USB_lock();
   
   /* Search for an existing entry for type */
   for (service_ptr = usb_host_ptr->SERVICE_HEAD_PTR;
      service_ptr;
      service_ptr = service_ptr->NEXT) 
   {
      if (service_ptr->TYPE == type) {
         service_ptr->SERVICE(handle, length);
         USB_unlock();
         return USB_OK;
      } /* Endif */
      
   } /* Endfor */

   USB_unlock();
   return USBERR_CLOSED_SERVICE;
} /* EndBody */

/*FUNCTION*-------------------------------------------------------------
*
*  Function Name  : _usb_host_open_pipe
*  Returned Value : Pipe ID
*  Comments       :
*  _usb_host_open_pipe routine initializes a new pipe descriptor and 
*  returns the pipe ID based on the USB bus address, endpoint number, 
*  direction of transfer, maximum packet size, interval and the type of pipe
*
*END*-----------------------------------------------------------------*/
int_16 _usb_host_open_pipe
   (
      /* [IN] the USB Host state structure */
      _usb_host_handle     handle,
      
      /* USB Address */
      uint_8               address,

      /* Endpoint number */
      uint_8               ep_num,

      /* Direction - Rx or Tx */
      uint_8               direction,

      /* Interval for transfer */
      uint_8               interval,

      /* Pipe type - Ctrl, Iso, Int, Bulk */
      uint_8               pipe_type,

      /* Max packet size */
      uint_16              max_pkt_size,
      
      /* NAK counter */
	   uint_8               nak_count,

      /* [IN] After all data is transfered, should we terminate the transfer 
      ** with a zero length packet if the last packet size == MAX_PACKET_SIZE? 
      */
      uint_8               flag
   )
{ /* Body */
   int_16 pipeid = -1, i;
   PIPE_DESCRIPTOR_STRUCT_PTR pipe_descr_ptr;
   USB_HOST_STATE_STRUCT_PTR usb_host_ptr;
   
   usb_host_ptr = (USB_HOST_STATE_STRUCT_PTR)handle;

   USB_lock();
   
   for (i=0; i<usb_host_ptr->MAX_PIPES; i++) {
      /* Check if a pipe is not open */
      if (!(usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR[i].OPEN)) {
         break;
      } /* Endif */
   } /* Endfor */

   USB_unlock();

   if (i != usb_host_ptr->MAX_PIPES) {
      pipeid = i;
      pipe_descr_ptr = 
         &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR[pipeid];
      pipe_descr_ptr->ADDRESS = address;
      pipe_descr_ptr->EP = ep_num;
      pipe_descr_ptr->DIRECTION = direction;
      pipe_descr_ptr->INTERVAL = 
         pipe_descr_ptr->CURRENT_INTERVAL = interval;
      pipe_descr_ptr->NAK_COUNT = 
         pipe_descr_ptr->CURRENT_NAK_COUNT = nak_count;
      pipe_descr_ptr->PIPETYPE = pipe_type;
      pipe_descr_ptr->MAX_PKT_SIZE = max_pkt_size;
      pipe_descr_ptr->OPEN = TRUE;
      pipe_descr_ptr->PIPE_ID = pipeid;
      pipe_descr_ptr->STATUS = USB_STATUS_IDLE;
	  pipe_descr_ptr->DONT_ZERO_TERMINATE = flag;
      return pipeid;
   } /* Endif */
   
   return USBERR_OPEN_PIPE_FAILED;

} /* Endbody */

/*FUNCTION*-------------------------------------------------------------
*
*  Function Name  : _usb_host_send_setup
*  Returned Value : None
*  Comments       :
*  Sends a Setup packet. Internally, following the SendSetup call
*  this takes care of the whole transaction (including receiving or sending 
*  any data to or from the device.
*
*END*-----------------------------------------------------------------*/
uint_8 _usb_host_send_setup
   (
      /* [IN] the USB Host state structure */
      _usb_host_handle        handle,
      
      /* Index into the Pipe Descriptor Array */
      int_16                  pipeid,
      
      /* Tx buffer for first phase */
      uchar_ptr               tx1_ptr, 
            
      /* Tx buffer for second phase */
      uchar_ptr               tx2_ptr,
      
      /* Rx buffer */
      uchar_ptr               rx_ptr, 
      
      /* Length of the packet for first phase */
      uint_32                 rx_length,
            
      /* Length of the packet for second phase */
      uint_32                 length2
   )
{ /* Body */
   PIPE_DESCRIPTOR_STRUCT_PTR pipe_descr_ptr;
   USB_HOST_STATE_STRUCT_PTR usb_host_ptr;
   
   usb_host_ptr = (USB_HOST_STATE_STRUCT_PTR)handle;

   /* Check if the pipe id is valid */
   if (pipeid < usb_host_ptr->MAX_PIPES) {
      pipe_descr_ptr = &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR[pipeid];
   } else {
      return USBERR_INVALID_PIPE_ID;
   } /* Endif */

   USB_lock();

   /* Check if a previously queued transfer is still in progress for this 
   ** pipe 
   */
   if (pipe_descr_ptr->STATUS != USB_STATUS_IDLE) {
      USB_unlock();
      return USB_STATUS_TRANSFER_IN_PROGRESS;
   } else {
      USB_unlock();
      /* Initialize the pipe descriptor for the current transfer request */
      pipe_descr_ptr->SOFAR = 0;
      pipe_descr_ptr->NEXTDATA01 = 0;       /* reset DATA0/1 */
      pipe_descr_ptr->RX_PTR = rx_ptr;
      pipe_descr_ptr->TX1_PTR = tx1_ptr;
      pipe_descr_ptr->TX2_PTR = tx2_ptr;
      pipe_descr_ptr->TODO1 = rx_length;
      pipe_descr_ptr->TODO2 = length2;

      pipe_descr_ptr->SEND_PHASE = FALSE;
      pipe_descr_ptr->FIRST_PHASE = TRUE;

      /* Check if this setup packet will have a send data phase */      
      if (!((((INTERNAL_USB_SETUP_PTR)pipe_descr_ptr->TX1_PTR)->BREQUESTTYPE) & 
         USB_SETUP_DATA_XFER_DIRECTION)) 
      {
         pipe_descr_ptr->SEND_PHASE = TRUE;
      } /* Endif */      

      USB_lock();
      
      /* return successful transfer initiation status */
      pipe_descr_ptr->STATUS = USB_STATUS_TRANSFER_QUEUED;

#ifdef __USB_OS_MQX__

      /* Call the low-level routine to send a setup packet */      
      ((USB_CALLBACK_FUNCTIONS_STRUCT_PTR)usb_host_ptr->CALLBACK_STRUCT_PTR)->\
         HOST_SEND_SETUP(handle, pipe_descr_ptr);
#else
      _usb_hci_vusb11_send_setup(handle, pipe_descr_ptr);
#endif

      /* Indicate that a transfer is pending on this pipe */
      pipe_descr_ptr->PACKETPENDING = TRUE;

      USB_unlock();
   } /* Endif */
   
   return USB_STATUS_TRANSFER_QUEUED;

} /* Endbody */

/*FUNCTION*-------------------------------------------------------------
*
*  Function Name  : _usb_host_get_transfer_status
*  Returned Value : Status
*  Comments       :
* _usb_host_get_transfer_status is a routine that returns status of a transfer. 
*
*END*-----------------------------------------------------------------*/
uint_8 _usb_host_get_transfer_status
   (
      /* [IN] the USB Host state structure */
      _usb_host_handle     handle,
      
      /* the Pipe ID */
      int_16               pipeid
   )
{ /* Body */
   USB_HOST_STATE_STRUCT_PTR usb_host_ptr;
   
   usb_host_ptr = (USB_HOST_STATE_STRUCT_PTR)handle;

   /* Check if a valid pipe id */   
   if (pipeid < usb_host_ptr->MAX_PIPES) {
      /* return the status of the transfer on this pipe */
      return (usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR[pipeid].STATUS);
   } else {
      return USBERR_INVALID_PIPE_ID;
   } /* Endif */
} /* Endbody */

/*FUNCTION*-------------------------------------------------------------
*
*  Function Name  : _usb_host_queue_pkts
*  Returned Value : None
*  Comments       :
*        Queue the Pipe's transaction for processing
*END*-----------------------------------------------------------------*/

void _usb_host_queue_pkts
   (
      /* [IN] the USB Host state structure */
      _usb_host_handle                  handle,

      /* [IN] Pipe descriptor to queue */      
      PIPE_DESCRIPTOR_STRUCT_PTR        pipe_descr_ptr
   )
{ /* Body */
   int_16 pipe_head, pipe_tail;
   USB_HOST_STATE_STRUCT_PTR usb_host_ptr;
   
   usb_host_ptr = (USB_HOST_STATE_STRUCT_PTR)handle;

   USB_lock();

   pipe_descr_ptr->NEXT_PIPE = -1;
   
   /* Get the relevant Pipe Head and Tail */
   if (pipe_descr_ptr->PIPETYPE == USB_ISOCHRONOUS_PIPE) {
      pipe_head = usb_host_ptr->CURRENT_ISO_HEAD;
      pipe_tail = usb_host_ptr->CURRENT_ISO_TAIL;
   } else if (pipe_descr_ptr->PIPETYPE == USB_INTERRUPT_PIPE) {
      pipe_head = usb_host_ptr->CURRENT_INTR_HEAD;
      pipe_tail = usb_host_ptr->CURRENT_INTR_TAIL;
   } else if (pipe_descr_ptr->PIPETYPE == USB_CONTROL_PIPE) {
      pipe_head = usb_host_ptr->CURRENT_CTRL_HEAD;
      pipe_tail = usb_host_ptr->CURRENT_CTRL_TAIL;
   } else if (pipe_descr_ptr->PIPETYPE == USB_BULK_PIPE) {
      pipe_head = usb_host_ptr->CURRENT_BULK_HEAD;
      pipe_tail = usb_host_ptr->CURRENT_BULK_TAIL;
   } /* Endif */
   
   if (pipe_head == -1) {
      /* First pipe added to the Active Pipe List */
      pipe_head = pipe_descr_ptr->PIPE_ID;
   } else { 
   
      if (pipe_tail != -1) {
         /* Add it to the Next pointer of the Tail */
         usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR[pipe_tail].NEXT_PIPE = 
            pipe_descr_ptr->PIPE_ID;
      } else {
         /* This is only the second Active Pipe added to the Active list. 
         ** Add it to the next pointer of the head.
         */
         usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR[pipe_head].NEXT_PIPE = 
            pipe_descr_ptr->PIPE_ID;
      } /* Endif */
      
      /* New Tail */
      pipe_tail = pipe_descr_ptr->PIPE_ID;
   } /* Endif */
   
   /* Re-set the relevant Pipe Head and Tail */
   if (pipe_descr_ptr->PIPETYPE == USB_ISOCHRONOUS_PIPE) {
      usb_host_ptr->CURRENT_ISO_HEAD = pipe_head;
      usb_host_ptr->CURRENT_ISO_TAIL = pipe_tail;
   } else if (pipe_descr_ptr->PIPETYPE == USB_INTERRUPT_PIPE) {
      usb_host_ptr->CURRENT_INTR_HEAD = pipe_head;
      usb_host_ptr->CURRENT_INTR_TAIL = pipe_tail;
   } else if (pipe_descr_ptr->PIPETYPE == USB_CONTROL_PIPE) {
      usb_host_ptr->CURRENT_CTRL_HEAD = pipe_head;
      usb_host_ptr->CURRENT_CTRL_TAIL = pipe_tail;
   } else if (pipe_descr_ptr->PIPETYPE == USB_BULK_PIPE) {
      usb_host_ptr->CURRENT_BULK_HEAD = pipe_head;
      usb_host_ptr->CURRENT_BULK_TAIL = pipe_tail;
   } /* Endif */

   USB_unlock();
   
} /* EndBody */      

/*FUNCTION*-------------------------------------------------------------
*
*  Function Name  : _usb_host_update_current_head
*  Returned Value : None
*  Comments       :
*        Update the respective (based on the pipe type) Queue Head
*END*-----------------------------------------------------------------*/

void _usb_host_update_current_head
   (
      /* [IN] the USB Host state structure */
      _usb_host_handle           handle,
      
      /* [IN] The pipe type */
      uint_8 pipetype
   )
{ /* Body */
   PIPE_DESCRIPTOR_STRUCT_PTR pipe_descr_ptr;
   int_16 pipe_head, pipe_tail;
   USB_HOST_STATE_STRUCT_PTR usb_host_ptr;
   
   usb_host_ptr = (USB_HOST_STATE_STRUCT_PTR)handle;

   USB_lock();
   
   pipe_descr_ptr = NULL;

   if (pipetype == USB_ISOCHRONOUS_PIPE) {
      /* Check if the type of queue is empty */
      if (usb_host_ptr->CURRENT_ISO_HEAD != -1) {
         pipe_descr_ptr = 
            &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR\
            [usb_host_ptr->CURRENT_ISO_HEAD];
      } /* Endif */
      
      /* Initialize the new queue head and tail */
      pipe_head = usb_host_ptr->CURRENT_ISO_HEAD;
      pipe_tail = usb_host_ptr->CURRENT_ISO_TAIL;
   } else if (pipetype == USB_INTERRUPT_PIPE) {
      /* Check if the type of queue is empty */
      if (usb_host_ptr->CURRENT_INTR_HEAD != -1) {
         pipe_descr_ptr = 
            &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR\
            [usb_host_ptr->CURRENT_INTR_HEAD];
      } /* Endif */
      
      /* Initialize the new queue head and tail */
      pipe_head = usb_host_ptr->CURRENT_INTR_HEAD;
      pipe_tail = usb_host_ptr->CURRENT_INTR_TAIL;
   } else if (pipetype == USB_CONTROL_PIPE) {
      /* Check if the type of queue is empty */
      if (usb_host_ptr->CURRENT_CTRL_HEAD != -1) {
         pipe_descr_ptr = 
            &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR\
            [usb_host_ptr->CURRENT_CTRL_HEAD];
      } /* Endif */
      
      /* Initialize the new queue head and tail */
      pipe_head = usb_host_ptr->CURRENT_CTRL_HEAD;
      pipe_tail = usb_host_ptr->CURRENT_CTRL_TAIL;
   } else if (pipetype == USB_BULK_PIPE) {
      /* Check if the type of queue is empty */
      if (usb_host_ptr->CURRENT_BULK_HEAD != -1) {
         pipe_descr_ptr = &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR\
         [usb_host_ptr->CURRENT_BULK_HEAD];
      } /* Endif */
      /* Initialize the new queue head and tail */
      pipe_head = usb_host_ptr->CURRENT_BULK_HEAD;
      pipe_tail = usb_host_ptr->CURRENT_BULK_TAIL;
   } /* Endif */

   /* Check if another pipe was found on the respective type queue */
   if (pipe_descr_ptr) {
      /* Check if there is another pipe after this */
      if (pipe_descr_ptr->NEXT_PIPE != -1) {
         if ((pipe_descr_ptr->STATUS != USB_STATUS_IDLE) && 
            (pipe_tail != -1)) 
         {
            usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR[pipe_tail].NEXT_PIPE = 
               pipe_head;
            pipe_tail = pipe_head;
         } /* Endif */
         /* Initialize the new pipe head */
         pipe_head = pipe_descr_ptr->NEXT_PIPE;
         if (pipe_tail != -1) {
            usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR[pipe_tail].NEXT_PIPE = -1;
         } /* Endif */
      } else {
         if (pipe_descr_ptr->STATUS == USB_STATUS_IDLE) {
            pipe_head = -1;
            pipe_tail = -1;
         } /* Endif */
      } /* Endif */
   } /* Endif */

   /* Update the new heads and tails of the respective pipes types */   
   if (pipetype == USB_ISOCHRONOUS_PIPE) {
      usb_host_ptr->CURRENT_ISO_HEAD = pipe_head;
      usb_host_ptr->CURRENT_ISO_TAIL = pipe_tail;
   } else if (pipetype == USB_INTERRUPT_PIPE) {
      usb_host_ptr->CURRENT_INTR_HEAD = pipe_head;
      usb_host_ptr->CURRENT_INTR_TAIL = pipe_tail;
   } else if (pipetype == USB_CONTROL_PIPE) {
      usb_host_ptr->CURRENT_CTRL_HEAD = pipe_head;
      usb_host_ptr->CURRENT_CTRL_TAIL = pipe_tail;
   } else if (pipetype == USB_BULK_PIPE) {
      usb_host_ptr->CURRENT_BULK_HEAD = pipe_head;
      usb_host_ptr->CURRENT_BULK_TAIL = pipe_tail;
   } /* Endif */

   USB_unlock();
      
} /* Endbody */

/*FUNCTION*-------------------------------------------------------------
*
*  Function Name  : _usb_host_update_current_interval_on_queue
*  Returned Value : None
*  Comments       :
*        Update the interval for the given pipe
*END*-----------------------------------------------------------------*/

void _usb_host_update_current_interval_on_queue
   (
      /* [IN] the USB Host state structure */
      _usb_host_handle           handle,
      
      /* [IN] the USB Host state structure */
      PIPE_DESCRIPTOR_STRUCT_PTR pipe_descr_ptr
   )
{ /* Body */
   USB_HOST_STATE_STRUCT_PTR usb_host_ptr;
   
   usb_host_ptr = (USB_HOST_STATE_STRUCT_PTR)handle;
   
   while(TRUE) {
      /* Update the current interval for all pipes */
      if (pipe_descr_ptr->CURRENT_INTERVAL) {
         pipe_descr_ptr->CURRENT_INTERVAL--;
         if ((!pipe_descr_ptr->CURRENT_INTERVAL) && (pipe_descr_ptr->PIPETYPE != USB_INTERRUPT_PIPE)) {
            pipe_descr_ptr->CURRENT_NAK_COUNT = pipe_descr_ptr->NAK_COUNT;
         } /* Endif */
      } /* Endif */
      if (pipe_descr_ptr->NEXT_PIPE != -1) {
         pipe_descr_ptr = &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR\
            [pipe_descr_ptr->NEXT_PIPE];
      } else {
         break;
      } /* Endif */
   } /* EndWhile */
      
} /* EndBody */

/*FUNCTION*-------------------------------------------------------------
*
*  Function Name  : _usb_host_update_interval_for_pipes
*  Returned Value : None
*  Comments       :
*        Update the interval for the interrupt pipe
*END*-----------------------------------------------------------------*/

void _usb_host_update_interval_for_pipes
   (
      /* [IN] the USB Host state structure */
      _usb_host_handle           handle
   )
{ /* Body */
#ifdef V8
   static PIPE_DESCRIPTOR_STRUCT_PTR pipe_descr_ptr;
#else
   PIPE_DESCRIPTOR_STRUCT_PTR pipe_descr_ptr;
#endif
   USB_HOST_STATE_STRUCT_PTR usb_host_ptr;
   
   usb_host_ptr = (USB_HOST_STATE_STRUCT_PTR)handle;
   
   USB_lock();

   /* Check if there are any Interrupt pipes on the Interrupt pipe queue */
   if (usb_host_ptr->CURRENT_INTR_HEAD != -1) {
      pipe_descr_ptr = 
         &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR\
         [usb_host_ptr->CURRENT_INTR_HEAD];
      _usb_host_update_current_interval_on_queue(usb_host_ptr, pipe_descr_ptr);
   } /* Endif */
   
   /* Check if any control pipes are NAK deferred */
   if (usb_host_ptr->CURRENT_CTRL_HEAD != -1) {
      pipe_descr_ptr = 
         &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR\
         [usb_host_ptr->CURRENT_CTRL_HEAD];
      _usb_host_update_current_interval_on_queue(usb_host_ptr, pipe_descr_ptr);
   } /* Endif */
   
   /* Check if any bulk pipes are NAK deferred */
   if (usb_host_ptr->CURRENT_BULK_HEAD != -1) {
      pipe_descr_ptr = 
         &usb_host_ptr->PIPE_DESCRIPTOR_BASE_PTR\
         [usb_host_ptr->CURRENT_BULK_HEAD];
      _usb_host_update_current_interval_on_queue(usb_host_ptr, pipe_descr_ptr);
   } /* Endif */

   USB_unlock();
  
} /* EndBody */      



/* EOF */