mutex_unlock(&card_mutex);
}
-/* ------------------------------------------------------------------ */
-/* Code to handle 1394a broadcast channel */
-
-#define THIRTY_TWO_CHANNELS (0xFFFFFFFFU)
-#define IRM_RETRIES 2
-
-/*
- * The abi is set by device_for_each_child(), even though we have no use
- * for data, nor do we have a meaningful return value.
- */
-int fw_irm_set_broadcast_channel_register(struct device *dev, void *data)
+static int set_broadcast_channel(struct device *dev, void *data)
{
- struct fw_device *d;
- int rcode;
- int node_id;
- int max_speed;
- int retries;
- int generation;
- __be32 regval;
- struct fw_card *card;
-
- d = fw_device(dev);
- /* FIXME: do we need locking here? */
- generation = d->generation;
- smp_rmb(); /* Ensure generation is at least as old as node_id */
- node_id = d->node_id;
- max_speed = d->max_speed;
- retries = IRM_RETRIES;
- card = d->card;
-tryagain_r:
- rcode = fw_run_transaction(card, TCODE_READ_QUADLET_REQUEST,
- node_id, generation, max_speed,
- CSR_REGISTER_BASE + CSR_BROADCAST_CHANNEL,
- ®val, 4);
- switch (rcode) {
- case RCODE_BUSY:
- if (retries--)
- goto tryagain_r;
- fw_notify("node %x read broadcast channel busy\n",
- node_id);
- return 0;
-
- default:
- fw_notify("node %x read broadcast channel failed %x\n",
- node_id, rcode);
- return 0;
-
- case RCODE_COMPLETE:
- /*
- * Paranoid reporting of nonstandard broadcast channel
- * contents goes here
- */
- if (regval != cpu_to_be32(BROADCAST_CHANNEL_INITIAL))
- return 0;
- break;
- }
- retries = IRM_RETRIES;
- regval = cpu_to_be32(BROADCAST_CHANNEL_INITIAL |
- BROADCAST_CHANNEL_VALID);
-tryagain_w:
- rcode = fw_run_transaction(card,
- TCODE_WRITE_QUADLET_REQUEST, node_id,
- generation, max_speed,
- CSR_REGISTER_BASE + CSR_BROADCAST_CHANNEL,
- ®val, 4);
- switch (rcode) {
- case RCODE_BUSY:
- if (retries--)
- goto tryagain_w;
- fw_notify("node %x write broadcast channel busy\n",
- node_id);
- return 0;
-
- default:
- fw_notify("node %x write broadcast channel failed %x\n",
- node_id, rcode);
- return 0;
-
- case RCODE_COMPLETE:
- return 0;
- }
+ fw_device_set_broadcast_channel(fw_device(dev), (long)data);
return 0;
}
-static void
-irm_allocate_broadcast(struct fw_device *irm_dev, struct device *locald)
+static void allocate_broadcast_channel(struct fw_card *card, int generation)
{
- u32 generation;
- u32 node_id;
- u32 max_speed;
- u32 retries;
- __be32 old_data;
- __be32 lock_data[2];
- int rcode;
-
- /*
- * The device we are updating is the IRM, so we must do
- * some extra work.
- */
- retries = IRM_RETRIES;
- generation = irm_dev->generation;
- /* FIXME: do we need locking here? */
- smp_rmb();
- node_id = irm_dev->node_id;
- max_speed = irm_dev->max_speed;
-
- lock_data[0] = cpu_to_be32(THIRTY_TWO_CHANNELS);
- lock_data[1] = cpu_to_be32(THIRTY_TWO_CHANNELS & ~1);
-tryagain:
- old_data = lock_data[0];
- rcode = fw_run_transaction(irm_dev->card, TCODE_LOCK_COMPARE_SWAP,
- node_id, generation, max_speed,
- CSR_REGISTER_BASE+CSR_CHANNELS_AVAILABLE_HI,
- &lock_data[0], 8);
- switch (rcode) {
- case RCODE_BUSY:
- if (retries--)
- goto tryagain;
- /* fallthrough */
- default:
- fw_error("node %x: allocate broadcast channel failed (%x)\n",
- node_id, rcode);
- return;
-
- case RCODE_COMPLETE:
- if (lock_data[0] == old_data)
- break;
- if (retries--) {
- lock_data[1] = cpu_to_be32(be32_to_cpu(lock_data[0])&~1);
- goto tryagain;
- }
- fw_error("node %x: allocate broadcast channel failed: too many"
- " retries\n", node_id);
- return;
+ int channel, bandwidth = 0;
+
+ fw_iso_resource_manage(card, generation, 1ULL << 31,
+ &channel, &bandwidth, true);
+ if (channel == 31) {
+ card->broadcast_channel_allocated = true;
+ device_for_each_child(card->device, (void *)(long)generation,
+ set_broadcast_channel);
}
- irm_dev->card->is_irm = true;
- device_for_each_child(locald, NULL, fw_irm_set_broadcast_channel_register);
}
-/* ------------------------------------------------------------------ */
-
static const char gap_count_table[] = {
63, 5, 7, 8, 10, 13, 16, 18, 21, 24, 26, 29, 32, 35, 37, 40
static void fw_card_bm_work(struct work_struct *work)
{
struct fw_card *card = container_of(work, struct fw_card, work.work);
- struct fw_device *root_device, *irm_device, *local_device;
- struct fw_node *root_node, *local_node, *irm_node;
+ struct fw_device *root_device;
+ struct fw_node *root_node;
unsigned long flags;
- int root_id, new_root_id, irm_id, gap_count, generation, grace, rcode;
+ int root_id, new_root_id, irm_id, local_id;
+ int gap_count, generation, grace, rcode;
bool do_reset = false;
bool root_device_is_running;
bool root_device_is_cmc;
__be32 lock_data[2];
spin_lock_irqsave(&card->lock, flags);
- card->is_irm = false;
- local_node = card->local_node;
- root_node = card->root_node;
- irm_node = card->irm_node;
- if (local_node == NULL) {
+ if (card->local_node == NULL) {
spin_unlock_irqrestore(&card->lock, flags);
goto out_put_card;
}
- fw_node_get(local_node);
- fw_node_get(root_node);
- fw_node_get(irm_node);
generation = card->generation;
+ root_node = card->root_node;
+ fw_node_get(root_node);
root_device = root_node->data;
root_device_is_running = root_device &&
atomic_read(&root_device->state) == FW_DEVICE_RUNNING;
root_device_is_cmc = root_device && root_device->cmc;
- root_id = root_node->node_id;
- irm_device = irm_node->data;
- local_device = local_node->data;
+ root_id = root_node->node_id;
+ irm_id = card->irm_node->node_id;
+ local_id = card->local_node->node_id;
grace = time_after(jiffies, card->reset_jiffies + DIV_ROUND_UP(HZ, 8));
* next generation.
*/
- irm_id = irm_node->node_id;
- if (!irm_node->link_on) {
- new_root_id = local_node->node_id;
+ if (!card->irm_node->link_on) {
+ new_root_id = local_id;
fw_notify("IRM has link off, making local node (%02x) root.\n",
new_root_id);
goto pick_me;
}
lock_data[0] = cpu_to_be32(0x3f);
- lock_data[1] = cpu_to_be32(local_node->node_id);
+ lock_data[1] = cpu_to_be32(local_id);
spin_unlock_irqrestore(&card->lock, flags);
if (rcode == RCODE_COMPLETE &&
lock_data[0] != cpu_to_be32(0x3f)) {
- /* Somebody else is BM, let them do the work. */
- if (irm_id == local_node->node_id) {
- /* But we are IRM, so do irm-y things */
- irm_allocate_broadcast(irm_device,
- card->device);
- }
+
+ /* Somebody else is BM. Only act as IRM. */
+ if (local_id == irm_id)
+ allocate_broadcast_channel(card, generation);
+
goto out;
}
* do a bus reset and pick the local node as
* root, and thus, IRM.
*/
- new_root_id = local_node->node_id;
+ new_root_id = local_id;
fw_notify("BM lock failed, making local node (%02x) root.\n",
new_root_id);
goto pick_me;
* Either link_on is false, or we failed to read the
* config rom. In either case, pick another root.
*/
- new_root_id = local_node->node_id;
+ new_root_id = local_id;
} else if (!root_device_is_running) {
/*
* If we haven't probed this device yet, bail out now
* successfully read the config rom, but it's not
* cycle master capable.
*/
- new_root_id = local_node->node_id;
+ new_root_id = local_id;
}
pick_me:
card->index, new_root_id, gap_count);
fw_send_phy_config(card, new_root_id, generation, gap_count);
fw_core_initiate_bus_reset(card, 1);
- } else if (irm_node->node_id == local_node->node_id) {
- /*
- * We are IRM, so do irm-y things.
- * There's no reason to do this if we're doing a reset. . .
- * We'll be back.
- */
- irm_allocate_broadcast(irm_device, card->device);
+ /* Will allocate broadcast channel after the reset. */
+ } else {
+ if (local_id == irm_id)
+ allocate_broadcast_channel(card, generation);
}
out:
fw_node_put(root_node);
- fw_node_put(local_node);
- fw_node_put(irm_node);
out_put_card:
fw_card_put(card);
}
projects / karo-tx-linux.git / blobdiff