Commit 036176d9 authored by Takashi Sakamoto's avatar Takashi Sakamoto
Browse files

firewire: core: abort pending transactions at card removal 

IEEE 1394 defines the split, concatenated, and unified transaction.
To support the split transaction, core function uses linked list to
maintain the transactions waiting for acknowledge packet. After clearing
sources of hardware interrupts, the acknowledge packet is no longer
handled, therefore it is required to abort the pending transactions.

This commit executes callback with RCODE_CANCELLED for the pending
transactions at card removal.

Link: https://lore.kernel.org/r/20251111223834.311287-1-o-takashi@sakamocchi.jp


Signed-off-by: default avatarTakashi Sakamoto <o-takashi@sakamocchi.jp>
parent ae1ef2fb

drivers/firewire/core-card.c

+1 −0
Original line number Diff line number Diff line
@@ -790,6 +790,7 @@ void fw_core_remove_card(struct fw_card *card) 
	drain_workqueue(card->isoc_wq);

	drain_workqueue(card->async_wq);

	card->driver->disable(card);

	fw_cancel_pending_transactions(card);



	scoped_guard(spinlock_irqsave, &card->lock)

		fw_destroy_nodes(card);

drivers/firewire/core-transaction.c

+28 −0
Original line number Diff line number Diff line
@@ -51,6 +51,34 @@ static void remove_transaction_entry(struct fw_card *card, struct fw_transaction 
	card->transactions.tlabel_mask &= ~(1ULL << entry->tlabel);

}



// Must be called without holding card->transactions.lock.

void fw_cancel_pending_transactions(struct fw_card *card)

{

	struct fw_transaction *t, *tmp;

	LIST_HEAD(pending_list);



	// NOTE: This can be without irqsave when we can guarantee that __fw_send_request() for

	// local destination never runs in any type of IRQ context.

	scoped_guard(spinlock_irqsave, &card->transactions.lock) {

		list_for_each_entry_safe(t, tmp, &card->transactions.list, link) {

			if (try_cancel_split_timeout(t))

				list_move(&t->link, &pending_list);

		}

	}



	list_for_each_entry_safe(t, tmp, &pending_list, link) {

		list_del(&t->link);



		if (!t->with_tstamp) {

			t->callback.without_tstamp(card, RCODE_CANCELLED, NULL, 0,

						   t->callback_data);

		} else {

			t->callback.with_tstamp(card, RCODE_CANCELLED, t->packet.timestamp, 0,

						NULL, 0, t->callback_data);

		}

	}

}



// card->transactions.lock must be acquired in advance.

#define find_and_pop_transaction_entry(card, condition)			\

({									\

drivers/firewire/core.h

+2 −0
Original line number Diff line number Diff line
@@ -287,6 +287,8 @@ void fw_fill_response(struct fw_packet *response, u32 *request_header, 
void fw_request_get(struct fw_request *request);

void fw_request_put(struct fw_request *request);



void fw_cancel_pending_transactions(struct fw_card *card);



// Convert the value of IEEE 1394 CYCLE_TIME register to the format of timeStamp field in

// descriptors of 1394 OHCI.

static inline u32 cycle_time_to_ohci_tstamp(u32 tstamp)

drivers/firewire/ohci.c

+0 −5
Original line number Diff line number Diff line
@@ -3719,11 +3719,6 @@ static void pci_remove(struct pci_dev *dev) 


	fw_core_remove_card(&ohci->card);



	/*

	 * FIXME: Fail all pending packets here, now that the upper

	 * layers can't queue any more.

	 */



	software_reset(ohci);



	irq = pci_irq_vector(dev, 0);