Searched refs:msgq (Results 1 - 13 of 13) sorted by relevance

/linux-4.1.27/drivers/scsi/arm/
H A Dmsgqueue.c20 * Function: struct msgqueue_entry *mqe_alloc(MsgQueue_t *msgq)
22 * Params : msgq - message queue to claim entry for
25 static struct msgqueue_entry *mqe_alloc(MsgQueue_t *msgq) mqe_alloc() argument
29 if ((mq = msgq->free) != NULL) mqe_alloc()
30 msgq->free = mq->next; mqe_alloc()
36 * Function: void mqe_free(MsgQueue_t *msgq, struct msgqueue_entry *mq)
38 * Params : msgq - message queue to free entry from
41 static void mqe_free(MsgQueue_t *msgq, struct msgqueue_entry *mq) mqe_free() argument
44 mq->next = msgq->free; mqe_free()
45 msgq->free = mq; mqe_free()
50 * Function: void msgqueue_initialise(MsgQueue_t *msgq)
52 * Params : msgq - queue to initialise
54 void msgqueue_initialise(MsgQueue_t *msgq) msgqueue_initialise() argument
58 msgq->qe = NULL; msgqueue_initialise()
59 msgq->free = &msgq->entries[0]; msgqueue_initialise()
62 msgq->entries[i].next = &msgq->entries[i + 1]; msgqueue_initialise()
64 msgq->entries[NR_MESSAGES - 1].next = NULL; msgqueue_initialise()
69 * Function: void msgqueue_free(MsgQueue_t *msgq)
71 * Params : msgq - queue to free
73 void msgqueue_free(MsgQueue_t *msgq) msgqueue_free() argument
78 * Function: int msgqueue_msglength(MsgQueue_t *msgq)
80 * Params : msgq - queue to examine
83 int msgqueue_msglength(MsgQueue_t *msgq) msgqueue_msglength() argument
85 struct msgqueue_entry *mq = msgq->qe; msgqueue_msglength()
88 for (mq = msgq->qe; mq; mq = mq->next) msgqueue_msglength()
95 * Function: struct message *msgqueue_getmsg(MsgQueue_t *msgq, int msgno)
97 * Params : msgq - queue to obtain message from
101 struct message *msgqueue_getmsg(MsgQueue_t *msgq, int msgno) msgqueue_getmsg() argument
105 for (mq = msgq->qe; mq && msgno; mq = mq->next, msgno--); msgqueue_getmsg()
111 * Function: int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...)
113 * Params : msgq - queue to add message on
118 int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...) msgqueue_addmsg() argument
120 struct msgqueue_entry *mq = mqe_alloc(msgq); msgqueue_addmsg()
136 mqp = &msgq->qe; msgqueue_addmsg()
147 * Function: void msgqueue_flush(MsgQueue_t *msgq)
149 * Params : msgq - queue to flush
151 void msgqueue_flush(MsgQueue_t *msgq) msgqueue_flush() argument
155 for (mq = msgq->qe; mq; mq = mqnext) { msgqueue_flush()
157 mqe_free(msgq, mq); msgqueue_flush()
159 msgq->qe = NULL; msgqueue_flush()
H A Dmsgqueue.h35 * Function: void msgqueue_initialise(MsgQueue_t *msgq)
37 * Params : msgq - queue to initialise
39 extern void msgqueue_initialise(MsgQueue_t *msgq);
42 * Function: void msgqueue_free(MsgQueue_t *msgq)
44 * Params : msgq - queue to free
46 extern void msgqueue_free(MsgQueue_t *msgq);
49 * Function: int msgqueue_msglength(MsgQueue_t *msgq)
51 * Params : msgq - queue to examine
54 extern int msgqueue_msglength(MsgQueue_t *msgq);
57 * Function: struct message *msgqueue_getmsg(MsgQueue_t *msgq, int msgno)
59 * Params : msgq - queue to obtain message from
63 extern struct message *msgqueue_getmsg(MsgQueue_t *msgq, int msgno);
66 * Function: int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...)
68 * Params : msgq - queue to add message on
73 extern int msgqueue_addmsg(MsgQueue_t *msgq, int length, ...);
76 * Function: void msgqueue_flush(MsgQueue_t *msgq)
78 * Params : msgq - queue to flush
80 extern void msgqueue_flush(MsgQueue_t *msgq);
/linux-4.1.27/drivers/net/ethernet/brocade/bna/
H A Dbfa_msgq.c100 bfa_wc_down(&cmdq->msgq->init_wc); cmdq_sm_init_wait_entry()
202 if (!bfa_nw_ioc_mbox_queue(cmdq->msgq->ioc, &cmdq->dbell_mb, bfa_msgq_cmdq_dbell()
303 if (!bfa_nw_ioc_mbox_queue(cmdq->msgq->ioc, &cmdq->copy_mb, bfa_msgq_cmdq_copy_rsp()
310 bfa_msgq_cmdq_attach(struct bfa_msgq_cmdq *cmdq, struct bfa_msgq *msgq) bfa_msgq_cmdq_attach() argument
314 cmdq->msgq = msgq; bfa_msgq_cmdq_attach()
365 bfa_wc_down(&rspq->msgq->init_wc); rspq_sm_init_wait_entry()
412 if (!bfa_nw_ioc_is_disabled(rspq->msgq->ioc)) rspq_sm_dbell_wait_entry()
460 if (!bfa_nw_ioc_mbox_queue(rspq->msgq->ioc, &rspq->dbell_mb, bfa_msgq_rspq_dbell()
498 bfa_msgq_rspq_attach(struct bfa_msgq_rspq *rspq, struct bfa_msgq *msgq) bfa_msgq_rspq_attach() argument
501 rspq->msgq = msgq; bfa_msgq_rspq_attach()
506 bfa_msgq_init_rsp(struct bfa_msgq *msgq, bfa_msgq_init_rsp() argument
509 bfa_fsm_send_event(&msgq->cmdq, CMDQ_E_INIT_RESP); bfa_msgq_init_rsp()
510 bfa_fsm_send_event(&msgq->rspq, RSPQ_E_INIT_RESP); bfa_msgq_init_rsp()
516 struct bfa_msgq *msgq = (struct bfa_msgq *)arg; bfa_msgq_init() local
518 (struct bfi_msgq_cfg_req *)&msgq->init_mb.msg[0]; bfa_msgq_init()
524 bfa_dma_be_addr_set(msgq_cfg->cmdq.addr, msgq->cmdq.addr.pa); bfa_msgq_init()
525 msgq_cfg->cmdq.q_depth = htons(msgq->cmdq.depth); bfa_msgq_init()
526 bfa_dma_be_addr_set(msgq_cfg->rspq.addr, msgq->rspq.addr.pa); bfa_msgq_init()
527 msgq_cfg->rspq.q_depth = htons(msgq->rspq.depth); bfa_msgq_init()
529 bfa_nw_ioc_mbox_queue(msgq->ioc, &msgq->init_mb, NULL, NULL); bfa_msgq_init()
535 struct bfa_msgq *msgq = (struct bfa_msgq *)cbarg; bfa_msgq_isr() local
539 bfa_msgq_init_rsp(msgq, msg); bfa_msgq_isr()
543 bfa_msgq_rspq_pi_update(&msgq->rspq, msg); bfa_msgq_isr()
547 bfa_msgq_cmdq_ci_update(&msgq->cmdq, msg); bfa_msgq_isr()
551 bfa_msgq_cmdq_copy_req(&msgq->cmdq, msg); bfa_msgq_isr()
562 struct bfa_msgq *msgq = (struct bfa_msgq *)cbarg; bfa_msgq_notify() local
566 bfa_wc_init(&msgq->init_wc, bfa_msgq_init, msgq); bfa_msgq_notify()
567 bfa_wc_up(&msgq->init_wc); bfa_msgq_notify()
568 bfa_fsm_send_event(&msgq->cmdq, CMDQ_E_START); bfa_msgq_notify()
569 bfa_wc_up(&msgq->init_wc); bfa_msgq_notify()
570 bfa_fsm_send_event(&msgq->rspq, RSPQ_E_START); bfa_msgq_notify()
571 bfa_wc_wait(&msgq->init_wc); bfa_msgq_notify()
575 bfa_fsm_send_event(&msgq->cmdq, CMDQ_E_STOP); bfa_msgq_notify()
576 bfa_fsm_send_event(&msgq->rspq, RSPQ_E_STOP); bfa_msgq_notify()
580 bfa_fsm_send_event(&msgq->cmdq, CMDQ_E_FAIL); bfa_msgq_notify()
581 bfa_fsm_send_event(&msgq->rspq, RSPQ_E_FAIL); bfa_msgq_notify()
597 bfa_msgq_memclaim(struct bfa_msgq *msgq, u8 *kva, u64 pa) bfa_msgq_memclaim() argument
599 msgq->cmdq.addr.kva = kva; bfa_msgq_memclaim()
600 msgq->cmdq.addr.pa = pa; bfa_msgq_memclaim()
605 msgq->rspq.addr.kva = kva; bfa_msgq_memclaim()
606 msgq->rspq.addr.pa = pa; bfa_msgq_memclaim()
610 bfa_msgq_attach(struct bfa_msgq *msgq, struct bfa_ioc *ioc) bfa_msgq_attach() argument
612 msgq->ioc = ioc; bfa_msgq_attach()
614 bfa_msgq_cmdq_attach(&msgq->cmdq, msgq); bfa_msgq_attach()
615 bfa_msgq_rspq_attach(&msgq->rspq, msgq); bfa_msgq_attach()
617 bfa_nw_ioc_mbox_regisr(msgq->ioc, BFI_MC_MSGQ, bfa_msgq_isr, msgq); bfa_msgq_attach()
618 bfa_q_qe_init(&msgq->ioc_notify); bfa_msgq_attach()
619 bfa_ioc_notify_init(&msgq->ioc_notify, bfa_msgq_notify, msgq); bfa_msgq_attach()
620 bfa_nw_ioc_notify_register(msgq->ioc, &msgq->ioc_notify); bfa_msgq_attach()
624 bfa_msgq_regisr(struct bfa_msgq *msgq, enum bfi_mclass mc, bfa_msgq_regisr() argument
627 msgq->rspq.rsphdlr[mc].cbfn = cbfn; bfa_msgq_regisr()
628 msgq->rspq.rsphdlr[mc].cbarg = cbarg; bfa_msgq_regisr()
632 bfa_msgq_cmd_post(struct bfa_msgq *msgq, struct bfa_msgq_cmd_entry *cmd) bfa_msgq_cmd_post() argument
635 BFA_MSGQ_FREE_CNT(&msgq->cmdq)) { bfa_msgq_cmd_post()
636 __cmd_copy(&msgq->cmdq, cmd); bfa_msgq_cmd_post()
638 bfa_fsm_send_event(&msgq->cmdq, CMDQ_E_POST); bfa_msgq_cmd_post()
640 list_add_tail(&cmd->qe, &msgq->cmdq.pending_q); bfa_msgq_cmd_post()
645 bfa_msgq_rsp_copy(struct bfa_msgq *msgq, u8 *buf, size_t buf_len) bfa_msgq_rsp_copy() argument
647 struct bfa_msgq_rspq *rspq = &msgq->rspq; bfa_msgq_rsp_copy()
H A Dbfa_msgq.h83 struct bfa_msgq *msgq; member in struct:bfa_msgq_cmdq
108 struct bfa_msgq *msgq; member in struct:bfa_msgq_rspq
123 void bfa_msgq_memclaim(struct bfa_msgq *msgq, u8 *kva, u64 pa);
124 void bfa_msgq_attach(struct bfa_msgq *msgq, struct bfa_ioc *ioc);
125 void bfa_msgq_regisr(struct bfa_msgq *msgq, enum bfi_mclass mc,
127 void bfa_msgq_cmd_post(struct bfa_msgq *msgq,
129 void bfa_msgq_rsp_copy(struct bfa_msgq *msgq, u8 *buf, size_t buf_len);
H A Dbna_enet.c426 bfa_msgq_cmd_post(&ethport->bna->msgq, &ethport->msgq_cmd); bna_bfi_ethport_admin_up()
443 bfa_msgq_cmd_post(&ethport->bna->msgq, &ethport->msgq_cmd); bna_bfi_ethport_admin_down()
464 bfa_msgq_cmd_post(&ethport->bna->msgq, &ethport->msgq_cmd); bna_bfi_ethport_lpbk_up()
481 bfa_msgq_cmd_post(&ethport->bna->msgq, &ethport->msgq_cmd); bna_bfi_ethport_lpbk_down()
1192 bfa_msgq_cmd_post(&enet->bna->msgq, &enet->msgq_cmd); bna_bfi_pause_set()
1656 bfa_msgq_cmd_post(&ioceth->bna->msgq, &ioceth->msgq_cmd); bna_bfi_attr_get()
1755 bfa_msgq_attach(&bna->msgq, &ioceth->ioc); bna_ioceth_init()
1756 bfa_msgq_memclaim(&bna->msgq, kva, dma); bna_ioceth_init()
1757 bfa_msgq_regisr(&bna->msgq, BFI_MC_ENET, bna_msgq_rsp_handler, bna); bna_ioceth_init()
1917 bfa_msgq_cmd_post(&bna->msgq, &bna->stats_mod.stats_get_cmd); bna_bfi_stats_get()
2040 /* Also initializes diag, cee, sfp, phy_port, msgq */ bna_init()
H A Dbna_tx_rx.c289 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_ucast_req()
305 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_mcast_add_req()
321 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_mcast_del_req()
336 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_mcast_filter_req()
351 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_rx_promisc_req()
376 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_rx_vlan_filter_set()
391 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_vlan_strip_enable()
407 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_rit_cfg()
427 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_rss_cfg()
442 bfa_msgq_cmd_post(&rxf->rx->bna->msgq, &rxf->msgq_cmd); bna_bfi_rss_enable()
1903 bfa_msgq_cmd_post(&rx->bna->msgq, &rx->msgq_cmd); bna_bfi_rx_enet_start()
1917 bfa_msgq_cmd_post(&rx->bna->msgq, &rx->msgq_cmd); bna_bfi_rx_enet_stop()
2343 bfa_msgq_rsp_copy(&rx->bna->msgq, (u8 *)cfg_rsp, bna_bfi_rx_enet_start_rsp()
3419 bfa_msgq_cmd_post(&tx->bna->msgq, &tx->msgq_cmd); bna_bfi_tx_enet_start()
3433 bfa_msgq_cmd_post(&tx->bna->msgq, &tx->msgq_cmd); bna_bfi_tx_enet_stop()
3591 bfa_msgq_rsp_copy(&tx->bna->msgq, (u8 *)cfg_rsp, bna_bfi_tx_enet_start_rsp()
H A Dbna_types.h939 struct bfa_msgq msgq; member in struct:bna
/linux-4.1.27/drivers/isdn/mISDN/
H A Dstack.c34 skb_queue_tail(&st->msgq, skb); _queue_message()
229 skb = skb_dequeue(&st->msgq); mISDNStackd()
234 skb = skb_dequeue(&st->msgq); mISDNStackd()
274 if (!skb_queue_empty(&st->msgq)) mISDNStackd()
323 skb_queue_purge(&st->msgq); mISDNStackd()
387 skb_queue_head_init(&newst->msgq); create_stack()
/linux-4.1.27/security/selinux/include/
H A Dclassmap.h101 { "msgq",
/linux-4.1.27/include/drm/
H A Ddrm_dp_mst_helper.h351 /* msg has started transmitting on a slot - still on msgq */
353 /* msg has finished transmitting on a slot - removed from msgq only in slot */
/linux-4.1.27/kernel/
H A Dauditsc.c2134 * @qbytes: msgq bytes
2135 * @uid: msgq user id
2136 * @gid: msgq group id
2137 * @mode: msgq mode (permissions)
/linux-4.1.27/include/linux/
H A DmISDNif.h512 struct sk_buff_head msgq; member in struct:mISDNstack
/linux-4.1.27/arch/ia64/kernel/
H A Dperfmon.c814 DPRINT(("ctx=%p msgq reset\n", ctx)); pfm_reset_msgq()

Completed in 518 milliseconds