msgr 44 arch/powerpc/include/asm/mpic_msgr.h extern void mpic_msgr_put(struct mpic_msgr *msgr); msgr 53 arch/powerpc/include/asm/mpic_msgr.h extern void mpic_msgr_enable(struct mpic_msgr *msgr); msgr 62 arch/powerpc/include/asm/mpic_msgr.h extern void mpic_msgr_disable(struct mpic_msgr *msgr); msgr 73 arch/powerpc/include/asm/mpic_msgr.h static inline void mpic_msgr_write(struct mpic_msgr *msgr, u32 message) msgr 75 arch/powerpc/include/asm/mpic_msgr.h out_be32(msgr->base, message); msgr 86 arch/powerpc/include/asm/mpic_msgr.h static inline u32 mpic_msgr_read(struct mpic_msgr *msgr) msgr 88 arch/powerpc/include/asm/mpic_msgr.h return in_be32(msgr->base); msgr 97 arch/powerpc/include/asm/mpic_msgr.h static inline void mpic_msgr_clear(struct mpic_msgr *msgr) msgr 99 arch/powerpc/include/asm/mpic_msgr.h (void) mpic_msgr_read(msgr); msgr 110 arch/powerpc/include/asm/mpic_msgr.h static inline void mpic_msgr_set_destination(struct mpic_msgr *msgr, msgr 113 arch/powerpc/include/asm/mpic_msgr.h out_be32(msgr->base, 1 << get_hard_smp_processor_id(cpu_num)); msgr 124 arch/powerpc/include/asm/mpic_msgr.h static inline int mpic_msgr_get_irq(struct mpic_msgr *msgr) msgr 126 arch/powerpc/include/asm/mpic_msgr.h return msgr->irq; msgr 30 arch/powerpc/sysdev/mpic_msgr.c static inline void _mpic_msgr_mer_write(struct mpic_msgr *msgr, u32 value) msgr 32 arch/powerpc/sysdev/mpic_msgr.c out_be32(msgr->mer, value); msgr 35 arch/powerpc/sysdev/mpic_msgr.c static inline u32 _mpic_msgr_mer_read(struct mpic_msgr *msgr) msgr 37 arch/powerpc/sysdev/mpic_msgr.c return in_be32(msgr->mer); msgr 40 arch/powerpc/sysdev/mpic_msgr.c static inline void _mpic_msgr_disable(struct mpic_msgr *msgr) msgr 42 arch/powerpc/sysdev/mpic_msgr.c u32 mer = _mpic_msgr_mer_read(msgr); msgr 44 arch/powerpc/sysdev/mpic_msgr.c _mpic_msgr_mer_write(msgr, mer & ~(1 << msgr->num)); msgr 50 arch/powerpc/sysdev/mpic_msgr.c struct mpic_msgr *msgr; msgr 53 arch/powerpc/sysdev/mpic_msgr.c msgr = ERR_PTR(-EBUSY); msgr 59 arch/powerpc/sysdev/mpic_msgr.c msgr = mpic_msgrs[reg_num]; msgr 60 arch/powerpc/sysdev/mpic_msgr.c if (msgr->in_use == MSGR_FREE) msgr 61 arch/powerpc/sysdev/mpic_msgr.c msgr->in_use = MSGR_INUSE; msgr 64 arch/powerpc/sysdev/mpic_msgr.c return msgr; msgr 68 arch/powerpc/sysdev/mpic_msgr.c void mpic_msgr_put(struct mpic_msgr *msgr) msgr 72 arch/powerpc/sysdev/mpic_msgr.c raw_spin_lock_irqsave(&msgr->lock, flags); msgr 73 arch/powerpc/sysdev/mpic_msgr.c msgr->in_use = MSGR_FREE; msgr 74 arch/powerpc/sysdev/mpic_msgr.c _mpic_msgr_disable(msgr); msgr 75 arch/powerpc/sysdev/mpic_msgr.c raw_spin_unlock_irqrestore(&msgr->lock, flags); msgr 79 arch/powerpc/sysdev/mpic_msgr.c void mpic_msgr_enable(struct mpic_msgr *msgr) msgr 84 arch/powerpc/sysdev/mpic_msgr.c raw_spin_lock_irqsave(&msgr->lock, flags); msgr 85 arch/powerpc/sysdev/mpic_msgr.c mer = _mpic_msgr_mer_read(msgr); msgr 86 arch/powerpc/sysdev/mpic_msgr.c _mpic_msgr_mer_write(msgr, mer | (1 << msgr->num)); msgr 87 arch/powerpc/sysdev/mpic_msgr.c raw_spin_unlock_irqrestore(&msgr->lock, flags); msgr 91 arch/powerpc/sysdev/mpic_msgr.c void mpic_msgr_disable(struct mpic_msgr *msgr) msgr 95 arch/powerpc/sysdev/mpic_msgr.c raw_spin_lock_irqsave(&msgr->lock, flags); msgr 96 arch/powerpc/sysdev/mpic_msgr.c _mpic_msgr_disable(msgr); msgr 97 arch/powerpc/sysdev/mpic_msgr.c raw_spin_unlock_irqrestore(&msgr->lock, flags); msgr 218 arch/powerpc/sysdev/mpic_msgr.c struct mpic_msgr *msgr; msgr 221 arch/powerpc/sysdev/mpic_msgr.c msgr = kzalloc(sizeof(struct mpic_msgr), GFP_KERNEL); msgr 222 arch/powerpc/sysdev/mpic_msgr.c if (!msgr) { msgr 228 arch/powerpc/sysdev/mpic_msgr.c msgr->base = msgr_block_addr + i * MPIC_MSGR_STRIDE; msgr 229 arch/powerpc/sysdev/mpic_msgr.c msgr->mer = (u32 *)((u8 *)msgr->base + MPIC_MSGR_MER_OFFSET); msgr 230 arch/powerpc/sysdev/mpic_msgr.c msgr->in_use = MSGR_FREE; msgr 231 arch/powerpc/sysdev/mpic_msgr.c msgr->num = i; msgr 232 arch/powerpc/sysdev/mpic_msgr.c raw_spin_lock_init(&msgr->lock); msgr 235 arch/powerpc/sysdev/mpic_msgr.c msgr->irq = irq_of_parse_and_map(np, irq_index); msgr 236 arch/powerpc/sysdev/mpic_msgr.c if (!msgr->irq) { msgr 239 arch/powerpc/sysdev/mpic_msgr.c kfree(msgr); msgr 244 arch/powerpc/sysdev/mpic_msgr.c msgr->irq = 0; msgr 247 arch/powerpc/sysdev/mpic_msgr.c mpic_msgrs[reg_number] = msgr; msgr 248 arch/powerpc/sysdev/mpic_msgr.c mpic_msgr_disable(msgr); msgr 250 arch/powerpc/sysdev/mpic_msgr.c reg_number, msgr->irq); msgr 632 fs/ceph/mds_client.c ceph_con_init(&s->s_con, s, &mds_con_ops, &mdsc->fsc->client->msgr); msgr 136 include/linux/ceph/libceph.h struct ceph_messenger msgr; /* messenger instance */ msgr 148 include/linux/ceph/libceph.h #define from_msgr(ms) container_of(ms, struct ceph_client, msgr) msgr 259 include/linux/ceph/messenger.h struct ceph_messenger *msgr; msgr 338 include/linux/ceph/messenger.h extern void ceph_messenger_init(struct ceph_messenger *msgr, msgr 340 include/linux/ceph/messenger.h extern void ceph_messenger_fini(struct ceph_messenger *msgr); msgr 341 include/linux/ceph/messenger.h extern void ceph_messenger_reset_nonce(struct ceph_messenger *msgr); msgr 345 include/linux/ceph/messenger.h struct ceph_messenger *msgr); msgr 876 net/ceph/auth_x.c if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) msgr 895 net/ceph/auth_x.c if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) msgr 144 net/ceph/ceph_common.c if (!net_eq(current->nsproxy->net_ns, read_pnet(&client->msgr.net))) msgr 628 net/ceph/ceph_common.c return &client->msgr.inst.addr; msgr 673 net/ceph/ceph_common.c ceph_messenger_init(&client->msgr, myaddr); msgr 688 net/ceph/ceph_common.c ceph_messenger_fini(&client->msgr); msgr 698 net/ceph/ceph_common.c atomic_set(&client->msgr.stopping, 1); msgr 703 net/ceph/ceph_common.c ceph_messenger_fini(&client->msgr); msgr 716 net/ceph/ceph_common.c ceph_messenger_reset_nonce(&client->msgr); msgr 222 net/ceph/messenger.c static void encode_my_addr(struct ceph_messenger *msgr) msgr 224 net/ceph/messenger.c memcpy(&msgr->my_enc_addr, &msgr->inst.addr, sizeof(msgr->my_enc_addr)); msgr 225 net/ceph/messenger.c ceph_encode_banner_addr(&msgr->my_enc_addr); msgr 370 net/ceph/messenger.c if (atomic_read(&con->msgr->stopping)) { msgr 464 net/ceph/messenger.c ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family, msgr 493 net/ceph/messenger.c if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELAY)) { msgr 727 net/ceph/messenger.c struct ceph_messenger *msgr) msgr 733 net/ceph/messenger.c con->msgr = msgr; msgr 751 net/ceph/messenger.c static u32 get_global_seq(struct ceph_messenger *msgr, u32 gt) msgr 755 net/ceph/messenger.c spin_lock(&msgr->global_seq_lock); msgr 756 net/ceph/messenger.c if (msgr->global_seq < gt) msgr 757 net/ceph/messenger.c msgr->global_seq = gt; msgr 758 net/ceph/messenger.c ret = ++msgr->global_seq; msgr 759 net/ceph/messenger.c spin_unlock(&msgr->global_seq_lock); msgr 1440 net/ceph/messenger.c con_out_kvec_add(con, sizeof (con->msgr->my_enc_addr), msgr 1441 net/ceph/messenger.c &con->msgr->my_enc_addr); msgr 1460 net/ceph/messenger.c unsigned int global_seq = get_global_seq(con->msgr, 0); msgr 1482 net/ceph/messenger.c cpu_to_le64(from_msgr(con->msgr)->supported_features); msgr 1563 net/ceph/messenger.c bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); msgr 2040 net/ceph/messenger.c if (addr_is_blank(&con->msgr->inst.addr)) { msgr 2041 net/ceph/messenger.c int port = addr_port(&con->msgr->inst.addr); msgr 2043 net/ceph/messenger.c memcpy(&con->msgr->inst.addr.in_addr, msgr 2046 net/ceph/messenger.c addr_set_port(&con->msgr->inst.addr, port); msgr 2047 net/ceph/messenger.c encode_my_addr(con->msgr); msgr 2049 net/ceph/messenger.c ceph_pr_addr(&con->msgr->inst.addr)); msgr 2057 net/ceph/messenger.c u64 sup_feat = from_msgr(con->msgr)->supported_features; msgr 2058 net/ceph/messenger.c u64 req_feat = from_msgr(con->msgr)->required_features; msgr 2186 net/ceph/messenger.c get_global_seq(con->msgr, msgr 2323 net/ceph/messenger.c bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); msgr 2372 net/ceph/messenger.c bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); msgr 3034 net/ceph/messenger.c void ceph_messenger_reset_nonce(struct ceph_messenger *msgr) msgr 3036 net/ceph/messenger.c u32 nonce = le32_to_cpu(msgr->inst.addr.nonce) + 1000000; msgr 3037 net/ceph/messenger.c msgr->inst.addr.nonce = cpu_to_le32(nonce); msgr 3038 net/ceph/messenger.c encode_my_addr(msgr); msgr 3044 net/ceph/messenger.c void ceph_messenger_init(struct ceph_messenger *msgr, msgr 3047 net/ceph/messenger.c spin_lock_init(&msgr->global_seq_lock); msgr 3050 net/ceph/messenger.c msgr->inst.addr = *myaddr; msgr 3053 net/ceph/messenger.c msgr->inst.addr.type = 0; msgr 3054 net/ceph/messenger.c get_random_bytes(&msgr->inst.addr.nonce, sizeof(msgr->inst.addr.nonce)); msgr 3055 net/ceph/messenger.c encode_my_addr(msgr); msgr 3057 net/ceph/messenger.c atomic_set(&msgr->stopping, 0); msgr 3058 net/ceph/messenger.c write_pnet(&msgr->net, get_net(current->nsproxy->net_ns)); msgr 3060 net/ceph/messenger.c dout("%s %p\n", __func__, msgr); msgr 3064 net/ceph/messenger.c void ceph_messenger_fini(struct ceph_messenger *msgr) msgr 3066 net/ceph/messenger.c put_net(read_pnet(&msgr->net)); msgr 3097 net/ceph/messenger.c msg->hdr.src = con->msgr->inst.name; msgr 1089 net/ceph/mon_client.c &monc->client->msgr); msgr 1185 net/ceph/mon_client.c monc->client->msgr.inst.name.type = CEPH_ENTITY_TYPE_CLIENT; msgr 1186 net/ceph/mon_client.c monc->client->msgr.inst.name.num = msgr 1240 net/ceph/osd_client.c ceph_con_init(&osd->o_con, osd, &osd_con_ops, &osdc->client->msgr);