Commit 86c8dd7f authored by Takashi Sakamoto's avatar Takashi Sakamoto Committed by Takashi Iwai

ALSA: firewire-digi00x: delayed registration of sound card

When some digi00x units are connected sequentially, userspace
applications are involved at bus-reset state on IEEE 1394 bus. In the
state, any communications can be canceled. Therefore, sound card
registration should be delayed till the bus gets calm.

This commit achieves it.
Signed-off-by: default avatarTakashi Sakamoto <o-takashi@sakamocchi.jp>
Signed-off-by: default avatarTakashi Iwai <tiwai@suse.de>
parent 6c29230e
...@@ -126,12 +126,17 @@ int snd_dg00x_transaction_register(struct snd_dg00x *dg00x) ...@@ -126,12 +126,17 @@ int snd_dg00x_transaction_register(struct snd_dg00x *dg00x)
return err; return err;
error: error:
fw_core_remove_address_handler(&dg00x->async_handler); fw_core_remove_address_handler(&dg00x->async_handler);
dg00x->async_handler.address_callback = NULL; dg00x->async_handler.callback_data = NULL;
return err; return err;
} }
void snd_dg00x_transaction_unregister(struct snd_dg00x *dg00x) void snd_dg00x_transaction_unregister(struct snd_dg00x *dg00x)
{ {
if (dg00x->async_handler.callback_data == NULL)
return;
snd_fw_async_midi_port_destroy(&dg00x->out_control); snd_fw_async_midi_port_destroy(&dg00x->out_control);
fw_core_remove_address_handler(&dg00x->async_handler); fw_core_remove_address_handler(&dg00x->async_handler);
dg00x->async_handler.callback_data = NULL;
} }
...@@ -40,10 +40,8 @@ static int name_card(struct snd_dg00x *dg00x) ...@@ -40,10 +40,8 @@ static int name_card(struct snd_dg00x *dg00x)
return 0; return 0;
} }
static void dg00x_card_free(struct snd_card *card) static void dg00x_free(struct snd_dg00x *dg00x)
{ {
struct snd_dg00x *dg00x = card->private_data;
snd_dg00x_stream_destroy_duplex(dg00x); snd_dg00x_stream_destroy_duplex(dg00x);
snd_dg00x_transaction_unregister(dg00x); snd_dg00x_transaction_unregister(dg00x);
...@@ -52,28 +50,24 @@ static void dg00x_card_free(struct snd_card *card) ...@@ -52,28 +50,24 @@ static void dg00x_card_free(struct snd_card *card)
mutex_destroy(&dg00x->mutex); mutex_destroy(&dg00x->mutex);
} }
static int snd_dg00x_probe(struct fw_unit *unit, static void dg00x_card_free(struct snd_card *card)
const struct ieee1394_device_id *entry)
{ {
struct snd_card *card; dg00x_free(card->private_data);
struct snd_dg00x *dg00x; }
int err;
/* create card */ static void do_registration(struct work_struct *work)
err = snd_card_new(&unit->device, -1, NULL, THIS_MODULE, {
sizeof(struct snd_dg00x), &card); struct snd_dg00x *dg00x =
if (err < 0) container_of(work, struct snd_dg00x, dwork.work);
return err; int err;
card->private_free = dg00x_card_free;
/* initialize myself */ if (dg00x->registered)
dg00x = card->private_data; return;
dg00x->card = card;
dg00x->unit = fw_unit_get(unit);
mutex_init(&dg00x->mutex); err = snd_card_new(&dg00x->unit->device, -1, NULL, THIS_MODULE, 0,
spin_lock_init(&dg00x->lock); &dg00x->card);
init_waitqueue_head(&dg00x->hwdep_wait); if (err < 0)
return;
err = name_card(dg00x); err = name_card(dg00x);
if (err < 0) if (err < 0)
...@@ -101,35 +95,86 @@ static int snd_dg00x_probe(struct fw_unit *unit, ...@@ -101,35 +95,86 @@ static int snd_dg00x_probe(struct fw_unit *unit,
if (err < 0) if (err < 0)
goto error; goto error;
err = snd_card_register(card); err = snd_card_register(dg00x->card);
if (err < 0) if (err < 0)
goto error; goto error;
dev_set_drvdata(&unit->device, dg00x); dg00x->card->private_free = dg00x_card_free;
dg00x->card->private_data = dg00x;
dg00x->registered = true;
return err; return;
error: error:
snd_card_free(card); snd_dg00x_transaction_unregister(dg00x);
return err; snd_dg00x_stream_destroy_duplex(dg00x);
snd_card_free(dg00x->card);
dev_info(&dg00x->unit->device,
"Sound card registration failed: %d\n", err);
}
static int snd_dg00x_probe(struct fw_unit *unit,
const struct ieee1394_device_id *entry)
{
struct snd_dg00x *dg00x;
/* Allocate this independent of sound card instance. */
dg00x = kzalloc(sizeof(struct snd_dg00x), GFP_KERNEL);
if (dg00x == NULL)
return -ENOMEM;
dg00x->unit = fw_unit_get(unit);
dev_set_drvdata(&unit->device, dg00x);
mutex_init(&dg00x->mutex);
spin_lock_init(&dg00x->lock);
init_waitqueue_head(&dg00x->hwdep_wait);
/* Allocate and register this sound card later. */
INIT_DEFERRABLE_WORK(&dg00x->dwork, do_registration);
snd_fw_schedule_registration(unit, &dg00x->dwork);
return 0;
} }
static void snd_dg00x_update(struct fw_unit *unit) static void snd_dg00x_update(struct fw_unit *unit)
{ {
struct snd_dg00x *dg00x = dev_get_drvdata(&unit->device); struct snd_dg00x *dg00x = dev_get_drvdata(&unit->device);
/* Postpone a workqueue for deferred registration. */
if (!dg00x->registered)
snd_fw_schedule_registration(unit, &dg00x->dwork);
snd_dg00x_transaction_reregister(dg00x); snd_dg00x_transaction_reregister(dg00x);
/*
* After registration, userspace can start packet streaming, then this
* code block works fine.
*/
if (dg00x->registered) {
mutex_lock(&dg00x->mutex); mutex_lock(&dg00x->mutex);
snd_dg00x_stream_update_duplex(dg00x); snd_dg00x_stream_update_duplex(dg00x);
mutex_unlock(&dg00x->mutex); mutex_unlock(&dg00x->mutex);
}
} }
static void snd_dg00x_remove(struct fw_unit *unit) static void snd_dg00x_remove(struct fw_unit *unit)
{ {
struct snd_dg00x *dg00x = dev_get_drvdata(&unit->device); struct snd_dg00x *dg00x = dev_get_drvdata(&unit->device);
/*
* Confirm to stop the work for registration before the sound card is
* going to be released. The work is not scheduled again because bus
* reset handler is not called anymore.
*/
cancel_delayed_work_sync(&dg00x->dwork);
if (dg00x->registered) {
/* No need to wait for releasing card object in this context. */ /* No need to wait for releasing card object in this context. */
snd_card_free_when_closed(dg00x->card); snd_card_free_when_closed(dg00x->card);
} else {
/* Don't forget this case. */
dg00x_free(dg00x);
}
} }
static const struct ieee1394_device_id snd_dg00x_id_table[] = { static const struct ieee1394_device_id snd_dg00x_id_table[] = {
......
...@@ -37,6 +37,9 @@ struct snd_dg00x { ...@@ -37,6 +37,9 @@ struct snd_dg00x {
struct mutex mutex; struct mutex mutex;
spinlock_t lock; spinlock_t lock;
bool registered;
struct delayed_work dwork;
struct amdtp_stream tx_stream; struct amdtp_stream tx_stream;
struct fw_iso_resources tx_resources; struct fw_iso_resources tx_resources;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment