Merge branch 'topic/usb-mixer-cache' into next/usb-audio

5 files changed, 91 insertions, 68 deletions

diff --git a/sound/usb/caiaq/caiaq-device.c b/sound/usb/caiaq/caiaq-device.c
index a62500e387a6..41c36b055f6b 100644
--- a/sound/usb/caiaq/caiaq-device.c
+++ b/sound/usb/caiaq/caiaq-device.c
@@ -42,7 +42,7 @@
 #endif
 
 MODULE_AUTHOR("Daniel Mack <daniel@caiaq.de>");
-MODULE_DESCRIPTION("caiaq USB audio, version 1.3.9");
+MODULE_DESCRIPTION("caiaq USB audio, version 1.3.10");
 MODULE_LICENSE("GPL");
 MODULE_SUPPORTED_DEVICE("{{Native Instruments, RigKontrol2},"
                          "{Native Instruments, RigKontrol3},"
diff --git a/sound/usb/caiaq/caiaq-device.h b/sound/usb/caiaq/caiaq-device.h
index f9fbdbae269d..ab56e738c5fc 100644
--- a/sound/usb/caiaq/caiaq-device.h
+++ b/sound/usb/caiaq/caiaq-device.h
@@ -75,6 +75,7 @@ struct snd_usb_caiaqdev {
         wait_queue_head_t ep1_wait_queue;
         wait_queue_head_t prepare_wait_queue;
         int spec_received, audio_parm_answer;
+        int midi_out_active;
 
         char vendor_name[CAIAQ_USB_STR_LEN];
         char product_name[CAIAQ_USB_STR_LEN];
diff --git a/sound/usb/caiaq/caiaq-midi.c b/sound/usb/caiaq/caiaq-midi.c
index 30b57f97c6e4..f19fd360c936 100644
--- a/sound/usb/caiaq/caiaq-midi.c
+++ b/sound/usb/caiaq/caiaq-midi.c
@@ -59,6 +59,11 @@ static int snd_usb_caiaq_midi_output_open(struct snd_rawmidi_substream *substrea
 
 static int snd_usb_caiaq_midi_output_close(struct snd_rawmidi_substream *substream)
 {
+        struct snd_usb_caiaqdev *dev = substream->rmidi->private_data;
+        if (dev->midi_out_active) {
+                usb_kill_urb(&dev->midi_out_urb);
+                dev->midi_out_active = 0;
+        }
         return 0;
 }
 
@@ -69,7 +74,8 @@ static void snd_usb_caiaq_midi_send(struct snd_usb_caiaqdev *dev,
         
         dev->midi_out_buf[0] = EP1_CMD_MIDI_WRITE;
         dev->midi_out_buf[1] = 0; /* port */
-        len = snd_rawmidi_transmit_peek(substream, dev->midi_out_buf+3, EP1_BUFSIZE-3);
+        len = snd_rawmidi_transmit(substream, dev->midi_out_buf + 3,
+                                   EP1_BUFSIZE - 3);
         
         if (len <= 0)
                 return;
@@ -79,24 +85,24 @@ static void snd_usb_caiaq_midi_send(struct snd_usb_caiaqdev *dev,
         
         ret = usb_submit_urb(&dev->midi_out_urb, GFP_ATOMIC);
         if (ret < 0)
-                log("snd_usb_caiaq_midi_send(%p): usb_submit_urb() failed, %d\n",
-                                substream, ret);
+                log("snd_usb_caiaq_midi_send(%p): usb_submit_urb() failed,"
+                    "ret=%d, len=%d\n",
+                    substream, ret, len);
+        else
+                dev->midi_out_active = 1;
 }
 
 static void snd_usb_caiaq_midi_output_trigger(struct snd_rawmidi_substream *substream, int up)
 {
         struct snd_usb_caiaqdev *dev = substream->rmidi->private_data;
         
-        if (dev->midi_out_substream != NULL)
-                return;
-        
-        if (!up) {
+        if (up) {
+                dev->midi_out_substream = substream;
+                if (!dev->midi_out_active)
+                        snd_usb_caiaq_midi_send(dev, substream);
+        } else {
                 dev->midi_out_substream = NULL;
-                return;
         }
-        
-        dev->midi_out_substream = substream;
-        snd_usb_caiaq_midi_send(dev, substream);
 }
 
 
@@ -161,16 +167,14 @@ int snd_usb_caiaq_midi_init(struct snd_usb_caiaqdev *device)
 void snd_usb_caiaq_midi_output_done(struct urb* urb)
 {
         struct snd_usb_caiaqdev *dev = urb->context;
-        char *buf = urb->transfer_buffer;
         
+        dev->midi_out_active = 0;
         if (urb->status != 0)
                 return;
 
         if (!dev->midi_out_substream)
                 return;
 
-        snd_rawmidi_transmit_ack(dev->midi_out_substream, buf[2]);
-        dev->midi_out_substream = NULL;
         snd_usb_caiaq_midi_send(dev, dev->midi_out_substream);
 }
 
diff --git a/sound/usb/usbmixer.c b/sound/usb/usbmixer.c
index bc8bd00047ad..330f2fbff2d1 100644
--- a/sound/usb/usbmixer.c
+++ b/sound/usb/usbmixer.c
@@ -111,6 +111,8 @@ struct mixer_build {
         const struct usbmix_selector_map *selector_map;
 };
 
+#define MAX_CHANNELS    10      /* max logical channels */
+
 struct usb_mixer_elem_info {
         struct usb_mixer_interface *mixer;
         struct usb_mixer_elem_info *next_id_elem; /* list of controls with same id */
@@ -121,6 +123,8 @@ struct usb_mixer_elem_info {
         int channels;
         int val_type;
         int min, max, res;
+        int cached;
+        int cache_val[MAX_CHANNELS];
         u8 initialized;
 };
 
@@ -182,8 +186,6 @@ enum {
         USB_PROC_DCR_RELEASE = 6,
 };
 
-#define MAX_CHANNELS    10      /* max logical channels */
-
 
 /*
  * manual mapping of mixer names
@@ -377,11 +379,35 @@ static int get_cur_ctl_value(struct usb_mixer_elem_info *cval, int validx, int *
 }
 
 /* channel = 0: master, 1 = first channel */
-static inline int get_cur_mix_value(struct usb_mixer_elem_info *cval, int channel, int *value)
+static inline int get_cur_mix_raw(struct usb_mixer_elem_info *cval,
+                                  int channel, int *value)
 {
         return get_ctl_value(cval, GET_CUR, (cval->control << 8) | channel, value);
 }
 
+static int get_cur_mix_value(struct usb_mixer_elem_info *cval,
+                             int channel, int index, int *value)
+{
+        int err;
+
+        if (cval->cached & (1 << channel)) {
+                *value = cval->cache_val[index];
+                return 0;
+        }
+        err = get_cur_mix_raw(cval, channel, value);
+        if (err < 0) {
+                if (!cval->mixer->ignore_ctl_error)
+                        snd_printd(KERN_ERR "cannot get current value for "
+                                   "control %d ch %d: err = %d\n",
+                                   cval->control, channel, err);
+                return err;
+        }
+        cval->cached |= 1 << channel;
+        cval->cache_val[index] = *value;
+        return 0;
+}
+
+
 /*
  * set a mixer value
  */
@@ -413,9 +439,17 @@ static int set_cur_ctl_value(struct usb_mixer_elem_info *cval, int validx, int v
         return set_ctl_value(cval, SET_CUR, validx, value);
 }
 
-static inline int set_cur_mix_value(struct usb_mixer_elem_info *cval, int channel, int value)
+static int set_cur_mix_value(struct usb_mixer_elem_info *cval, int channel,
+                             int index, int value)
 {
-        return set_ctl_value(cval, SET_CUR, (cval->control << 8) | channel, value);
+        int err;
+        err = set_ctl_value(cval, SET_CUR, (cval->control << 8) | channel,
+                            value);
+        if (err < 0)
+                return err;
+        cval->cached |= 1 << channel;
+        cval->cache_val[index] = value;
+        return 0;
 }
 
 /*
@@ -719,7 +753,7 @@ static int get_min_max(struct usb_mixer_elem_info *cval, int default_min)
                 if (cval->min + cval->res < cval->max) {
                         int last_valid_res = cval->res;
                         int saved, test, check;
-                        get_cur_mix_value(cval, minchn, &saved);
+                        get_cur_mix_raw(cval, minchn, &saved);
                         for (;;) {
                                 test = saved;
                                 if (test < cval->max)
@@ -727,8 +761,8 @@ static int get_min_max(struct usb_mixer_elem_info *cval, int default_min)
                                 else
                                         test -= cval->res;
                                 if (test < cval->min || test > cval->max ||
-                                    set_cur_mix_value(cval, minchn, test) ||
-                                    get_cur_mix_value(cval, minchn, &check)) {
+                                    set_cur_mix_value(cval, minchn, 0, test) ||
+                                    get_cur_mix_raw(cval, minchn, &check)) {
                                         cval->res = last_valid_res;
                                         break;
                                 }
@@ -736,7 +770,7 @@ static int get_min_max(struct usb_mixer_elem_info *cval, int default_min)
                                         break;
                                 cval->res *= 2;
                         }
-                        set_cur_mix_value(cval, minchn, saved);
+                        set_cur_mix_value(cval, minchn, 0, saved);
                 }
 
                 cval->initialized = 1;
@@ -776,35 +810,25 @@ static int mixer_ctl_feature_get(struct snd_kcontrol *kcontrol, struct snd_ctl_e
         struct usb_mixer_elem_info *cval = kcontrol->private_data;
         int c, cnt, val, err;
 
+        ucontrol->value.integer.value[0] = cval->min;
         if (cval->cmask) {
                 cnt = 0;
                 for (c = 0; c < MAX_CHANNELS; c++) {
-                        if (cval->cmask & (1 << c)) {
-                                err = get_cur_mix_value(cval, c + 1, &val);
-                                if (err < 0) {
-                                        if (cval->mixer->ignore_ctl_error) {
-                                                ucontrol->value.integer.value[0] = cval->min;
-                                                return 0;
-                                        }
-                                        snd_printd(KERN_ERR "cannot get current value for control %d ch %d: err = %d\n", cval->control, c + 1, err);
-                                        return err;
-                                }
-                                val = get_relative_value(cval, val);
-                                ucontrol->value.integer.value[cnt] = val;
-                                cnt++;
-                        }
+                        if (!(cval->cmask & (1 << c)))
+                                continue;
+                        err = get_cur_mix_value(cval, c + 1, cnt, &val);
+                        if (err < 0)
+                                return cval->mixer->ignore_ctl_error ? 0 : err;
+                        val = get_relative_value(cval, val);
+                        ucontrol->value.integer.value[cnt] = val;
+                        cnt++;
                 }
+                return 0;
         } else {
                 /* master channel */
-                err = get_cur_mix_value(cval, 0, &val);
-                if (err < 0) {
-                        if (cval->mixer->ignore_ctl_error) {
-                                ucontrol->value.integer.value[0] = cval->min;
-                                return 0;
-                        }
-                        snd_printd(KERN_ERR "cannot get current value for control %d master ch: err = %d\n", cval->control, err);
-                        return err;
-                }
+                err = get_cur_mix_value(cval, 0, 0, &val);
+                if (err < 0)
+                        return cval->mixer->ignore_ctl_error ? 0 : err;
                 val = get_relative_value(cval, val);
                 ucontrol->value.integer.value[0] = val;
         }
@@ -821,34 +845,28 @@ static int mixer_ctl_feature_put(struct snd_kcontrol *kcontrol, struct snd_ctl_e
         if (cval->cmask) {
                 cnt = 0;
                 for (c = 0; c < MAX_CHANNELS; c++) {
-                        if (cval->cmask & (1 << c)) {
-                                err = get_cur_mix_value(cval, c + 1, &oval);
-                                if (err < 0) {
-                                        if (cval->mixer->ignore_ctl_error)
-                                                return 0;
-                                        return err;
-                                }
-                                val = ucontrol->value.integer.value[cnt];
-                                val = get_abs_value(cval, val);
-                                if (oval != val) {
-                                        set_cur_mix_value(cval, c + 1, val);
-                                        changed = 1;
-                                }
-                                get_cur_mix_value(cval, c + 1, &val);
-                                cnt++;
+                        if (!(cval->cmask & (1 << c)))
+                                continue;
+                        err = get_cur_mix_value(cval, c + 1, cnt, &oval);
+                        if (err < 0)
+                                return cval->mixer->ignore_ctl_error ? 0 : err;
+                        val = ucontrol->value.integer.value[cnt];
+                        val = get_abs_value(cval, val);
+                        if (oval != val) {
+                                set_cur_mix_value(cval, c + 1, cnt, val);
+                                changed = 1;
                         }
+                        cnt++;
                 }
         } else {
                 /* master channel */
-                err = get_cur_mix_value(cval, 0, &oval);
-                if (err < 0 && cval->mixer->ignore_ctl_error)
-                        return 0;
+                err = get_cur_mix_value(cval, 0, 0, &oval);
                 if (err < 0)
-                        return err;
+                        return cval->mixer->ignore_ctl_error ? 0 : err;
                 val = ucontrol->value.integer.value[0];
                 val = get_abs_value(cval, val);
                 if (val != oval) {
-                        set_cur_mix_value(cval, 0, val);
+                        set_cur_mix_value(cval, 0, 0, val);
                         changed = 1;
                 }
         }
diff --git a/sound/usb/usx2y/usbusx2y.c b/sound/usb/usx2y/usbusx2y.c
index ca26c532e77e..11639bd72a51 100644
--- a/sound/usb/usx2y/usbusx2y.c
+++ b/sound/usb/usx2y/usbusx2y.c
@@ -238,7 +238,7 @@ static void i_usX2Y_In04Int(struct urb *urb)
                                         send = 0;
                                 for (j = 0; j < URBS_AsyncSeq  &&  !err; ++j)
                                         if (0 == usX2Y->AS04.urb[j]->status) {
-                                                struct us428_p4out *p4out = us428ctls->p4out + send;    // FIXME if more then 1 p4out is new, 1 gets lost.
+                                                struct us428_p4out *p4out = us428ctls->p4out + send;    // FIXME if more than 1 p4out is new, 1 gets lost.
                                                 usb_fill_bulk_urb(usX2Y->AS04.urb[j], usX2Y->chip.dev,
                                                                   usb_sndbulkpipe(usX2Y->chip.dev, 0x04), &p4out->val.vol, 
                                                                   p4out->type == eLT_Light ? sizeof(struct us428_lights) : 5,