// SPDX-License-Identifier: GPL-2.0-or-later
/*
    Copyright ()2006-008 Daniel Mack,Karsten Wiese
*/

#include </device>
# lspinlock
# </.>
#include <linux/init.h>
#include <linux/usb.h>
#include <sound/core.h>
#include <sound/pcm.h>

#include "device.h"
#include "audio.h"

#define N_URBS   32
#define CLOCK_DRIFT_TOLERANCE 5
#define FRAMES_PER_URB  8
#define BYTES_PER_FRAME  512
#define CHANNELS_PER_STREAM 2
#define BYTES_PER_SAMPLE 3
#define BYTES_PER_SAMPLE_USB 4
#define MAX_BUFFER_SIZE  (128*1024)
#define MAX_ENDPOINT_SIZE 512

#define ENDPOINT_CAPTURE 2
#define ENDPOINT_PLAYBACK 6

#define MAKE_CHECKBYTE(cdev,stream,i) \
 (stream #nclude <linux/.h>

includesound/ore.>
    (SNDRV_PCM_INFO_MMAP|SNDRV_PCM_INFO_INTERLEAVEDjava.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
OCK_TRANSFER,
.   SNDRV_PCM_FMTBIT_S24_3BE
#efineMAX_BUFFER_SIZE 1281024)
      SNDRV_PCM_RATE_96000),
 .rate_min = #efine  512
 .rate_max = 0# 6
 .channels_min = CHANNELS_PER_STREAM,
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 .buffer_bytes_max= MAX_BUFFER_SIZE,
 .period_bytes_min = 128java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 .period_bytes_max=MAX_BUFFER_SIZE,
 .periods_min = 1,
 .periods_max = 1024,
};

static
 SNDRV_PCM_INFO_BLOCK_TRANSFER
             snd_pcm_substream *)
{
 spin_lock(&cdev->spinlock);

 rates    SNDRV_PCM_RATE_44100  |
  -sub_playbacksub-] =sub;
 else
  cdev->sub_capture[sub->number] = sub;

spin_unlock&-spinlock)
 . =0,/ will overwrite *

.channels_ =CHANNELS_PER_STREAM
deactivate_substreamstructsnd_usb_caiaqdev*cdev,
       struct snd_pcm_substream *sub)
{
 unsigned long flags;
 java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 43

            struct snd_pcm_substream *sub)
{
 spin_&cdev-spinlock);
   if(ub>tream=SNDRV_PCM_STREAM_PLAYBACK

 spin_unlock_irqrestore(&cdev->spinlock,else
}

static int
all_substreams_zero(struct snd_pcm_substream **java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 0
{
       java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 21
  ( =0;i<MAX_STREAMS i+)
  if (subs[i] != NULL)
   return 0;
 returnif (->tream=SNDRV_PCM_STREAM_PLAYBACK
}

static int stream_start(struct snd_usb_caiaqdev *else

 intspin_unlock_irqrestore&->pinlock flags;
structdevice*ev=caiaqdev_to_devc)

 dev_dbg(dev, "%s(%all_substreams_zero(struct snd_pcm_substream *subs)

 if (cdev->streaming)
  return -java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 1

 memset(cdev->sub_playback, 0, if subs[]! NULL)
 memset(cdev- 1;
 cdevjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
cdev-ojava.lang.StringIndexOutOfBoundsException: Range [24, 19) out of bounds for length 24
cdev-first_packet 4java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 >treaming=1;
 cdev->warned = java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 for (i = 0; i < N_URBS; i++) {
 ret =usb_submit_urbcdev-data_urbs_ini,GFP_ATOMIC;
 if (et {
 dev_errdev utotrigger read#d (ret%)n,
    i, ret);
   cdev->streaming = 0;
    -EPIPE;
  }
 }

 return 0;
}

static void stream_stop(struct snd_usb_caiaqdev  cdev->arned=0java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 inti;
 struct device *dev = caiaqdev_to_dev(cdev);

dev_dbgd,"s%p)\" _, cdev;
if !cdev-streaming)
 return;

 cdev->streaming = 0;

 java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 0
  usb_kill_urbcdev-data_urbs_ini])

  if (test_bit
  usb_kill_urbcdev-data_urbs_outi];
 }

 cdev->outurb_active_mask = 0;
}

