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);