|
@@ -46,6 +46,7 @@
|
|
|
#include <linux/ktime.h>
|
|
|
#include <asm/facility.h>
|
|
|
#include <linux/crypto.h>
|
|
|
+#include <linux/mod_devicetable.h>
|
|
|
|
|
|
#include "ap_bus.h"
|
|
|
#include "ap_asm.h"
|
|
@@ -72,10 +73,12 @@ static int ap_thread_flag = 0;
|
|
|
module_param_named(poll_thread, ap_thread_flag, int, S_IRUSR|S_IRGRP);
|
|
|
MODULE_PARM_DESC(poll_thread, "Turn on/off poll thread, default is 0 (off).");
|
|
|
|
|
|
-static struct device *ap_root_device = NULL;
|
|
|
+static struct device *ap_root_device;
|
|
|
+
|
|
|
+DEFINE_SPINLOCK(ap_list_lock);
|
|
|
+LIST_HEAD(ap_card_list);
|
|
|
+
|
|
|
static struct ap_config_info *ap_configuration;
|
|
|
-static DEFINE_SPINLOCK(ap_device_list_lock);
|
|
|
-static LIST_HEAD(ap_device_list);
|
|
|
static bool initialised;
|
|
|
|
|
|
/*
|
|
@@ -129,6 +132,20 @@ static inline int ap_using_interrupts(void)
|
|
|
return ap_airq_flag;
|
|
|
}
|
|
|
|
|
|
+/**
|
|
|
+ * ap_airq_ptr() - Get the address of the adapter interrupt indicator
|
|
|
+ *
|
|
|
+ * Returns the address of the local-summary-indicator of the adapter
|
|
|
+ * interrupt handler for AP, or NULL if adapter interrupts are not
|
|
|
+ * available.
|
|
|
+ */
|
|
|
+void *ap_airq_ptr(void)
|
|
|
+{
|
|
|
+ if (ap_using_interrupts())
|
|
|
+ return ap_airq.lsi_ptr;
|
|
|
+ return NULL;
|
|
|
+}
|
|
|
+
|
|
|
/**
|
|
|
* ap_interrupts_available(): Test if AP interrupts are available.
|
|
|
*
|
|
@@ -229,101 +246,6 @@ static inline int ap_test_config_domain(unsigned int domain)
|
|
|
return ap_test_config(ap_configuration->aqm, domain);
|
|
|
}
|
|
|
|
|
|
-/**
|
|
|
- * ap_queue_enable_interruption(): Enable interruption on an AP.
|
|
|
- * @qid: The AP queue number
|
|
|
- * @ind: the notification indicator byte
|
|
|
- *
|
|
|
- * Enables interruption on AP queue via ap_aqic(). Based on the return
|
|
|
- * value it waits a while and tests the AP queue if interrupts
|
|
|
- * have been switched on using ap_test_queue().
|
|
|
- */
|
|
|
-static int ap_queue_enable_interruption(struct ap_device *ap_dev, void *ind)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
-
|
|
|
- status = ap_aqic(ap_dev->qid, ind);
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- case AP_RESPONSE_OTHERWISE_CHANGED:
|
|
|
- return 0;
|
|
|
- case AP_RESPONSE_Q_NOT_AVAIL:
|
|
|
- case AP_RESPONSE_DECONFIGURED:
|
|
|
- case AP_RESPONSE_CHECKSTOPPED:
|
|
|
- case AP_RESPONSE_INVALID_ADDRESS:
|
|
|
- pr_err("Registering adapter interrupts for AP %d failed\n",
|
|
|
- AP_QID_DEVICE(ap_dev->qid));
|
|
|
- return -EOPNOTSUPP;
|
|
|
- case AP_RESPONSE_RESET_IN_PROGRESS:
|
|
|
- case AP_RESPONSE_BUSY:
|
|
|
- default:
|
|
|
- return -EBUSY;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * __ap_send(): Send message to adjunct processor queue.
|
|
|
- * @qid: The AP queue number
|
|
|
- * @psmid: The program supplied message identifier
|
|
|
- * @msg: The message text
|
|
|
- * @length: The message length
|
|
|
- * @special: Special Bit
|
|
|
- *
|
|
|
- * Returns AP queue status structure.
|
|
|
- * Condition code 1 on NQAP can't happen because the L bit is 1.
|
|
|
- * Condition code 2 on NQAP also means the send is incomplete,
|
|
|
- * because a segment boundary was reached. The NQAP is repeated.
|
|
|
- */
|
|
|
-static inline struct ap_queue_status
|
|
|
-__ap_send(ap_qid_t qid, unsigned long long psmid, void *msg, size_t length,
|
|
|
- unsigned int special)
|
|
|
-{
|
|
|
- if (special == 1)
|
|
|
- qid |= 0x400000UL;
|
|
|
- return ap_nqap(qid, psmid, msg, length);
|
|
|
-}
|
|
|
-
|
|
|
-int ap_send(ap_qid_t qid, unsigned long long psmid, void *msg, size_t length)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
-
|
|
|
- status = __ap_send(qid, psmid, msg, length, 0);
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- return 0;
|
|
|
- case AP_RESPONSE_Q_FULL:
|
|
|
- case AP_RESPONSE_RESET_IN_PROGRESS:
|
|
|
- return -EBUSY;
|
|
|
- case AP_RESPONSE_REQ_FAC_NOT_INST:
|
|
|
- return -EINVAL;
|
|
|
- default: /* Device is gone. */
|
|
|
- return -ENODEV;
|
|
|
- }
|
|
|
-}
|
|
|
-EXPORT_SYMBOL(ap_send);
|
|
|
-
|
|
|
-int ap_recv(ap_qid_t qid, unsigned long long *psmid, void *msg, size_t length)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
-
|
|
|
- if (msg == NULL)
|
|
|
- return -EINVAL;
|
|
|
- status = ap_dqap(qid, psmid, msg, length);
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- return 0;
|
|
|
- case AP_RESPONSE_NO_PENDING_REPLY:
|
|
|
- if (status.queue_empty)
|
|
|
- return -ENOENT;
|
|
|
- return -EBUSY;
|
|
|
- case AP_RESPONSE_RESET_IN_PROGRESS:
|
|
|
- return -EBUSY;
|
|
|
- default:
|
|
|
- return -ENODEV;
|
|
|
- }
|
|
|
-}
|
|
|
-EXPORT_SYMBOL(ap_recv);
|
|
|
-
|
|
|
/**
|
|
|
* ap_query_queue(): Check if an AP queue is available.
|
|
|
* @qid: The AP queue number
|
|
@@ -338,7 +260,7 @@ static int ap_query_queue(ap_qid_t qid, int *queue_depth, int *device_type,
|
|
|
unsigned long info;
|
|
|
int nd;
|
|
|
|
|
|
- if (!ap_test_config_card_id(AP_QID_DEVICE(qid)))
|
|
|
+ if (!ap_test_config_card_id(AP_QID_CARD(qid)))
|
|
|
return -ENODEV;
|
|
|
|
|
|
status = ap_test_queue(qid, &info);
|
|
@@ -366,9 +288,7 @@ static int ap_query_queue(ap_qid_t qid, int *queue_depth, int *device_type,
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-/* State machine definitions and helpers */
|
|
|
-
|
|
|
-static void ap_sm_wait(enum ap_wait wait)
|
|
|
+void ap_wait(enum ap_wait wait)
|
|
|
{
|
|
|
ktime_t hr_time;
|
|
|
|
|
@@ -397,347 +317,21 @@ static void ap_sm_wait(enum ap_wait wait)
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-static enum ap_wait ap_sm_nop(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- return AP_WAIT_NONE;
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * ap_sm_recv(): Receive pending reply messages from an AP device but do
|
|
|
- * not change the state of the device.
|
|
|
- * @ap_dev: pointer to the AP device
|
|
|
- *
|
|
|
- * Returns AP_WAIT_NONE, AP_WAIT_AGAIN, or AP_WAIT_INTERRUPT
|
|
|
- */
|
|
|
-static struct ap_queue_status ap_sm_recv(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
- struct ap_message *ap_msg;
|
|
|
-
|
|
|
- status = ap_dqap(ap_dev->qid, &ap_dev->reply->psmid,
|
|
|
- ap_dev->reply->message, ap_dev->reply->length);
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- ap_dev->queue_count--;
|
|
|
- if (ap_dev->queue_count > 0)
|
|
|
- mod_timer(&ap_dev->timeout,
|
|
|
- jiffies + ap_dev->drv->request_timeout);
|
|
|
- list_for_each_entry(ap_msg, &ap_dev->pendingq, list) {
|
|
|
- if (ap_msg->psmid != ap_dev->reply->psmid)
|
|
|
- continue;
|
|
|
- list_del_init(&ap_msg->list);
|
|
|
- ap_dev->pendingq_count--;
|
|
|
- ap_msg->receive(ap_dev, ap_msg, ap_dev->reply);
|
|
|
- break;
|
|
|
- }
|
|
|
- case AP_RESPONSE_NO_PENDING_REPLY:
|
|
|
- if (!status.queue_empty || ap_dev->queue_count <= 0)
|
|
|
- break;
|
|
|
- /* The card shouldn't forget requests but who knows. */
|
|
|
- ap_dev->queue_count = 0;
|
|
|
- list_splice_init(&ap_dev->pendingq, &ap_dev->requestq);
|
|
|
- ap_dev->requestq_count += ap_dev->pendingq_count;
|
|
|
- ap_dev->pendingq_count = 0;
|
|
|
- break;
|
|
|
- default:
|
|
|
- break;
|
|
|
- }
|
|
|
- return status;
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * ap_sm_read(): Receive pending reply messages from an AP device.
|
|
|
- * @ap_dev: pointer to the AP device
|
|
|
- *
|
|
|
- * Returns AP_WAIT_NONE, AP_WAIT_AGAIN, or AP_WAIT_INTERRUPT
|
|
|
- */
|
|
|
-static enum ap_wait ap_sm_read(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
-
|
|
|
- if (!ap_dev->reply)
|
|
|
- return AP_WAIT_NONE;
|
|
|
- status = ap_sm_recv(ap_dev);
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- if (ap_dev->queue_count > 0) {
|
|
|
- ap_dev->state = AP_STATE_WORKING;
|
|
|
- return AP_WAIT_AGAIN;
|
|
|
- }
|
|
|
- ap_dev->state = AP_STATE_IDLE;
|
|
|
- return AP_WAIT_NONE;
|
|
|
- case AP_RESPONSE_NO_PENDING_REPLY:
|
|
|
- if (ap_dev->queue_count > 0)
|
|
|
- return AP_WAIT_INTERRUPT;
|
|
|
- ap_dev->state = AP_STATE_IDLE;
|
|
|
- return AP_WAIT_NONE;
|
|
|
- default:
|
|
|
- ap_dev->state = AP_STATE_BORKED;
|
|
|
- return AP_WAIT_NONE;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * ap_sm_suspend_read(): Receive pending reply messages from an AP device
|
|
|
- * without changing the device state in between. In suspend mode we don't
|
|
|
- * allow sending new requests, therefore just fetch pending replies.
|
|
|
- * @ap_dev: pointer to the AP device
|
|
|
- *
|
|
|
- * Returns AP_WAIT_NONE or AP_WAIT_AGAIN
|
|
|
- */
|
|
|
-static enum ap_wait ap_sm_suspend_read(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
-
|
|
|
- if (!ap_dev->reply)
|
|
|
- return AP_WAIT_NONE;
|
|
|
- status = ap_sm_recv(ap_dev);
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- if (ap_dev->queue_count > 0)
|
|
|
- return AP_WAIT_AGAIN;
|
|
|
- /* fall through */
|
|
|
- default:
|
|
|
- return AP_WAIT_NONE;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * ap_sm_write(): Send messages from the request queue to an AP device.
|
|
|
- * @ap_dev: pointer to the AP device
|
|
|
- *
|
|
|
- * Returns AP_WAIT_NONE, AP_WAIT_AGAIN, or AP_WAIT_INTERRUPT
|
|
|
- */
|
|
|
-static enum ap_wait ap_sm_write(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
- struct ap_message *ap_msg;
|
|
|
-
|
|
|
- if (ap_dev->requestq_count <= 0)
|
|
|
- return AP_WAIT_NONE;
|
|
|
- /* Start the next request on the queue. */
|
|
|
- ap_msg = list_entry(ap_dev->requestq.next, struct ap_message, list);
|
|
|
- status = __ap_send(ap_dev->qid, ap_msg->psmid,
|
|
|
- ap_msg->message, ap_msg->length, ap_msg->special);
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- ap_dev->queue_count++;
|
|
|
- if (ap_dev->queue_count == 1)
|
|
|
- mod_timer(&ap_dev->timeout,
|
|
|
- jiffies + ap_dev->drv->request_timeout);
|
|
|
- list_move_tail(&ap_msg->list, &ap_dev->pendingq);
|
|
|
- ap_dev->requestq_count--;
|
|
|
- ap_dev->pendingq_count++;
|
|
|
- if (ap_dev->queue_count < ap_dev->queue_depth) {
|
|
|
- ap_dev->state = AP_STATE_WORKING;
|
|
|
- return AP_WAIT_AGAIN;
|
|
|
- }
|
|
|
- /* fall through */
|
|
|
- case AP_RESPONSE_Q_FULL:
|
|
|
- ap_dev->state = AP_STATE_QUEUE_FULL;
|
|
|
- return AP_WAIT_INTERRUPT;
|
|
|
- case AP_RESPONSE_RESET_IN_PROGRESS:
|
|
|
- ap_dev->state = AP_STATE_RESET_WAIT;
|
|
|
- return AP_WAIT_TIMEOUT;
|
|
|
- case AP_RESPONSE_MESSAGE_TOO_BIG:
|
|
|
- case AP_RESPONSE_REQ_FAC_NOT_INST:
|
|
|
- list_del_init(&ap_msg->list);
|
|
|
- ap_dev->requestq_count--;
|
|
|
- ap_msg->rc = -EINVAL;
|
|
|
- ap_msg->receive(ap_dev, ap_msg, NULL);
|
|
|
- return AP_WAIT_AGAIN;
|
|
|
- default:
|
|
|
- ap_dev->state = AP_STATE_BORKED;
|
|
|
- return AP_WAIT_NONE;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * ap_sm_read_write(): Send and receive messages to/from an AP device.
|
|
|
- * @ap_dev: pointer to the AP device
|
|
|
- *
|
|
|
- * Returns AP_WAIT_NONE, AP_WAIT_AGAIN, or AP_WAIT_INTERRUPT
|
|
|
- */
|
|
|
-static enum ap_wait ap_sm_read_write(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- return min(ap_sm_read(ap_dev), ap_sm_write(ap_dev));
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * ap_sm_reset(): Reset an AP queue.
|
|
|
- * @qid: The AP queue number
|
|
|
- *
|
|
|
- * Submit the Reset command to an AP queue.
|
|
|
- */
|
|
|
-static enum ap_wait ap_sm_reset(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
-
|
|
|
- status = ap_rapq(ap_dev->qid);
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- case AP_RESPONSE_RESET_IN_PROGRESS:
|
|
|
- ap_dev->state = AP_STATE_RESET_WAIT;
|
|
|
- ap_dev->interrupt = AP_INTR_DISABLED;
|
|
|
- return AP_WAIT_TIMEOUT;
|
|
|
- case AP_RESPONSE_BUSY:
|
|
|
- return AP_WAIT_TIMEOUT;
|
|
|
- case AP_RESPONSE_Q_NOT_AVAIL:
|
|
|
- case AP_RESPONSE_DECONFIGURED:
|
|
|
- case AP_RESPONSE_CHECKSTOPPED:
|
|
|
- default:
|
|
|
- ap_dev->state = AP_STATE_BORKED;
|
|
|
- return AP_WAIT_NONE;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * ap_sm_reset_wait(): Test queue for completion of the reset operation
|
|
|
- * @ap_dev: pointer to the AP device
|
|
|
- *
|
|
|
- * Returns AP_POLL_IMMEDIATELY, AP_POLL_AFTER_TIMEROUT or 0.
|
|
|
- */
|
|
|
-static enum ap_wait ap_sm_reset_wait(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
- unsigned long info;
|
|
|
-
|
|
|
- if (ap_dev->queue_count > 0 && ap_dev->reply)
|
|
|
- /* Try to read a completed message and get the status */
|
|
|
- status = ap_sm_recv(ap_dev);
|
|
|
- else
|
|
|
- /* Get the status with TAPQ */
|
|
|
- status = ap_test_queue(ap_dev->qid, &info);
|
|
|
-
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- if (ap_using_interrupts() &&
|
|
|
- ap_queue_enable_interruption(ap_dev,
|
|
|
- ap_airq.lsi_ptr) == 0)
|
|
|
- ap_dev->state = AP_STATE_SETIRQ_WAIT;
|
|
|
- else
|
|
|
- ap_dev->state = (ap_dev->queue_count > 0) ?
|
|
|
- AP_STATE_WORKING : AP_STATE_IDLE;
|
|
|
- return AP_WAIT_AGAIN;
|
|
|
- case AP_RESPONSE_BUSY:
|
|
|
- case AP_RESPONSE_RESET_IN_PROGRESS:
|
|
|
- return AP_WAIT_TIMEOUT;
|
|
|
- case AP_RESPONSE_Q_NOT_AVAIL:
|
|
|
- case AP_RESPONSE_DECONFIGURED:
|
|
|
- case AP_RESPONSE_CHECKSTOPPED:
|
|
|
- default:
|
|
|
- ap_dev->state = AP_STATE_BORKED;
|
|
|
- return AP_WAIT_NONE;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-/**
|
|
|
- * ap_sm_setirq_wait(): Test queue for completion of the irq enablement
|
|
|
- * @ap_dev: pointer to the AP device
|
|
|
- *
|
|
|
- * Returns AP_POLL_IMMEDIATELY, AP_POLL_AFTER_TIMEROUT or 0.
|
|
|
- */
|
|
|
-static enum ap_wait ap_sm_setirq_wait(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- struct ap_queue_status status;
|
|
|
- unsigned long info;
|
|
|
-
|
|
|
- if (ap_dev->queue_count > 0 && ap_dev->reply)
|
|
|
- /* Try to read a completed message and get the status */
|
|
|
- status = ap_sm_recv(ap_dev);
|
|
|
- else
|
|
|
- /* Get the status with TAPQ */
|
|
|
- status = ap_test_queue(ap_dev->qid, &info);
|
|
|
-
|
|
|
- if (status.int_enabled == 1) {
|
|
|
- /* Irqs are now enabled */
|
|
|
- ap_dev->interrupt = AP_INTR_ENABLED;
|
|
|
- ap_dev->state = (ap_dev->queue_count > 0) ?
|
|
|
- AP_STATE_WORKING : AP_STATE_IDLE;
|
|
|
- }
|
|
|
-
|
|
|
- switch (status.response_code) {
|
|
|
- case AP_RESPONSE_NORMAL:
|
|
|
- if (ap_dev->queue_count > 0)
|
|
|
- return AP_WAIT_AGAIN;
|
|
|
- /* fallthrough */
|
|
|
- case AP_RESPONSE_NO_PENDING_REPLY:
|
|
|
- return AP_WAIT_TIMEOUT;
|
|
|
- default:
|
|
|
- ap_dev->state = AP_STATE_BORKED;
|
|
|
- return AP_WAIT_NONE;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-/*
|
|
|
- * AP state machine jump table
|
|
|
- */
|
|
|
-static ap_func_t *ap_jumptable[NR_AP_STATES][NR_AP_EVENTS] = {
|
|
|
- [AP_STATE_RESET_START] = {
|
|
|
- [AP_EVENT_POLL] = ap_sm_reset,
|
|
|
- [AP_EVENT_TIMEOUT] = ap_sm_nop,
|
|
|
- },
|
|
|
- [AP_STATE_RESET_WAIT] = {
|
|
|
- [AP_EVENT_POLL] = ap_sm_reset_wait,
|
|
|
- [AP_EVENT_TIMEOUT] = ap_sm_nop,
|
|
|
- },
|
|
|
- [AP_STATE_SETIRQ_WAIT] = {
|
|
|
- [AP_EVENT_POLL] = ap_sm_setirq_wait,
|
|
|
- [AP_EVENT_TIMEOUT] = ap_sm_nop,
|
|
|
- },
|
|
|
- [AP_STATE_IDLE] = {
|
|
|
- [AP_EVENT_POLL] = ap_sm_write,
|
|
|
- [AP_EVENT_TIMEOUT] = ap_sm_nop,
|
|
|
- },
|
|
|
- [AP_STATE_WORKING] = {
|
|
|
- [AP_EVENT_POLL] = ap_sm_read_write,
|
|
|
- [AP_EVENT_TIMEOUT] = ap_sm_reset,
|
|
|
- },
|
|
|
- [AP_STATE_QUEUE_FULL] = {
|
|
|
- [AP_EVENT_POLL] = ap_sm_read,
|
|
|
- [AP_EVENT_TIMEOUT] = ap_sm_reset,
|
|
|
- },
|
|
|
- [AP_STATE_SUSPEND_WAIT] = {
|
|
|
- [AP_EVENT_POLL] = ap_sm_suspend_read,
|
|
|
- [AP_EVENT_TIMEOUT] = ap_sm_nop,
|
|
|
- },
|
|
|
- [AP_STATE_BORKED] = {
|
|
|
- [AP_EVENT_POLL] = ap_sm_nop,
|
|
|
- [AP_EVENT_TIMEOUT] = ap_sm_nop,
|
|
|
- },
|
|
|
-};
|
|
|
-
|
|
|
-static inline enum ap_wait ap_sm_event(struct ap_device *ap_dev,
|
|
|
- enum ap_event event)
|
|
|
-{
|
|
|
- return ap_jumptable[ap_dev->state][event](ap_dev);
|
|
|
-}
|
|
|
-
|
|
|
-static inline enum ap_wait ap_sm_event_loop(struct ap_device *ap_dev,
|
|
|
- enum ap_event event)
|
|
|
-{
|
|
|
- enum ap_wait wait;
|
|
|
-
|
|
|
- while ((wait = ap_sm_event(ap_dev, event)) == AP_WAIT_AGAIN)
|
|
|
- ;
|
|
|
- return wait;
|
|
|
-}
|
|
|
-
|
|
|
/**
|
|
|
* ap_request_timeout(): Handling of request timeouts
|
|
|
* @data: Holds the AP device.
|
|
|
*
|
|
|
* Handles request timeouts.
|
|
|
*/
|
|
|
-static void ap_request_timeout(unsigned long data)
|
|
|
+void ap_request_timeout(unsigned long data)
|
|
|
{
|
|
|
- struct ap_device *ap_dev = (struct ap_device *) data;
|
|
|
+ struct ap_queue *aq = (struct ap_queue *) data;
|
|
|
|
|
|
if (ap_suspend_flag)
|
|
|
return;
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- ap_sm_wait(ap_sm_event(ap_dev, AP_EVENT_TIMEOUT));
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
+ spin_lock_bh(&aq->lock);
|
|
|
+ ap_wait(ap_sm_event(aq, AP_EVENT_TIMEOUT));
|
|
|
+ spin_unlock_bh(&aq->lock);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -772,7 +366,8 @@ static void ap_interrupt_handler(struct airq_struct *airq)
|
|
|
*/
|
|
|
static void ap_tasklet_fn(unsigned long dummy)
|
|
|
{
|
|
|
- struct ap_device *ap_dev;
|
|
|
+ struct ap_card *ac;
|
|
|
+ struct ap_queue *aq;
|
|
|
enum ap_wait wait = AP_WAIT_NONE;
|
|
|
|
|
|
/* Reset the indicator if interrupts are used. Thus new interrupts can
|
|
@@ -782,35 +377,35 @@ static void ap_tasklet_fn(unsigned long dummy)
|
|
|
if (ap_using_interrupts())
|
|
|
xchg(ap_airq.lsi_ptr, 0);
|
|
|
|
|
|
- spin_lock(&ap_device_list_lock);
|
|
|
- list_for_each_entry(ap_dev, &ap_device_list, list) {
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- wait = min(wait, ap_sm_event_loop(ap_dev, AP_EVENT_POLL));
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
+ spin_lock_bh(&ap_list_lock);
|
|
|
+ for_each_ap_card(ac) {
|
|
|
+ for_each_ap_queue(aq, ac) {
|
|
|
+ spin_lock_bh(&aq->lock);
|
|
|
+ wait = min(wait, ap_sm_event_loop(aq, AP_EVENT_POLL));
|
|
|
+ spin_unlock_bh(&aq->lock);
|
|
|
+ }
|
|
|
}
|
|
|
- spin_unlock(&ap_device_list_lock);
|
|
|
- ap_sm_wait(wait);
|
|
|
+ spin_unlock_bh(&ap_list_lock);
|
|
|
+
|
|
|
+ ap_wait(wait);
|
|
|
}
|
|
|
|
|
|
static int ap_pending_requests(void)
|
|
|
{
|
|
|
- struct ap_device *ap_dev;
|
|
|
- int id, pending = 0;
|
|
|
-
|
|
|
- for (id = 0; pending == 0 && id < AP_DEVICES; id++) {
|
|
|
- spin_lock_bh(&ap_device_list_lock);
|
|
|
- list_for_each_entry(ap_dev, &ap_device_list, list) {
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- if (ap_dev->queue_count)
|
|
|
- pending = 1;
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
- if (pending)
|
|
|
- break;
|
|
|
+ struct ap_card *ac;
|
|
|
+ struct ap_queue *aq;
|
|
|
+
|
|
|
+ spin_lock_bh(&ap_list_lock);
|
|
|
+ for_each_ap_card(ac) {
|
|
|
+ for_each_ap_queue(aq, ac) {
|
|
|
+ if (aq->queue_count == 0)
|
|
|
+ continue;
|
|
|
+ spin_unlock_bh(&ap_list_lock);
|
|
|
+ return 1;
|
|
|
}
|
|
|
- spin_unlock_bh(&ap_device_list_lock);
|
|
|
}
|
|
|
-
|
|
|
- return pending;
|
|
|
+ spin_unlock_bh(&ap_list_lock);
|
|
|
+ return 0;
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -874,207 +469,8 @@ static void ap_poll_thread_stop(void)
|
|
|
mutex_unlock(&ap_poll_thread_mutex);
|
|
|
}
|
|
|
|
|
|
-/**
|
|
|
- * ap_queue_message(): Queue a request to an AP device.
|
|
|
- * @ap_dev: The AP device to queue the message to
|
|
|
- * @ap_msg: The message that is to be added
|
|
|
- */
|
|
|
-void ap_queue_message(struct ap_device *ap_dev, struct ap_message *ap_msg)
|
|
|
-{
|
|
|
- /* For asynchronous message handling a valid receive-callback
|
|
|
- * is required. */
|
|
|
- BUG_ON(!ap_msg->receive);
|
|
|
-
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- /* Queue the message. */
|
|
|
- list_add_tail(&ap_msg->list, &ap_dev->requestq);
|
|
|
- ap_dev->requestq_count++;
|
|
|
- ap_dev->total_request_count++;
|
|
|
- /* Send/receive as many request from the queue as possible. */
|
|
|
- ap_sm_wait(ap_sm_event_loop(ap_dev, AP_EVENT_POLL));
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
-}
|
|
|
-EXPORT_SYMBOL(ap_queue_message);
|
|
|
-
|
|
|
-/**
|
|
|
- * ap_cancel_message(): Cancel a crypto request.
|
|
|
- * @ap_dev: The AP device that has the message queued
|
|
|
- * @ap_msg: The message that is to be removed
|
|
|
- *
|
|
|
- * Cancel a crypto request. This is done by removing the request
|
|
|
- * from the device pending or request queue. Note that the
|
|
|
- * request stays on the AP queue. When it finishes the message
|
|
|
- * reply will be discarded because the psmid can't be found.
|
|
|
- */
|
|
|
-void ap_cancel_message(struct ap_device *ap_dev, struct ap_message *ap_msg)
|
|
|
-{
|
|
|
- struct ap_message *tmp;
|
|
|
-
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- if (!list_empty(&ap_msg->list)) {
|
|
|
- list_for_each_entry(tmp, &ap_dev->pendingq, list)
|
|
|
- if (tmp->psmid == ap_msg->psmid) {
|
|
|
- ap_dev->pendingq_count--;
|
|
|
- goto found;
|
|
|
- }
|
|
|
- ap_dev->requestq_count--;
|
|
|
-found:
|
|
|
- list_del_init(&ap_msg->list);
|
|
|
- }
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
-}
|
|
|
-EXPORT_SYMBOL(ap_cancel_message);
|
|
|
-
|
|
|
-/*
|
|
|
- * AP device related attributes.
|
|
|
- */
|
|
|
-static ssize_t ap_hwtype_show(struct device *dev,
|
|
|
- struct device_attribute *attr, char *buf)
|
|
|
-{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
- return snprintf(buf, PAGE_SIZE, "%d\n", ap_dev->device_type);
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(hwtype, 0444, ap_hwtype_show, NULL);
|
|
|
-
|
|
|
-static ssize_t ap_raw_hwtype_show(struct device *dev,
|
|
|
- struct device_attribute *attr, char *buf)
|
|
|
-{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
-
|
|
|
- return snprintf(buf, PAGE_SIZE, "%d\n", ap_dev->raw_hwtype);
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(raw_hwtype, 0444, ap_raw_hwtype_show, NULL);
|
|
|
-
|
|
|
-static ssize_t ap_depth_show(struct device *dev, struct device_attribute *attr,
|
|
|
- char *buf)
|
|
|
-{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
- return snprintf(buf, PAGE_SIZE, "%d\n", ap_dev->queue_depth);
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(depth, 0444, ap_depth_show, NULL);
|
|
|
-static ssize_t ap_request_count_show(struct device *dev,
|
|
|
- struct device_attribute *attr,
|
|
|
- char *buf)
|
|
|
-{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
- int rc;
|
|
|
-
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- rc = snprintf(buf, PAGE_SIZE, "%d\n", ap_dev->total_request_count);
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
- return rc;
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(request_count, 0444, ap_request_count_show, NULL);
|
|
|
-
|
|
|
-static ssize_t ap_requestq_count_show(struct device *dev,
|
|
|
- struct device_attribute *attr, char *buf)
|
|
|
-{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
- int rc;
|
|
|
-
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- rc = snprintf(buf, PAGE_SIZE, "%d\n", ap_dev->requestq_count);
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
- return rc;
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(requestq_count, 0444, ap_requestq_count_show, NULL);
|
|
|
-
|
|
|
-static ssize_t ap_pendingq_count_show(struct device *dev,
|
|
|
- struct device_attribute *attr, char *buf)
|
|
|
-{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
- int rc;
|
|
|
-
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- rc = snprintf(buf, PAGE_SIZE, "%d\n", ap_dev->pendingq_count);
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
- return rc;
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(pendingq_count, 0444, ap_pendingq_count_show, NULL);
|
|
|
-
|
|
|
-static ssize_t ap_reset_show(struct device *dev,
|
|
|
- struct device_attribute *attr, char *buf)
|
|
|
-{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
- int rc = 0;
|
|
|
-
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- switch (ap_dev->state) {
|
|
|
- case AP_STATE_RESET_START:
|
|
|
- case AP_STATE_RESET_WAIT:
|
|
|
- rc = snprintf(buf, PAGE_SIZE, "Reset in progress.\n");
|
|
|
- break;
|
|
|
- case AP_STATE_WORKING:
|
|
|
- case AP_STATE_QUEUE_FULL:
|
|
|
- rc = snprintf(buf, PAGE_SIZE, "Reset Timer armed.\n");
|
|
|
- break;
|
|
|
- default:
|
|
|
- rc = snprintf(buf, PAGE_SIZE, "No Reset Timer set.\n");
|
|
|
- }
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
- return rc;
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(reset, 0444, ap_reset_show, NULL);
|
|
|
-
|
|
|
-static ssize_t ap_interrupt_show(struct device *dev,
|
|
|
- struct device_attribute *attr, char *buf)
|
|
|
-{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
- int rc = 0;
|
|
|
-
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- if (ap_dev->state == AP_STATE_SETIRQ_WAIT)
|
|
|
- rc = snprintf(buf, PAGE_SIZE, "Enable Interrupt pending.\n");
|
|
|
- else if (ap_dev->interrupt == AP_INTR_ENABLED)
|
|
|
- rc = snprintf(buf, PAGE_SIZE, "Interrupts enabled.\n");
|
|
|
- else
|
|
|
- rc = snprintf(buf, PAGE_SIZE, "Interrupts disabled.\n");
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
- return rc;
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(interrupt, 0444, ap_interrupt_show, NULL);
|
|
|
-
|
|
|
-static ssize_t ap_modalias_show(struct device *dev,
|
|
|
- struct device_attribute *attr, char *buf)
|
|
|
-{
|
|
|
- return sprintf(buf, "ap:t%02X\n", to_ap_dev(dev)->device_type);
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(modalias, 0444, ap_modalias_show, NULL);
|
|
|
-
|
|
|
-static ssize_t ap_functions_show(struct device *dev,
|
|
|
- struct device_attribute *attr, char *buf)
|
|
|
-{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
- return snprintf(buf, PAGE_SIZE, "0x%08X\n", ap_dev->functions);
|
|
|
-}
|
|
|
-
|
|
|
-static DEVICE_ATTR(ap_functions, 0444, ap_functions_show, NULL);
|
|
|
-
|
|
|
-static struct attribute *ap_dev_attrs[] = {
|
|
|
- &dev_attr_hwtype.attr,
|
|
|
- &dev_attr_raw_hwtype.attr,
|
|
|
- &dev_attr_depth.attr,
|
|
|
- &dev_attr_request_count.attr,
|
|
|
- &dev_attr_requestq_count.attr,
|
|
|
- &dev_attr_pendingq_count.attr,
|
|
|
- &dev_attr_reset.attr,
|
|
|
- &dev_attr_interrupt.attr,
|
|
|
- &dev_attr_modalias.attr,
|
|
|
- &dev_attr_ap_functions.attr,
|
|
|
- NULL
|
|
|
-};
|
|
|
-static struct attribute_group ap_dev_attr_group = {
|
|
|
- .attrs = ap_dev_attrs
|
|
|
-};
|
|
|
+#define is_card_dev(x) ((x)->parent == ap_root_device)
|
|
|
+#define is_queue_dev(x) ((x)->parent != ap_root_device)
|
|
|
|
|
|
/**
|
|
|
* ap_bus_match()
|
|
@@ -1085,7 +481,6 @@ static struct attribute_group ap_dev_attr_group = {
|
|
|
*/
|
|
|
static int ap_bus_match(struct device *dev, struct device_driver *drv)
|
|
|
{
|
|
|
- struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
struct ap_driver *ap_drv = to_ap_drv(drv);
|
|
|
struct ap_device_id *id;
|
|
|
|
|
@@ -1094,10 +489,14 @@ static int ap_bus_match(struct device *dev, struct device_driver *drv)
|
|
|
* supported types of the device_driver.
|
|
|
*/
|
|
|
for (id = ap_drv->ids; id->match_flags; id++) {
|
|
|
- if ((id->match_flags & AP_DEVICE_ID_MATCH_DEVICE_TYPE) &&
|
|
|
- (id->dev_type != ap_dev->device_type))
|
|
|
- continue;
|
|
|
- return 1;
|
|
|
+ if (is_card_dev(dev) &&
|
|
|
+ id->match_flags & AP_DEVICE_ID_MATCH_CARD_TYPE &&
|
|
|
+ id->dev_type == to_ap_dev(dev)->device_type)
|
|
|
+ return 1;
|
|
|
+ if (is_queue_dev(dev) &&
|
|
|
+ id->match_flags & AP_DEVICE_ID_MATCH_QUEUE_TYPE &&
|
|
|
+ id->dev_type == to_ap_dev(dev)->device_type)
|
|
|
+ return 1;
|
|
|
}
|
|
|
return 0;
|
|
|
}
|
|
@@ -1133,13 +532,17 @@ static int ap_dev_suspend(struct device *dev)
|
|
|
{
|
|
|
struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
|
|
|
- /* Poll on the device until all requests are finished. */
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- ap_dev->state = AP_STATE_SUSPEND_WAIT;
|
|
|
- while (ap_sm_event(ap_dev, AP_EVENT_POLL) != AP_WAIT_NONE)
|
|
|
- ;
|
|
|
- ap_dev->state = AP_STATE_BORKED;
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
+ if (ap_dev->drv && ap_dev->drv->suspend)
|
|
|
+ ap_dev->drv->suspend(ap_dev);
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+static int ap_dev_resume(struct device *dev)
|
|
|
+{
|
|
|
+ struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
+
|
|
|
+ if (ap_dev->drv && ap_dev->drv->resume)
|
|
|
+ ap_dev->drv->resume(ap_dev);
|
|
|
return 0;
|
|
|
}
|
|
|
|
|
@@ -1154,9 +557,25 @@ static void ap_bus_suspend(void)
|
|
|
tasklet_disable(&ap_tasklet);
|
|
|
}
|
|
|
|
|
|
-static int __ap_devices_unregister(struct device *dev, void *dummy)
|
|
|
+static int __ap_card_devices_unregister(struct device *dev, void *dummy)
|
|
|
+{
|
|
|
+ if (is_card_dev(dev))
|
|
|
+ device_unregister(dev);
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+static int __ap_queue_devices_unregister(struct device *dev, void *dummy)
|
|
|
+{
|
|
|
+ if (is_queue_dev(dev))
|
|
|
+ device_unregister(dev);
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+static int __ap_queue_devices_with_id_unregister(struct device *dev, void *data)
|
|
|
{
|
|
|
- device_unregister(dev);
|
|
|
+ if (is_queue_dev(dev) &&
|
|
|
+ AP_QID_CARD(to_ap_queue(dev)->qid) == (int)(long) data)
|
|
|
+ device_unregister(dev);
|
|
|
return 0;
|
|
|
}
|
|
|
|
|
@@ -1164,8 +583,13 @@ static void ap_bus_resume(void)
|
|
|
{
|
|
|
int rc;
|
|
|
|
|
|
- /* Unconditionally remove all AP devices */
|
|
|
- bus_for_each_dev(&ap_bus_type, NULL, NULL, __ap_devices_unregister);
|
|
|
+ /* remove all queue devices */
|
|
|
+ bus_for_each_dev(&ap_bus_type, NULL, NULL,
|
|
|
+ __ap_queue_devices_unregister);
|
|
|
+ /* remove all card devices */
|
|
|
+ bus_for_each_dev(&ap_bus_type, NULL, NULL,
|
|
|
+ __ap_card_devices_unregister);
|
|
|
+
|
|
|
/* Reset thin interrupt setting */
|
|
|
if (ap_interrupts_available() && !ap_using_interrupts()) {
|
|
|
rc = register_adapter_interrupt(&ap_airq);
|
|
@@ -1207,7 +631,7 @@ static struct notifier_block ap_power_notifier = {
|
|
|
.notifier_call = ap_power_event,
|
|
|
};
|
|
|
|
|
|
-static SIMPLE_DEV_PM_OPS(ap_bus_pm_ops, ap_dev_suspend, NULL);
|
|
|
+static SIMPLE_DEV_PM_OPS(ap_bus_pm_ops, ap_dev_suspend, ap_dev_resume);
|
|
|
|
|
|
static struct bus_type ap_bus_type = {
|
|
|
.name = "ap",
|
|
@@ -1216,17 +640,6 @@ static struct bus_type ap_bus_type = {
|
|
|
.pm = &ap_bus_pm_ops,
|
|
|
};
|
|
|
|
|
|
-void ap_device_init_reply(struct ap_device *ap_dev,
|
|
|
- struct ap_message *reply)
|
|
|
-{
|
|
|
- ap_dev->reply = reply;
|
|
|
-
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- ap_sm_wait(ap_sm_event(ap_dev, AP_EVENT_POLL));
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
-}
|
|
|
-EXPORT_SYMBOL(ap_device_init_reply);
|
|
|
-
|
|
|
static int ap_device_probe(struct device *dev)
|
|
|
{
|
|
|
struct ap_device *ap_dev = to_ap_dev(dev);
|
|
@@ -1240,58 +653,22 @@ static int ap_device_probe(struct device *dev)
|
|
|
return rc;
|
|
|
}
|
|
|
|
|
|
-/**
|
|
|
- * __ap_flush_queue(): Flush requests.
|
|
|
- * @ap_dev: Pointer to the AP device
|
|
|
- *
|
|
|
- * Flush all requests from the request/pending queue of an AP device.
|
|
|
- */
|
|
|
-static void __ap_flush_queue(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- struct ap_message *ap_msg, *next;
|
|
|
-
|
|
|
- list_for_each_entry_safe(ap_msg, next, &ap_dev->pendingq, list) {
|
|
|
- list_del_init(&ap_msg->list);
|
|
|
- ap_dev->pendingq_count--;
|
|
|
- ap_msg->rc = -EAGAIN;
|
|
|
- ap_msg->receive(ap_dev, ap_msg, NULL);
|
|
|
- }
|
|
|
- list_for_each_entry_safe(ap_msg, next, &ap_dev->requestq, list) {
|
|
|
- list_del_init(&ap_msg->list);
|
|
|
- ap_dev->requestq_count--;
|
|
|
- ap_msg->rc = -EAGAIN;
|
|
|
- ap_msg->receive(ap_dev, ap_msg, NULL);
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-void ap_flush_queue(struct ap_device *ap_dev)
|
|
|
-{
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- __ap_flush_queue(ap_dev);
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
-}
|
|
|
-EXPORT_SYMBOL(ap_flush_queue);
|
|
|
-
|
|
|
static int ap_device_remove(struct device *dev)
|
|
|
{
|
|
|
struct ap_device *ap_dev = to_ap_dev(dev);
|
|
|
struct ap_driver *ap_drv = ap_dev->drv;
|
|
|
|
|
|
- ap_flush_queue(ap_dev);
|
|
|
- del_timer_sync(&ap_dev->timeout);
|
|
|
- spin_lock_bh(&ap_device_list_lock);
|
|
|
- list_del_init(&ap_dev->list);
|
|
|
- spin_unlock_bh(&ap_device_list_lock);
|
|
|
+ spin_lock_bh(&ap_list_lock);
|
|
|
+ if (is_card_dev(dev))
|
|
|
+ list_del_init(&to_ap_card(dev)->list);
|
|
|
+ else
|
|
|
+ list_del_init(&to_ap_queue(dev)->list);
|
|
|
+ spin_unlock_bh(&ap_list_lock);
|
|
|
if (ap_drv->remove)
|
|
|
ap_drv->remove(ap_dev);
|
|
|
return 0;
|
|
|
}
|
|
|
|
|
|
-static void ap_device_release(struct device *dev)
|
|
|
-{
|
|
|
- kfree(to_ap_dev(dev));
|
|
|
-}
|
|
|
-
|
|
|
int ap_driver_register(struct ap_driver *ap_drv, struct module *owner,
|
|
|
char *name)
|
|
|
{
|
|
@@ -1354,12 +731,7 @@ static ssize_t ap_control_domain_mask_show(struct bus_type *bus, char *buf)
|
|
|
{
|
|
|
if (!ap_configuration) /* QCI not supported */
|
|
|
return snprintf(buf, PAGE_SIZE, "not supported\n");
|
|
|
- if (!test_facility(76))
|
|
|
- /* format 0 - 16 bit domain field */
|
|
|
- return snprintf(buf, PAGE_SIZE, "%08x%08x\n",
|
|
|
- ap_configuration->adm[0],
|
|
|
- ap_configuration->adm[1]);
|
|
|
- /* format 1 - 256 bit domain field */
|
|
|
+
|
|
|
return snprintf(buf, PAGE_SIZE,
|
|
|
"0x%08x%08x%08x%08x%08x%08x%08x%08x\n",
|
|
|
ap_configuration->adm[0], ap_configuration->adm[1],
|
|
@@ -1371,6 +743,22 @@ static ssize_t ap_control_domain_mask_show(struct bus_type *bus, char *buf)
|
|
|
static BUS_ATTR(ap_control_domain_mask, 0444,
|
|
|
ap_control_domain_mask_show, NULL);
|
|
|
|
|
|
+static ssize_t ap_usage_domain_mask_show(struct bus_type *bus, char *buf)
|
|
|
+{
|
|
|
+ if (!ap_configuration) /* QCI not supported */
|
|
|
+ return snprintf(buf, PAGE_SIZE, "not supported\n");
|
|
|
+
|
|
|
+ return snprintf(buf, PAGE_SIZE,
|
|
|
+ "0x%08x%08x%08x%08x%08x%08x%08x%08x\n",
|
|
|
+ ap_configuration->aqm[0], ap_configuration->aqm[1],
|
|
|
+ ap_configuration->aqm[2], ap_configuration->aqm[3],
|
|
|
+ ap_configuration->aqm[4], ap_configuration->aqm[5],
|
|
|
+ ap_configuration->aqm[6], ap_configuration->aqm[7]);
|
|
|
+}
|
|
|
+
|
|
|
+static BUS_ATTR(ap_usage_domain_mask, 0444,
|
|
|
+ ap_usage_domain_mask_show, NULL);
|
|
|
+
|
|
|
static ssize_t ap_config_time_show(struct bus_type *bus, char *buf)
|
|
|
{
|
|
|
return snprintf(buf, PAGE_SIZE, "%d\n", ap_config_time);
|
|
@@ -1466,6 +854,7 @@ static BUS_ATTR(ap_max_domain_id, 0444, ap_max_domain_id_show, NULL);
|
|
|
static struct bus_attribute *const ap_bus_attrs[] = {
|
|
|
&bus_attr_ap_domain,
|
|
|
&bus_attr_ap_control_domain_mask,
|
|
|
+ &bus_attr_ap_usage_domain_mask,
|
|
|
&bus_attr_config_time,
|
|
|
&bus_attr_poll_thread,
|
|
|
&bus_attr_ap_interrupts,
|
|
@@ -1524,110 +913,162 @@ static int ap_select_domain(void)
|
|
|
return -ENODEV;
|
|
|
}
|
|
|
|
|
|
-/**
|
|
|
- * __ap_scan_bus(): Scan the AP bus.
|
|
|
- * @dev: Pointer to device
|
|
|
- * @data: Pointer to data
|
|
|
- *
|
|
|
- * Scan the AP bus for new devices.
|
|
|
+/*
|
|
|
+ * helper function to be used with bus_find_dev
|
|
|
+ * matches for the card device with the given id
|
|
|
*/
|
|
|
-static int __ap_scan_bus(struct device *dev, void *data)
|
|
|
+static int __match_card_device_with_id(struct device *dev, void *data)
|
|
|
{
|
|
|
- return to_ap_dev(dev)->qid == (ap_qid_t)(unsigned long) data;
|
|
|
+ return is_card_dev(dev) && to_ap_card(dev)->id == (int)(long) data;
|
|
|
}
|
|
|
|
|
|
+/* helper function to be used with bus_find_dev
|
|
|
+ * matches for the queue device with a given qid
|
|
|
+ */
|
|
|
+static int __match_queue_device_with_qid(struct device *dev, void *data)
|
|
|
+{
|
|
|
+ return is_queue_dev(dev) && to_ap_queue(dev)->qid == (int)(long) data;
|
|
|
+}
|
|
|
+
|
|
|
+/**
|
|
|
+ * ap_scan_bus(): Scan the AP bus for new devices
|
|
|
+ * Runs periodically, workqueue timer (ap_config_time)
|
|
|
+ */
|
|
|
static void ap_scan_bus(struct work_struct *unused)
|
|
|
{
|
|
|
- struct ap_device *ap_dev;
|
|
|
+ struct ap_queue *aq;
|
|
|
+ struct ap_card *ac;
|
|
|
struct device *dev;
|
|
|
ap_qid_t qid;
|
|
|
- int queue_depth = 0, device_type = 0;
|
|
|
- unsigned int device_functions = 0;
|
|
|
- int rc, i, borked;
|
|
|
+ int depth = 0, type = 0;
|
|
|
+ unsigned int functions = 0;
|
|
|
+ int rc, id, dom, borked, domains;
|
|
|
|
|
|
ap_query_configuration();
|
|
|
if (ap_select_domain() != 0)
|
|
|
goto out;
|
|
|
|
|
|
-
|
|
|
- spin_lock_bh(&ap_domain_lock);
|
|
|
- for (i = 0; i < AP_DEVICES; i++) {
|
|
|
- qid = AP_MKQID(i, ap_domain_index);
|
|
|
+ for (id = 0; id < AP_DEVICES; id++) {
|
|
|
+ /* check if device is registered */
|
|
|
dev = bus_find_device(&ap_bus_type, NULL,
|
|
|
- (void *)(unsigned long)qid,
|
|
|
- __ap_scan_bus);
|
|
|
- rc = ap_query_queue(qid, &queue_depth, &device_type,
|
|
|
- &device_functions);
|
|
|
- if (dev) {
|
|
|
- ap_dev = to_ap_dev(dev);
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- if (rc == -ENODEV)
|
|
|
- ap_dev->state = AP_STATE_BORKED;
|
|
|
- borked = ap_dev->state == AP_STATE_BORKED;
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
- if (borked) /* Remove broken device */
|
|
|
+ (void *)(long) id,
|
|
|
+ __match_card_device_with_id);
|
|
|
+ ac = dev ? to_ap_card(dev) : NULL;
|
|
|
+ if (!ap_test_config_card_id(id)) {
|
|
|
+ if (dev) {
|
|
|
+ /* Card device has been removed from
|
|
|
+ * configuration, remove the belonging
|
|
|
+ * queue devices.
|
|
|
+ */
|
|
|
+ bus_for_each_dev(&ap_bus_type, NULL,
|
|
|
+ (void *)(long) id,
|
|
|
+ __ap_queue_devices_with_id_unregister);
|
|
|
+ /* now remove the card device */
|
|
|
device_unregister(dev);
|
|
|
- put_device(dev);
|
|
|
- if (!borked)
|
|
|
- continue;
|
|
|
- }
|
|
|
- if (rc)
|
|
|
- continue;
|
|
|
- ap_dev = kzalloc(sizeof(*ap_dev), GFP_KERNEL);
|
|
|
- if (!ap_dev)
|
|
|
- break;
|
|
|
- ap_dev->qid = qid;
|
|
|
- ap_dev->state = AP_STATE_RESET_START;
|
|
|
- ap_dev->interrupt = AP_INTR_DISABLED;
|
|
|
- ap_dev->queue_depth = queue_depth;
|
|
|
- ap_dev->raw_hwtype = device_type;
|
|
|
- ap_dev->device_type = device_type;
|
|
|
- /* CEX6 toleration: map to CEX5 */
|
|
|
- if (device_type == AP_DEVICE_TYPE_CEX6)
|
|
|
- ap_dev->device_type = AP_DEVICE_TYPE_CEX5;
|
|
|
- ap_dev->functions = device_functions;
|
|
|
- spin_lock_init(&ap_dev->lock);
|
|
|
- INIT_LIST_HEAD(&ap_dev->pendingq);
|
|
|
- INIT_LIST_HEAD(&ap_dev->requestq);
|
|
|
- INIT_LIST_HEAD(&ap_dev->list);
|
|
|
- setup_timer(&ap_dev->timeout, ap_request_timeout,
|
|
|
- (unsigned long) ap_dev);
|
|
|
-
|
|
|
- ap_dev->device.bus = &ap_bus_type;
|
|
|
- ap_dev->device.parent = ap_root_device;
|
|
|
- rc = dev_set_name(&ap_dev->device, "card%02x",
|
|
|
- AP_QID_DEVICE(ap_dev->qid));
|
|
|
- if (rc) {
|
|
|
- kfree(ap_dev);
|
|
|
- continue;
|
|
|
- }
|
|
|
- /* Add to list of devices */
|
|
|
- spin_lock_bh(&ap_device_list_lock);
|
|
|
- list_add(&ap_dev->list, &ap_device_list);
|
|
|
- spin_unlock_bh(&ap_device_list_lock);
|
|
|
- /* Start with a device reset */
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- ap_sm_wait(ap_sm_event(ap_dev, AP_EVENT_POLL));
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
- /* Register device */
|
|
|
- ap_dev->device.release = ap_device_release;
|
|
|
- rc = device_register(&ap_dev->device);
|
|
|
- if (rc) {
|
|
|
- spin_lock_bh(&ap_dev->lock);
|
|
|
- list_del_init(&ap_dev->list);
|
|
|
- spin_unlock_bh(&ap_dev->lock);
|
|
|
- put_device(&ap_dev->device);
|
|
|
+ put_device(dev);
|
|
|
+ }
|
|
|
continue;
|
|
|
}
|
|
|
- /* Add device attributes. */
|
|
|
- rc = sysfs_create_group(&ap_dev->device.kobj,
|
|
|
- &ap_dev_attr_group);
|
|
|
- if (rc) {
|
|
|
- device_unregister(&ap_dev->device);
|
|
|
- continue;
|
|
|
+ /* According to the configuration there should be a card
|
|
|
+ * device, so check if there is at least one valid queue
|
|
|
+ * and maybe create queue devices and the card device.
|
|
|
+ */
|
|
|
+ domains = 0;
|
|
|
+ for (dom = 0; dom < AP_DOMAINS; dom++) {
|
|
|
+ qid = AP_MKQID(id, dom);
|
|
|
+ dev = bus_find_device(&ap_bus_type, NULL,
|
|
|
+ (void *)(long) qid,
|
|
|
+ __match_queue_device_with_qid);
|
|
|
+ aq = dev ? to_ap_queue(dev) : NULL;
|
|
|
+ if (!ap_test_config_domain(dom)) {
|
|
|
+ if (dev) {
|
|
|
+ /* Queue device exists but has been
|
|
|
+ * removed from configuration.
|
|
|
+ */
|
|
|
+ device_unregister(dev);
|
|
|
+ put_device(dev);
|
|
|
+ }
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ rc = ap_query_queue(qid, &depth, &type, &functions);
|
|
|
+ if (dev) {
|
|
|
+ spin_lock_bh(&aq->lock);
|
|
|
+ if (rc == -ENODEV ||
|
|
|
+ /* adapter reconfiguration */
|
|
|
+ (ac && ac->functions != functions))
|
|
|
+ aq->state = AP_STATE_BORKED;
|
|
|
+ borked = aq->state == AP_STATE_BORKED;
|
|
|
+ spin_unlock_bh(&aq->lock);
|
|
|
+ if (borked) /* Remove broken device */
|
|
|
+ device_unregister(dev);
|
|
|
+ put_device(dev);
|
|
|
+ if (!borked) {
|
|
|
+ domains++;
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (rc)
|
|
|
+ continue;
|
|
|
+ /* new queue device needed */
|
|
|
+ if (!ac) {
|
|
|
+ /* but first create the card device */
|
|
|
+ ac = ap_card_create(id, depth,
|
|
|
+ type, functions);
|
|
|
+ if (!ac)
|
|
|
+ continue;
|
|
|
+ ac->ap_dev.device.bus = &ap_bus_type;
|
|
|
+ ac->ap_dev.device.parent = ap_root_device;
|
|
|
+ dev_set_name(&ac->ap_dev.device,
|
|
|
+ "card%02x", id);
|
|
|
+ /* Register card with AP bus */
|
|
|
+ rc = device_register(&ac->ap_dev.device);
|
|
|
+ if (rc) {
|
|
|
+ put_device(&ac->ap_dev.device);
|
|
|
+ ac = NULL;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ /* get it and thus adjust reference counter */
|
|
|
+ get_device(&ac->ap_dev.device);
|
|
|
+ /* Add card device to card list */
|
|
|
+ spin_lock_bh(&ap_list_lock);
|
|
|
+ list_add(&ac->list, &ap_card_list);
|
|
|
+ spin_unlock_bh(&ap_list_lock);
|
|
|
+ }
|
|
|
+ /* now create the new queue device */
|
|
|
+ aq = ap_queue_create(qid, type);
|
|
|
+ if (!aq)
|
|
|
+ continue;
|
|
|
+ aq->card = ac;
|
|
|
+ aq->ap_dev.device.bus = &ap_bus_type;
|
|
|
+ aq->ap_dev.device.parent = &ac->ap_dev.device;
|
|
|
+ dev_set_name(&aq->ap_dev.device,
|
|
|
+ "%02x.%04x", id, dom);
|
|
|
+ /* Add queue device to card queue list */
|
|
|
+ spin_lock_bh(&ap_list_lock);
|
|
|
+ list_add(&aq->list, &ac->queues);
|
|
|
+ spin_unlock_bh(&ap_list_lock);
|
|
|
+ /* Start with a device reset */
|
|
|
+ spin_lock_bh(&aq->lock);
|
|
|
+ ap_wait(ap_sm_event(aq, AP_EVENT_POLL));
|
|
|
+ spin_unlock_bh(&aq->lock);
|
|
|
+ /* Register device */
|
|
|
+ rc = device_register(&aq->ap_dev.device);
|
|
|
+ if (rc) {
|
|
|
+ spin_lock_bh(&ap_list_lock);
|
|
|
+ list_del_init(&aq->list);
|
|
|
+ spin_unlock_bh(&ap_list_lock);
|
|
|
+ put_device(&aq->ap_dev.device);
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ domains++;
|
|
|
+ } /* end domain loop */
|
|
|
+ if (ac) {
|
|
|
+ /* remove card dev if there are no queue devices */
|
|
|
+ if (!domains)
|
|
|
+ device_unregister(&ac->ap_dev.device);
|
|
|
+ put_device(&ac->ap_dev.device);
|
|
|
}
|
|
|
- }
|
|
|
- spin_unlock_bh(&ap_domain_lock);
|
|
|
+ } /* end device loop */
|
|
|
out:
|
|
|
mod_timer(&ap_config_timer, jiffies + ap_config_time * HZ);
|
|
|
}
|
|
@@ -1787,7 +1228,15 @@ void ap_module_exit(void)
|
|
|
del_timer_sync(&ap_config_timer);
|
|
|
hrtimer_cancel(&ap_poll_timer);
|
|
|
tasklet_kill(&ap_tasklet);
|
|
|
- bus_for_each_dev(&ap_bus_type, NULL, NULL, __ap_devices_unregister);
|
|
|
+
|
|
|
+ /* first remove queue devices */
|
|
|
+ bus_for_each_dev(&ap_bus_type, NULL, NULL,
|
|
|
+ __ap_queue_devices_unregister);
|
|
|
+ /* now remove the card devices */
|
|
|
+ bus_for_each_dev(&ap_bus_type, NULL, NULL,
|
|
|
+ __ap_card_devices_unregister);
|
|
|
+
|
|
|
+ /* remove bus attributes */
|
|
|
for (i = 0; ap_bus_attrs[i]; i++)
|
|
|
bus_remove_file(&ap_bus_type, ap_bus_attrs[i]);
|
|
|
unregister_pm_notifier(&ap_power_notifier);
|