Searched refs:msgr (Results 1 - 17 of 17) sorted by relevance

/linux-master/arch/powerpc/include/asm/
H A Dmpic_msgr.h37 * @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 Dmpic_msgr.c32 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 DMakefile9 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 Dmessenger.c197 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 Dmessenger_v1.c357 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 Dceph_common.c144 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 Dmessenger_v2.c1476 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 Dmon_client.c1203 &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 Dauth_x.c1033 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN))
1052 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN))
H A Dosd_client.c1296 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 Dmessenger.h475 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 Dlibceph.h132 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 Drados.h10 #include <linux/ceph/msgr.h>
H A Dceph_fs.h16 #include <linux/ceph/msgr.h>
/linux-master/fs/ceph/
H A Dsnap.c921 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 Ddebugfs.c355 struct ceph_entity_inst *inst = &fsc->client->msgr.inst;
H A Dmds_client.c1002 ceph_con_init(&s->s_con, s, &mds_con_ops, &mdsc->fsc->client->msgr);

Completed in 234 milliseconds