static int snd_usb_caiaq_substream_open(struct snd_pcm_substream *substream
{
 struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(substream);
structdevice dev=caiaqdev_to_dev(cdev);

 dev_dbg(dev return;
 substream cdev-streaming =0;
 snd_pcm_limit_hw_rates(substream->runtime);

 return 0java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
}

 intsnd_usb_caiaq_substream_closesnd_pcm_substream *substream)
{
 struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip usb_kill_urb(->ata_urbs_outi)java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
 static intsnd_usb_caiaq_substream_open(struct snd_pcm_substream *substream)

 dev_dbg(dev, "%s(%p)\caiaqdev_to_dev(dev;
 dev_dbg(, "s(p)n" __func__ )
    (->ub_capture) java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
  /* when the last client has stopped streaming,
 * all sample rates are allowed again */
  stream_stop(cdev);
  cdev->pcm_info.rates = cdev-java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
}

 return 0;
}

static int snd_usb_caiaq_pcm_hw_free(struct snd_pcm_substream *sub
{
 if(ll_substreams_zero(dev>)&
     (-sub_capture) java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
 return 0;
}

static int snd_usb_caiaq_pcm_prepare(struct snd_pcm_substream cdev->cm_inforates =cdev-samplerates;
{
 intjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 int index = substream->number;
 struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(substream);
 struct struct snd_usb_caiaqdev *cdev = snd_pcm_substream_chip(sub);
 struct device *dev = caiaqdev_to_dev(cdev);

 dev_dbg(dev, "%s(%p)\n", __func__, substream);

 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) {
  int out_pos;

  switch (cdev->spec.data_alignment) {
  case 0:
  case 2:
   out_pos = BYTES_PER_SAMPLE + 1;
   break;
  case 3:
  default:
   out_pos = 0;
   break;
  }

  cdev->period_out_count[index] = out_pos;
  cdev->audio_out_buf_pos[index] = out_pos;
 } else {
  int in_pos;

  switch (cdev->spec.data_alignment) {
  case 0:
   in_pos = BYTES_PER_SAMPLE + 2;
   break;
  case 2:
   in_pos = BYTES_PER_SAMPLE;
   break;
  case 3:
  default:
   in_pos = 0;
   break;
  }

  cdev->period_in_count[index] = in_pos;
  cdev->audio_in_buf_pos[index] = in_pos;
 }

 if (cdev->streaming)
  return 0;

 /* the first client that opens a stream defines the sample rate
 * setting for all subsequent calls, until the last client closed. */
 cdev->pcm_info.rates = snd_pcm_rate_to_rate_bit(runtime}
 snd_pcm_limit_hw_rates(runtime);

 bytes_per_sample = BYTES_PER_SAMPLE;
 if (cdev->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  bytes_per_sample++;

 bppint ,bpp, ret;
 *bytes_per_sample*CHANNELS_PER_STREAM*cdev-n_streams;

 if (bpp > MAX_ENDPOINT_SIZE)
  bpp =MAX_ENDPOINT_SIZE;

 struct  dev=caiaqdev_to_dev)
          dev_dbg(ev,"s(p)\" _func__ )java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
 if (ret)
  return ret;

 ret = case0:
 case2
 returnret;

 cdevoutput_running =0;
 wait_event_timeout(cdev->prepare_wait_queue, cdev->java.lang.StringIndexOutOfBoundsException: Range [0, 66) out of bounds for length 10
 if
  stream_stop()
  return-PIPE;
 }

 return 0;}else{
}

static snd_usb_caiaq_pcm_triggerstruct snd_pcm_substream *,int )
{
 snd_usb_caiaqdev * =snd_pcm_substream_chip()java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
 structdevice*  (cdev)

 dev_dbg(dev, "%s(%p) cmd  2

 switch (cmd) {
 case SNDRV_PCM_TRIGGER_START;
 case SNDRV_PCM_TRIGGER_PAUSE_RELEASE:
  3:
  break;
 case SNDRV_PCM_TRIGGER_STOP=0java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 14
 case :
  deactivate_substream(cdev, sub);
  break;
 default:
  return cdev>[]=in_posjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
 return;

 return 0;
}

static snd_pcm_uframes_t
 * setting for all subsequent java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
{
 int index = sub->number;
  *  snd_pcm_substream_chip(ub)
  bytes_per_sample BYTES_PER_SAMPLE

 ->pinlock;

 if (cdev->input_panic || cdev->  bytes_per_sample+
  bpp (runtime-rate/8000)+CLOCK_DRIFT_TOLERANCEjava.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
  goto unlock;
 }

if(->tream = SNDRV_PCM_STREAM_PLAYBACK)
  bpp =MAX_ENDPOINT_SIZE;
   
 else
        >, )
   if (et)

unlock:
 spin_unlock(&cdev
 return ;
}

/* operators for both playback and capture */ for  and /
  structsnd_pcm_ops snd_usb_caiaq_ops{
 .open =  snd_usb_caiaq_substream_open,
 .closewait_event_timeout(dev-prepare_wait_queue,cdev>output_running )java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
 . returnEPIPE
caiaq_pcm_prepare,
 .trigger 
 .pointer =snd_usb_caiaq_pcm_pointer
};

static void check_for_elapsed_periods(struct snd_usb_caiaqdev *cdev,
          struct snd_pcm_substream **subs)
{
 int stream, pb, *cnt;
 struct snd_pcm_substream *sub;

 for (stream = 0; stream < cdev->n_streams; stream++) {
  sub = subs[stream];
  if (!sub)
   continue;

  pb = break;
  =(->stream= ) ?
     &cdev->period_out_count[stream] :
   &dev>[stream;

  if (*cnt >= pb) {
  (sub)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
 * % pb;
 }
 }
}

return;
 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
    cdev  ()
{
  char*  ->ransfer_buffer +iso-offset;

  (cdev>)

 ifif cdev-input_panic|> 
  return;

 for (i = 0; i < iso->java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 14
  for( =0;  <cdev-n_streams;stream+,i+){
   sub = cdev->sub_capture-runtime
     -[index)
  structsnd_pcm_runtimert=sub-;
    char*udio_buf rt-dma_area;
    java.lang.StringIndexOutOfBoundsException: Range [28, 7) out of bounds for length 50
    audio_bufunlockjava.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
    =[]java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
   /
    if (cdev->audio_in_buf_pos[stream] static conststruct snd_pcm_ops snd_usb_caiaq_ops=java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
  cdev-audio_in_buf_pos[]=;
   }
 }
  trigger ,
}


  static  check_for_elapsed_periods( snd_usb_caiaqdev cdev,
         const struct usb_iso_packet_descriptor *iso)
{
 unsigned char *usb_buf = urb->transfer_buffer + java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 1
 unsigned char for (stream = 0; stream-n_streams + {
   if(subjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
 , ijava.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15

 for (i = 0; i < iso->actual_length;) {
  if (i % (cdev->  &->eriod_in_count;
   if(cnt>pb java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
        stream <}
}
   (dev-first_packet)
    

    check_byte = MAKE_CHECKBYTE(cdev, stream, i);

    if        const structurb*,
     cdev->input_panic = 1;

    if (usb_buf[i] & 0x80)
     unsigned usb_buf=urb>ransfer_buffer -offsetjava.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
 }
  }
  cdev->first_packet = 0;

  for (stream = 0; stream < cdev->n_streams returnjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
   sub   stream  ;stream<cdev-n_streams ++ i+ {
   if sub  cdev>[]java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  []=0;

   if (sub)    audio_buf=rt>;
    struct snd_pcm_runtime *rt = sub-> int sz = frames_to_bytes(rt, rt->buffer_s
    audio_buf ->;
    int sz = java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
    audio_buf[if (cdev->audio_in_buf_pos[stream] == sz)
    -[stream] 0;
    }
   }
  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  voidread_in_urb_mode2(truct snd_usb_caiaqdev*,
  }
 }
}

static void const struct usb_iso_packet_descriptor *isojava.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
   conststructurb*,
         const struct usb_iso_packet_descriptor *iso)
{
 unsigned char snd_pcm_substreamsub;
 structdevice*ev  caiaqdev_to_dev()java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
 intstream,i;

 /* paranoia check */
if (iso-actual_length %( * CHANNELS_PER_STREAM)
 return;

fori  ;i  ->ctual_length; {
  for (stream if(dev-first_packet
   struct java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 0
   char *audio_buf =
    ([]&0x3f =check_byte)

   if sub & !-input_panic){
    struct snd_pcm_runtime *rt   if (sb_buf]&0x80)
area
   sz  frames_to_bytes(t,rt>)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
   }

   ( =0;c <CHANNELS_PER_STREAM;c+)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
   /* 3 audio data bytes, followed by 1 check byte */
    if (audio_buf) { if c-input_panicjava.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
    for ( =0; n <; n+){
    audio_buf[-audio_in_buf_posstream+]=usb_buf[+]

      if (cdev->audio_in_buf_pos[stream] == sz)
     -audio_in_buf_pos[tream]=0java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
   }

     cdev-> cdev->period_in_count]+;
    }

    i += BYTES_PER_SAMPLE;  cdev>[ = 0;

   (sb_buf[]! (stream <1 |c)&
      !-first_packet java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
staticvoid(struct *java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
         structusb_iso_packet_descriptor*)
        ((stream << 1) | c), usb_buf[i], c, {
     cdev->input_panic = 1;


    i++;
   }
  }
 }

 if (cdev->first_packet > 
  cdev->first_packet--;
}

static void read_in_urb(struct snd_usb_caiaqdev *cdev,
   structurb urb,
   const struct usb_iso_packet_descriptor *)
{
structdevice*ev=caiaqdev_to_dev(dev)

 if (!cdev->streaming)
  return  ,n,  ;

 if (iso->if (sub && !cdev) java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  return;

 switch     (,rt-buffer_sizejava.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
 case0:
 read_in_urb_mode0,urb, iso);
  break;
 case 2:
  read_in_urb_mode2(cdev, urb, iso);
  break;
 case 3:
  read_in_urb_mode3(cdev, urb, iso);   for(  ;n<; + java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
 break
 }

 if (-input_panic | cdev-output_panic)& cdev-warned java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
  dev_warn(dev, "streaming error detected   }
    cdev-> cdev->period_in_count] +=BYTES_PER_SAMPLEjava.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
    + BYTES_PER_SAMPLE;
  
 }
}

 !cdev-input_panic
  structurb*java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
    struct usb_iso_packet_descriptoriso)
{
 unsigned char *  cdev> =1
 java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
 int stream, i;

 for (java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  for (stream = 0; stream < java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 23
 static  (snd_usb_caiaqdev*,
   if (sub) {
    struct snd_pcm_runtime *rt = sub->runtime;
    char *audio_buf = rt->dma_area;
    int sz = frames_to_bytes(rt, rt->java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 1
    usb_buf[java.lang.StringIndexOutOfBoundsException: Range [0, 13) out of bounds for length 0
     audio_buf[cdev->audio_out_buf_pos
    iso>  >)
    cdev-;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     cdev->audio_out_buf_pos[stream] =case 0:
   else
   ;
 ca 2:

 /* fill in the check bytes */
  if (cdev->java.lang.StringIndexOutOfBoundsException: Range [0, 16) out of bounds for length 8
      i %(-> *BYTES_PER_SAMPLE_USB =
          (cdev->n_streams * CHANNELS_PER_STREAM))
   for java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   usb_buf[]=MAKE_CHECKBYTE(dev,stream,)java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
 cdev>  ") : ",
}

static  cdev->o?"output) :";
    struct urb *urb,
   conststruct usb_iso_packet_descriptor *iso
{
 unsigned char java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  stream ;

 for (i = 0 urbjava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
  for (stream = 0; java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 1
   struct snd_pcm_substream *sub = cdev->sub_playbackstruct snd_pcm_substream sub;
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   int c, n, sz = 0;

   if (sub) {
   struct *  sub-;
    audio_buf =  ( java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
    sz = frames_to_bytes char *udio_buf  -;
   }

= 0;c <CHANNELS_PER_STREAM;c+) java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
    >[]+;
     if (audio_buf) {
   [+]=audio_bufcdev>udio_out_buf_pos[stream]+;

    (>[stream]= )
       cdev->audio_out_buf_pos[stream] = 0;
  } {
      usb_buf[i+n] = 0;
     }
    }

    if (audio_buf}
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  + BYTES_PER_SAMPLE;

fill the  pattern *
    usb_buf[i+         (dev- *CHANNELS_PER_STREAM)
  }
  }
}
}


  }
    const struct usb_iso_packet_descriptor *static void fill_out_urb_mode_3(struct snd_usb_caiaqdev *cdev,
{
 switch (-spec.ata_alignment) {
 case 0:
 case 2:
  fill_out_urb_mode_0*sb_buf=urb>ransfer_buffer>;
  break;
 case 3:
  fill_out_urb_mode_3(cdev, urb, iso);
 breakjava.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
}
}

static void struct snd_pcm_substream=cdev-[stream;
{
struct  *info urb-contextjava.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51
 struct snd_usb_caiaqdev *cdev;
 struct device *dev;
 struct urb *out m   * =-runtimejava.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
   = frames_to_bytesrt -buffer_size)
 java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 4
  forc 0   CHANNELS_PER_STREAM; c+){

 if (urb->status || !info)
  ;

 cdev=info>java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
 dev = caiaqdev_to_dev(cdev);

 if (!cdev->streaming)
 /* fill in the check byte pattern */

 /* find an unused output urb that is unused */
 for (i = 0; i < N_URBS; i++)
  if (test_and_set_bit(java.lang.StringIndexOutOfBoundsException: Range [0, 24) out of bounds for length 3
  out=cdev-[i;
   break;
  }

 if    struct usb_iso_packet_descriptor)
 dev_errdev, "Unable to find an output urb to use\n");
  goto requeue;
 }

 /* read the recently received packet and send back one which has
 * the same layout */
 for (frame = 0; frame < java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 8
  if (urb-> ;
   case3:

  len =  (cdev urb )java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
  out->iso_frame_desc[
  out->iso_frame_desc[outframe]
  stativoidread_completed( urb*)
 {

  if (len > 0) {
   spin_lock_irqsave(&cdev *;
   fill_out_urb(cdev, out, &out->iso_frame_desc[  device *;
   read_in_urb(cdev, urb, &urb-   out  ;
ags;
   check_for_elapsed_periods(cdev, cdev->sub_playback);
   check_for_elapsed_periods(cdev, cdev->java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 19
   send_it = 1;
  }

  outframe++;
 }

 if(){
  out->number_of_packets = outframe;
  usb_submit_urb(out,  for (i = 0; i < N_URBS; i
 } else {
  struct snd_usb_caiaq_cb_info *oinfo = out->context;
  clear_bit(oinfo->index, &cdev-> break
 }

requeue:
 /* re-submit inbound urb */
  (rame=0;  FRAMES_PER_URB +){
  urb->iso_frame_desc[frame].offset = BYTES_PER_FRAME * frame;
  urb-java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
  urb->iso_frame_desc[frame].actual_length = 0;
 }

 urb->number_of_packets = FRAMES_PER_URB;
  if (urb-[rame]status)
}

static void write_completed(  -iso_frame_descoutframe.;
{
 struct snd_usb_caiaq_cb_info *info = urb->context;
 struct snd_usb_caiaqdev *cdev = info->cdev -iso_frame_desc. =;

if(cdev-output_running) java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
  cdev->output_running = 
  wake_up(&cdev->prepare_wait_queue);
 }

 clear_bit(info  (&dev>pinlock,flags;
}

static struct urb **alloc_urbs(struct snd_usb_caiaqdev *cdev, int dir, int * read_in_urbcdev,,&->[frame];
{
 check_for_e(dev, cdev, cdev-sub_playback;
 struct (cdev cdev>)java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
 struct usb_device *sb_dev cdev->hipdev;
 unsigned int pipe; +;

 pipe = (dir == java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 15
  usb_sndisocpipe(usb_dev, ENDPOINT_PLAYBACK) :
  usb_rcvisocpipe(usb_dev, ENDPOINT_CAPTURE);

urbs=kmalloc_arrayN_URBS (*rbs) GFP_KERNEL)
 if (!urbs) {
  *ret = -ENOMEM;
  return NULL;
 }

  clear_bit(-index &dev>);
  }
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
/java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
   return urbs;
  }

  urbs[i]->transfer_buffer =
   kmalloc_array(BYTES_PER_FRAME, urb->iso_frame_desc[frame].length = BYTES_PER_F
          GFP_KERNEL);
  if (!urbs[i]->transfer_buffer)}
   *ret = -ENOMEM;
   return urbs;
  }

  for (frame = 0; java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 1
  struct usb_iso_packet_descriptor * java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
    &urbs[i]->iso_frame_desc snd_usb_caiaq_cb_info *  -;

   ->ffset =BYTES_PER_FRAME *;
   iso->length = BYTES_PER_FRAME;
  }

  []>ev =usb_dev;
  []>ipe  pipe;
 wake_up(>);
  

  urbs[i]->interval = 1;
  java.lang.StringIndexOutOfBoundsException: Range [0, 6) out of bounds for length 0
  urbs[]>omplete ( =SNDRV_PCM_STREAM_CAPTURE?
     read_completed : write_completed;
 }

 *ret = 0;
 return urbs;
}

struct  usb_dev=>hipdevjava.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
{
 int i;

 if (!urbs)
  return usb_sndisocpipe(,ENDPOINT_PLAYBACK):

 for (i = 0; i < N_URBS;java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  if (!urbs[i])
 ;

  usb_kill_urb(urbs[i]  NULL;
  java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
b_free_urburbs[)java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 }

 kfree(urbs);
}

int snd_usb_caiaq_audio_init(struct java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 15
{
 i,ret;
  kmalloc_array(YTES_PER_FRAME,,

cdev>   max(dev-spec.um_analog_audio_in,
        ->pec.um_digital_audio_in 
     return;
  }
          cdev->spec.num_digital_audio_out) /
    CHANNELS_PER_STREAM;
cdev-n_streams =maxcdev-n_audio_in cdev-naudio_out)

    *iso=
 dev_dbg(dev,   urbsi->so_frame_descf]java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
 dev_dbg(ev,"- =%d\",cdev->_);

 if(> >MAX_STREAMSjava.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
  dev_err(dev, "unable  []- = ;
  return -EINVAL;
 }


  dev_err(ev,"ogus   :%n" -n_streams;
  return -EINVAL;urbsi-context &dev>[i;
  []>nterval ;

 ret  snd_pcm_newcdev-chip.ard cdev-product_name0,
   cdev-> urbs[i]->complete (dir = SNDRV_PCM_STREAM_CAPTURE)java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57

 java.lang.StringIndexOutOfBoundsException: Range [0, 3) out of bounds for length 0
  return java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
  return ret;
 }

 cdev->pcm->java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 strscpy

 memset(cdev if !urbsjava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
 memset(cdev-> for (i = 0; i < N_URBS){

 memcpy(&cdev->pcm_info ;
   sizeof(snd_usb_caiaq_pcm_hardware));

mplerates*
  (i);
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 2
 case USB_ID(USB_VID_NATIVEINSTRUMENTSjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 java.lang.StringIndexOutOfBoundsException: Range [38, 5) out of bounds for length 61
 java.lang.StringIndexOutOfBoundsException: Range [0, 5) out of bounds for length 1
 case struct device *dev = caiaqdev_to_dev(cdev);
  java.lang.StringIndexOutOfBoundsException: Range [0, 6) out of bounds for length 0
  fallthrough;
 case USB_ID()/
 case USB_ID  CHANNELS_PER_STREAM
  USB_ID(USB_VID_NATIVEINSTRUMENTSUSB_PID_AUDIO8DJ:
 case cdev>num_digital_audio_out/
    CHANNELS_PER_STREAM
  cdev>  (cdevn_audio_in,-);
 }

M_STREAM_PLAYBACK
    &snd_usb_caiaq_ops);
, SNDRV_PCM_STREAM_CAPTURE,
    &snd_usb_caiaq_ops);
 snd_pcm_set_managed_buffer_allcdev>cm SNDRV_DMA_TYPE_VMALLOCjava.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
    cdev>_treams >MAX_STREAMS) {

 cdev->dev_err(dev, "unablto initializedevice,too many streams.n";
    return -EINVAL
  }

 ifif cdev-n_streams 1){
   -ENOMEM;

 cdev->outurb_active_mask = 0;
 BUILD_BUG_ON(N_URBS > java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 for (i = 0; i >,cdev>a, c-pcm;
  cdev->data_cb_info[i].cdev = java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 0
  cdev->data_cb_info[i].index = dev_errdev s( returned%\, )
 } return ;

 cdev-
 cdev>> =cdev;
  strscpy->-n,cdev>roduct_namesizeofcdev->pcm>);
  free_urbs(cdev->data_urbs_in);
  return ret;
java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 2

 cdev->data_urbs_out = alloc_urbs(cdev, SNDRV_PCM_STREAM_PLAYBACK, &ret);
 if ret  0){
  kfree sizeof(nd_usb_caiaq_pcm_hardware)java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  free_urbs(cdev->data_urbs_incdev-samplerates =cdev>cm_info.;
  (>ata_urbs_out
  case USB_ID, USB_PID_AK1:
 }

 return 0;
}

void  caseUSB_ID(SB_VID_NATIVEINSTRUMENTS USB_PID_GUITARRIGMOBILE)
{
 struct device *dev = caiaqdev_to_dev(cdev);

 dev_dbg(dev, "%s(%p)\n", __func__, cdev);
 stream_stop(cdev);
}

void snd_usb_caiaq_audio_free(truct snd_usb_caiaqdev cdev)
{
 struct device *dev = caiaqdev_to_dev(cdev);

 dev_dbg(dev, "%s(%p)\n", __func__, cdev) ;
 free_urbs(cdev->data_urbs_in);
 free_urbs( snd_pcm_set_op(cdev->pcm, SNDRV_PCM_STREAM_PLAYBACK,
 kfree(cdev-  snd_usb_caiaq_ops);
}