event_queue
hdev->event_queue.ci,
hl_eq_dump(hdev, &hdev->event_queue);
hl_eq_reset(hdev, &hdev->event_queue);
rc = hl_eq_init(hdev, &hdev->event_queue);
hl_eq_fini(hdev, &hdev->event_queue);
hl_eq_fini(hdev, &hdev->event_queue);
hdev->event_queue.check_eqe_index = false;
hdev->event_queue.check_eqe_index = true;
struct hl_eq event_queue;
if ((hdev->event_queue.check_eqe_index) &&
hl_irq_handler_eq(irq, &hdev->event_queue);
eq = &hdev->event_queue;
hdev->event_queue.check_eqe_index = false;
hdev->event_queue.check_eqe_index = true;
&hdev->event_queue);
free_irq(irq, &hdev->event_queue);
eq = &hdev->event_queue;
eq = &hdev->event_queue;
&hdev->event_queue);
free_irq(irq, &hdev->event_queue);
struct gpib_event_queue *queue = &board->event_queue;
spin_lock_irqsave(&board->event_queue.lock, flags);
spin_unlock_irqrestore(&board->event_queue.lock, flags);
retval = pop_gpib_event(board, &board->event_queue, &event);
init_event_queue(&board->event_queue);
while (num_gpib_events(&board->event_queue))
pop_gpib_event(board, &board->event_queue, &dummy);
if (num_gpib_events(&board->event_queue))
struct gpib_event_queue event_queue;
void ib_uverbs_free_event_queue(struct ib_uverbs_event_queue *event_queue);
void ib_uverbs_free_event_queue(struct ib_uverbs_event_queue *event_queue)
spin_lock_irq(&event_queue->lock);
event_queue->is_closed = 1;
spin_unlock_irq(&event_queue->lock);
wake_up_interruptible(&event_queue->poll_wait);
kill_fasync(&event_queue->async_queue, SIGIO, POLL_IN);
spin_lock_irq(&event_queue->lock);
list_for_each_entry_safe(entry, tmp, &event_queue->event_list, list) {
spin_unlock_irq(&event_queue->lock);
wake_up(&dd->event_queue);
dd->event_queue,
wait_queue_head_t event_queue;
init_waitqueue_head(&dd->event_queue);
LIST_HEAD(event_queue);
list_splice_init(&events->queue, &event_queue);
list_for_each_entry_safe(event, next_event, &event_queue, list) {
queue_delayed_work(wl->event_queue, &wl->event_work, 0);
wl->event_queue = create_singlethread_workqueue("gelic_event");
if (!wl->event_queue)
destroy_workqueue(wl->event_queue);
flush_workqueue(wl->event_queue);
struct workqueue_struct *event_queue;
struct event_queue ev_queue[MAX_EVENT];
struct event_queue *ev_put ;
struct event_queue *ev_get ;
struct event_queue *ev ; /* pointer into queue */
struct sk_buff_head *event_queue = &bus->trans.event_queue;
struct sk_buff *current_event_skb = skb_dequeue(event_queue);
current_event_skb = skb_dequeue(event_queue);
if (likely(skb_queue_len(&trans->event_queue) <
skb_queue_tail(&trans->event_queue, skb);
skb_queue_head_init(&trans->event_queue);
struct sk_buff_head *event_queue = &bus->trans.event_queue;
struct sk_buff *current_event_skb = skb_dequeue(event_queue);
current_event_skb = skb_dequeue(event_queue);
struct sk_buff_head event_queue;
init_waitqueue_head(&pevent->event_queue);
status = wait_event_interruptible(event->event_queue,
status = wait_event_interruptible_timeout(event->event_queue,
wake_up_interruptible(&event->event_queue);
wait_queue_head_t event_queue;
struct list_head event_queue;
INIT_LIST_HEAD(&priv->event_queue);
list_splice_init(&priv->event_queue, &list);
list_splice_init(&priv->event_queue, &list);
list_splice_init(&priv->event_queue, &list);
first = list_empty(&priv->event_queue);
list_add_tail(&event->link, &priv->event_queue);
list_for_each_entry_safe(event, event_next, &ctl->event_queue, entry) {
wait_event_interruptible(ctl->event_wq, !list_empty(&ctl->event_queue) ||
list_for_each_entry_safe(event, evt_next, &ctl->event_queue, entry) {
event = list_first_entry_or_null(&ctl->event_queue, struct t7xx_fsm_event, entry);
list_add_tail(&event->entry, &ctl->event_queue);
list_for_each_entry_safe(event, evt_next, &ctl->event_queue, entry) {
INIT_LIST_HEAD(&ctl->event_queue);
struct list_head event_queue;
struct event_info event_queue[10];
taskInfo = &(ctrl->event_queue[ctrl->next_event]);
if (ctrl->event_queue[loop].event_type != 0) {
hp_slot = ctrl->event_queue[loop].hp_slot;
if (ctrl->event_queue[loop].event_type == INT_BUTTON_PRESS) {
} else if (ctrl->event_queue[loop].event_type ==
else if (ctrl->event_queue[loop].event_type == INT_BUTTON_RELEASE) {
else if (ctrl->event_queue[loop].event_type == INT_POWER_FAULT) {
ctrl->event_queue[loop].event_type = 0;
taskInfo = &(ctrl->event_queue[ctrl->next_event]);
taskInfo = &(ctrl->event_queue[ctrl->next_event]);
LIST_HEAD(event_queue);
list_splice_init(&smsg_event_queue, &event_queue);
list_for_each_entry_safe(p, n, &event_queue, list) {
kfree(tw_dev->event_queue[0]);
tw_dev->event_queue[0] = kzalloc_objs(TW_Event, TW_Q_LENGTH);
if (!tw_dev->event_queue[0]) {
tw_dev->event_queue[i] = (TW_Event *)((unsigned char *)tw_dev->event_queue[0] + (i * sizeof(TW_Event)));
event = tw_dev->event_queue[tw_dev->error_index];
memcpy(tw_ioctl->data_buffer, tw_dev->event_queue[event_index], sizeof(TW_Event));
tw_dev->event_queue[event_index]->retrieved = TW_AEN_RETRIEVED;
memcpy(tw_ioctl->data_buffer, tw_dev->event_queue[event_index], sizeof(TW_Event));
tw_dev->event_queue[event_index]->retrieved = TW_AEN_RETRIEVED;
event_index = (start_index + sequence_id - tw_dev->event_queue[start_index]->sequence_id + 1) % TW_Q_LENGTH;
if (!(tw_dev->event_queue[event_index]->sequence_id > sequence_id)) {
memcpy(tw_ioctl->data_buffer, tw_dev->event_queue[event_index], sizeof(TW_Event));
tw_dev->event_queue[event_index]->retrieved = TW_AEN_RETRIEVED;
event_index = (start_index + sequence_id - tw_dev->event_queue[start_index]->sequence_id - 1) % TW_Q_LENGTH;
if (!(tw_dev->event_queue[event_index]->sequence_id < sequence_id)) {
memcpy(tw_ioctl->data_buffer, tw_dev->event_queue[event_index], sizeof(TW_Event));
tw_dev->event_queue[event_index]->retrieved = TW_AEN_RETRIEVED;
TW_Event *event_queue[TW_Q_LENGTH];
tw_dev->event_queue[0] = kzalloc_objs(TW_Event, TW_Q_LENGTH);
if (!tw_dev->event_queue[0]) {
tw_dev->event_queue[i] = (TW_Event *)((unsigned char *)tw_dev->event_queue[0] + (i * sizeof(TW_Event)));
ret = memory_read_from_buffer(outbuf, count, &offset, tw_dev->event_queue[0], sizeof(TW_Event) * TW_Q_LENGTH);
event = tw_dev->event_queue[tw_dev->error_index];
kfree(tw_dev->event_queue[0]);
TW_Event *event_queue[TW_Q_LENGTH];
struct pqi_event_queue event_queue;
struct pqi_event_queue *event_queue;
event_queue = &ctrl_info->event_queue;
oq_ci = event_queue->oq_ci_copy;
oq_pi = readl(event_queue->oq_pi);
response = event_queue->oq_element_array + (oq_ci * PQI_EVENT_OQ_ELEMENT_LENGTH);
event_queue->oq_ci_copy = oq_ci;
writel(oq_ci, event_queue->oq_ci);
ctrl_info->event_queue.oq_element_array = element_array;
ctrl_info->event_queue.oq_element_array_bus_addr =
ctrl_info->event_queue.oq_pi = next_queue_index;
ctrl_info->event_queue.oq_pi_bus_addr =
ctrl_info->event_queue.oq_id = next_oq_id++;
ctrl_info->event_queue.int_msg_num = 0;
struct pqi_event_queue *event_queue;
event_queue = &ctrl_info->event_queue;
put_unaligned_le16(event_queue->oq_id,
put_unaligned_le64((u64)event_queue->oq_element_array_bus_addr,
put_unaligned_le64((u64)event_queue->oq_pi_bus_addr,
put_unaligned_le16(event_queue->int_msg_num,
event_queue->oq_ci = ctrl_info->iomem_base +
put_unaligned_le16(ctrl_info->event_queue.oq_id,
struct pqi_event_queue *event_queue;
event_queue = &ctrl_info->event_queue;
writel(0, event_queue->oq_pi);
event_queue->oq_ci_copy = 0;
parser->event_queue[pos] = entry;
*event = parser->event_queue[pos];
u32 event_queue[EVENT_QUEUE_SIZE];