Unplug ALSA cards as soon as we get the inotify message.

[nageru] / alsa_input.cpp

diff --git a/alsa_input.cpp b/alsa_input.cpp
index cf9c69f4dd877213ba3d0230aba98fefdf7bbd62..0ba07b145dc7a0fcc4f198fec772660d1f6088b8 100644 (file)
--- a/alsa_input.cpp
+++ b/alsa_input.cpp
@@ -450,19 +450,40 @@ ALSAPool::ProbeResult ALSAPool::probe_device_once(unsigned card_index, unsigned
        snd_ctl_card_info_alloca(&card_info);
        snd_ctl_card_info(ctl, card_info);
 
-       lock_guard<mutex> lock(mu);
-       unsigned internal_dev_index = find_free_device_index();
-       devices[internal_dev_index].address = address;
-       devices[internal_dev_index].name = snd_ctl_card_info_get_name(card_info);
-       devices[internal_dev_index].info = snd_pcm_info_get_name(pcm_info);
-       devices[internal_dev_index].num_channels = num_channels;
-       devices[internal_dev_index].state = Device::State::READY;
+       string name = snd_ctl_card_info_get_name(card_info);
+       string info = snd_pcm_info_get_name(pcm_info);
+
+       unsigned internal_dev_index;
+       {
+               lock_guard<mutex> lock(mu);
+               internal_dev_index = find_free_device_index(name, info, num_channels, address);
+               devices[internal_dev_index].address = address;
+               devices[internal_dev_index].name = name;
+               devices[internal_dev_index].info = info;
+               devices[internal_dev_index].num_channels = num_channels;
+               // Note: Purposefully does not overwrite held.
+       }
 
        fprintf(stderr, "%s: Probed successfully.\n", address);
 
+       reset_device(internal_dev_index);  // Restarts it if it is held (ie., we just replaced a dead card).
+
        return ALSAPool::ProbeResult::SUCCESS;
 }
 
+void ALSAPool::unplug_device(unsigned card_index, unsigned dev_index)
+{
+       char address[256];
+       snprintf(address, sizeof(address), "hw:%d,%d", card_index, dev_index);
+       for (unsigned i = 0; i < devices.size(); ++i) {
+               if (devices[i].state != Device::State::EMPTY &&
+                   devices[i].state != Device::State::DEAD &&
+                   devices[i].address == address) {
+                       free_card(i);
+               }
+       }
+}
+
 void ALSAPool::init()
 {
        thread(&ALSAPool::inotify_thread_func, this).detach();
@@ -511,7 +532,7 @@ void ALSAPool::inotify_thread_func()
                        if (sscanf(event->name, "pcmC%uD%u%c", &card, &device, &type) == 3 && type == 'c') {
                                if (event->mask & (IN_MOVED_FROM | IN_DELETE)) {
                                        printf("Deleted capture device: Card %u, device %u\n", card, device);
-                                       // TODO: Unplug.
+                                       unplug_device(card, device);
                                }
                                if (event->mask & (IN_MOVED_TO | IN_CREATE)) {
                                        printf("Adding capture device: Card %u, device %u\n", card, device);
@@ -570,16 +591,47 @@ void ALSAPool::set_card_state(unsigned index, ALSAPool::Device::State state)
                ;
 }
 
-unsigned ALSAPool::find_free_device_index()
+unsigned ALSAPool::find_free_device_index(const string &name, const string &info, unsigned num_channels, const string &address)
 {
+       // First try to find an exact match on a dead card.
+       for (unsigned i = 0; i < devices.size(); ++i) {
+               if (devices[i].state == Device::State::DEAD &&
+                   devices[i].address == address &&
+                   devices[i].name == name &&
+                   devices[i].info == info &&
+                   devices[i].num_channels == num_channels) {
+                       devices[i].state = Device::State::READY;
+                       return i;
+               }
+       }
+
+       // Then try to find a match on everything but the address
+       // (probably that devices were plugged back in a different order).
+       // If we have two cards that are equal, this might get them mixed up,
+       // but we don't have anything better.
+       for (unsigned i = 0; i < devices.size(); ++i) {
+               if (devices[i].state == Device::State::DEAD &&
+                   devices[i].name == name &&
+                   devices[i].info == info &&
+                   devices[i].num_channels == num_channels) {
+                       devices[i].state = Device::State::READY;
+                       return i;
+               }
+       }
+
+       // OK, so we didn't find a match; see if there are any empty slots.
        for (unsigned i = 0; i < devices.size(); ++i) {
                if (devices[i].state == Device::State::EMPTY) {
                        devices[i].state = Device::State::READY;
+                       devices[i].held = false;
                        return i;
                }
        }
+
+       // Failing that, we just insert the new device at the end.
        Device new_dev;
        new_dev.state = Device::State::READY;
+       new_dev.held = false;
        devices.push_back(new_dev);
        inputs.emplace_back(nullptr);
        return devices.size() - 1;