/linux-master/arch/powerpc/include/asm/ |
H A D | mpic_msgr.h | 37 * @msgr: the message register to return 44 extern void mpic_msgr_put(struct mpic_msgr *msgr); 48 * @msgr: the message register to enable 53 extern void mpic_msgr_enable(struct mpic_msgr *msgr); 57 * @msgr: the message register to disable 62 extern void mpic_msgr_disable(struct mpic_msgr *msgr); 66 * @msgr: the message register to write to 73 static inline void mpic_msgr_write(struct mpic_msgr *msgr, u32 message) argument 75 out_be32(msgr->base, message); 80 * @msgr 86 mpic_msgr_read(struct mpic_msgr *msgr) argument 97 mpic_msgr_clear(struct mpic_msgr *msgr) argument 110 mpic_msgr_set_destination(struct mpic_msgr *msgr, u32 cpu_num) argument 124 mpic_msgr_get_irq(struct mpic_msgr *msgr) argument [all...] |
/linux-master/arch/powerpc/sysdev/ |
H A D | mpic_msgr.c | 32 static inline void _mpic_msgr_mer_write(struct mpic_msgr *msgr, u32 value) argument 34 out_be32(msgr->mer, value); 37 static inline u32 _mpic_msgr_mer_read(struct mpic_msgr *msgr) argument 39 return in_be32(msgr->mer); 42 static inline void _mpic_msgr_disable(struct mpic_msgr *msgr) argument 44 u32 mer = _mpic_msgr_mer_read(msgr); 46 _mpic_msgr_mer_write(msgr, mer & ~(1 << msgr->num)); 52 struct mpic_msgr *msgr; local 55 msgr 70 mpic_msgr_put(struct mpic_msgr *msgr) argument 81 mpic_msgr_enable(struct mpic_msgr *msgr) argument 93 mpic_msgr_disable(struct mpic_msgr *msgr) argument 227 struct mpic_msgr *msgr; local [all...] |
H A D | Makefile | 9 mpic-msgr-obj-$(CONFIG_MPIC_MSGR) += mpic_msgr.o 10 obj-$(CONFIG_MPIC) += mpic.o $(mpic-msi-obj-y) $(mpic-msgr-obj-y)
|
/linux-master/net/ceph/ |
H A D | messenger.c | 197 void ceph_encode_my_addr(struct ceph_messenger *msgr) argument 199 if (!ceph_msgr2(from_msgr(msgr))) { 200 memcpy(&msgr->my_enc_addr, &msgr->inst.addr, 201 sizeof(msgr->my_enc_addr)); 202 ceph_encode_banner_addr(&msgr->my_enc_addr); 255 ceph_msgr_wq = alloc_workqueue("ceph-msgr", WQ_MEM_RECLAIM, 0); 351 if (atomic_read(&con->msgr->stopping)) { 447 ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family, 475 if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELA 631 ceph_con_init(struct ceph_connection *con, void *private, const struct ceph_connection_operations *ops, struct ceph_messenger *msgr) argument 656 ceph_get_global_seq(struct ceph_messenger *msgr, u32 gt) argument 1659 ceph_messenger_reset_nonce(struct ceph_messenger *msgr) argument 1669 ceph_messenger_init(struct ceph_messenger *msgr, struct ceph_entity_addr *myaddr) argument 1699 ceph_messenger_fini(struct ceph_messenger *msgr) argument [all...] |
H A D | messenger_v1.c | 357 con_out_kvec_add(con, sizeof (con->msgr->my_enc_addr), 358 &con->msgr->my_enc_addr); 378 unsigned int global_seq = ceph_get_global_seq(con->msgr, 0); 400 cpu_to_le64(from_msgr(con->msgr)->supported_features); 469 bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); 703 struct ceph_entity_addr *my_addr = &con->msgr->inst.addr; 736 ceph_encode_my_addr(con->msgr); 746 u64 sup_feat = from_msgr(con->msgr)->supported_features; 747 u64 req_feat = from_msgr(con->msgr)->required_features; 873 ceph_get_global_seq(con->msgr, [all...] |
H A D | ceph_common.c | 144 if (!net_eq(current->nsproxy->net_ns, read_pnet(&client->msgr.net))) 694 return &client->msgr.inst.addr; 735 /* msgr */ 739 ceph_messenger_init(&client->msgr, myaddr); 754 ceph_messenger_fini(&client->msgr); 764 atomic_set(&client->msgr.stopping, 1); 769 ceph_messenger_fini(&client->msgr); 782 ceph_messenger_reset_nonce(&client->msgr);
|
H A D | messenger_v2.c | 1476 struct ceph_entity_addr *my_addr = &con->msgr->inst.addr; 1477 struct ceph_client *client = from_msgr(con->msgr); 1528 struct ceph_entity_addr *my_addr = &con->msgr->inst.addr; 1869 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { 1890 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { 1909 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { 1936 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { 1960 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { 2008 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { 2223 struct ceph_entity_addr *my_addr = &con->msgr [all...] |
H A D | mon_client.c | 1203 &monc->client->msgr); 1243 * flush msgr queue before we destroy ourselves to ensure that: 1291 monc->client->msgr.inst.name.type = CEPH_ENTITY_TYPE_CLIENT; 1292 monc->client->msgr.inst.name.num =
|
H A D | auth_x.c | 1033 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) 1052 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN))
|
H A D | osd_client.c | 1296 ceph_con_init(&osd->o_con, osd, &osd_con_ops, &osdc->client->msgr); 1421 "letting msgr retry\n"); 2346 * around. Cancel it to avoid corrupting the msgr.
|
/linux-master/include/linux/ceph/ |
H A D | messenger.h | 475 struct ceph_messenger *msgr; member in struct:ceph_connection 525 void ceph_encode_my_addr(struct ceph_messenger *msgr); 531 u32 ceph_get_global_seq(struct ceph_messenger *msgr, u32 gt); 582 extern void ceph_messenger_init(struct ceph_messenger *msgr, 584 extern void ceph_messenger_fini(struct ceph_messenger *msgr); 585 extern void ceph_messenger_reset_nonce(struct ceph_messenger *msgr); 589 struct ceph_messenger *msgr);
|
H A D | libceph.h | 132 struct ceph_messenger msgr; /* messenger instance */ member in struct:ceph_client 144 #define from_msgr(ms) container_of(ms, struct ceph_client, msgr)
|
H A D | rados.h | 10 #include <linux/ceph/msgr.h>
|
H A D | ceph_fs.h | 16 #include <linux/ceph/msgr.h>
|
/linux-master/fs/ceph/ |
H A D | snap.c | 921 ret = ceph_monc_blocklist_add(&client->monc, &client->msgr.inst.addr); 924 ceph_pr_addr(&client->msgr.inst.addr), ret); 928 ret ? "" : ceph_pr_addr(&client->msgr.inst.addr),
|
H A D | debugfs.c | 355 struct ceph_entity_inst *inst = &fsc->client->msgr.inst;
|
H A D | mds_client.c | 1002 ceph_con_init(&s->s_con, s, &mds_con_ops, &mdsc->fsc->client->msgr);
|