Home
last modified time | relevance | path

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

12

/kernel/linux/linux-5.10/arch/powerpc/sysdev/
H A Dmpic_msgr.c30 static inline void _mpic_msgr_mer_write(struct mpic_msgr *msgr, u32 value) in _mpic_msgr_mer_write() argument
32 out_be32(msgr->mer, value); in _mpic_msgr_mer_write()
35 static inline u32 _mpic_msgr_mer_read(struct mpic_msgr *msgr) in _mpic_msgr_mer_read() argument
37 return in_be32(msgr->mer); in _mpic_msgr_mer_read()
40 static inline void _mpic_msgr_disable(struct mpic_msgr *msgr) in _mpic_msgr_disable() argument
42 u32 mer = _mpic_msgr_mer_read(msgr); in _mpic_msgr_disable()
44 _mpic_msgr_mer_write(msgr, mer & ~(1 << msgr->num)); in _mpic_msgr_disable()
50 struct mpic_msgr *msgr; in mpic_msgr_get() local
53 msgr in mpic_msgr_get()
68 mpic_msgr_put(struct mpic_msgr *msgr) mpic_msgr_put() argument
79 mpic_msgr_enable(struct mpic_msgr *msgr) mpic_msgr_enable() argument
91 mpic_msgr_disable(struct mpic_msgr *msgr) mpic_msgr_disable() argument
218 struct mpic_msgr *msgr; mpic_msgr_probe() local
[all...]
/kernel/linux/linux-6.6/arch/powerpc/sysdev/
H A Dmpic_msgr.c32 static inline void _mpic_msgr_mer_write(struct mpic_msgr *msgr, u32 value) in _mpic_msgr_mer_write() argument
34 out_be32(msgr->mer, value); in _mpic_msgr_mer_write()
37 static inline u32 _mpic_msgr_mer_read(struct mpic_msgr *msgr) in _mpic_msgr_mer_read() argument
39 return in_be32(msgr->mer); in _mpic_msgr_mer_read()
42 static inline void _mpic_msgr_disable(struct mpic_msgr *msgr) in _mpic_msgr_disable() argument
44 u32 mer = _mpic_msgr_mer_read(msgr); in _mpic_msgr_disable()
46 _mpic_msgr_mer_write(msgr, mer & ~(1 << msgr->num)); in _mpic_msgr_disable()
52 struct mpic_msgr *msgr; in mpic_msgr_get() local
55 msgr in mpic_msgr_get()
70 mpic_msgr_put(struct mpic_msgr *msgr) mpic_msgr_put() argument
81 mpic_msgr_enable(struct mpic_msgr *msgr) mpic_msgr_enable() argument
93 mpic_msgr_disable(struct mpic_msgr *msgr) mpic_msgr_disable() argument
227 struct mpic_msgr *msgr; mpic_msgr_probe() local
[all...]
/kernel/linux/linux-5.10/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) in mpic_msgr_write() argument
75 out_be32(msgr->base, message); in mpic_msgr_write()
80 * @msgr
86 mpic_msgr_read(struct mpic_msgr *msgr) mpic_msgr_read() argument
97 mpic_msgr_clear(struct mpic_msgr *msgr) mpic_msgr_clear() argument
110 mpic_msgr_set_destination(struct mpic_msgr *msgr, u32 cpu_num) mpic_msgr_set_destination() argument
124 mpic_msgr_get_irq(struct mpic_msgr *msgr) mpic_msgr_get_irq() argument
[all...]
/kernel/linux/linux-6.6/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) in mpic_msgr_write() argument
75 out_be32(msgr->base, message); in mpic_msgr_write()
80 * @msgr
86 mpic_msgr_read(struct mpic_msgr *msgr) mpic_msgr_read() argument
97 mpic_msgr_clear(struct mpic_msgr *msgr) mpic_msgr_clear() argument
110 mpic_msgr_set_destination(struct mpic_msgr *msgr, u32 cpu_num) mpic_msgr_set_destination() argument
124 mpic_msgr_get_irq(struct mpic_msgr *msgr) mpic_msgr_get_irq() argument
[all...]
/kernel/linux/linux-6.6/net/ceph/
H A Dmessenger.c197 void ceph_encode_my_addr(struct ceph_messenger *msgr) in ceph_encode_my_addr() argument
199 if (!ceph_msgr2(from_msgr(msgr))) { in ceph_encode_my_addr()
200 memcpy(&msgr->my_enc_addr, &msgr->inst.addr, in ceph_encode_my_addr()
201 sizeof(msgr->my_enc_addr)); in ceph_encode_my_addr()
202 ceph_encode_banner_addr(&msgr->my_enc_addr); in ceph_encode_my_addr()
255 ceph_msgr_wq = alloc_workqueue("ceph-msgr", WQ_MEM_RECLAIM, 0); in ceph_msgr_init()
351 if (atomic_read(&con->msgr->stopping)) { in ceph_sock_data_ready()
447 ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family, in ceph_tcp_connect()
475 if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELA in ceph_tcp_connect()
631 ceph_con_init(struct ceph_connection *con, void *private, const struct ceph_connection_operations *ops, struct ceph_messenger *msgr) ceph_con_init() argument
656 ceph_get_global_seq(struct ceph_messenger *msgr, u32 gt) ceph_get_global_seq() argument
1659 ceph_messenger_reset_nonce(struct ceph_messenger *msgr) ceph_messenger_reset_nonce() argument
1669 ceph_messenger_init(struct ceph_messenger *msgr, struct ceph_entity_addr *myaddr) ceph_messenger_init() argument
1699 ceph_messenger_fini(struct ceph_messenger *msgr) ceph_messenger_fini() argument
[all...]
H A Dmessenger_v1.c357 con_out_kvec_add(con, sizeof (con->msgr->my_enc_addr), in prepare_write_banner()
358 &con->msgr->my_enc_addr); in prepare_write_banner()
378 unsigned int global_seq = ceph_get_global_seq(con->msgr, 0); in prepare_write_connect()
400 cpu_to_le64(from_msgr(con->msgr)->supported_features); in prepare_write_connect()
469 bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); in write_partial_message_data()
703 struct ceph_entity_addr *my_addr = &con->msgr->inst.addr; in process_banner()
736 ceph_encode_my_addr(con->msgr); in process_banner()
746 u64 sup_feat = from_msgr(con->msgr)->supported_features; in process_connect()
747 u64 req_feat = from_msgr(con->msgr)->required_features; in process_connect()
873 ceph_get_global_seq(con->msgr, in process_connect()
[all...]
H A Dceph_common.c144 if (!net_eq(current->nsproxy->net_ns, read_pnet(&client->msgr.net))) in ceph_compare_options()
694 return &client->msgr.inst.addr; in ceph_client_addr()
735 /* msgr */ in ceph_create_client()
739 ceph_messenger_init(&client->msgr, myaddr); in ceph_create_client()
754 ceph_messenger_fini(&client->msgr); in ceph_create_client()
764 atomic_set(&client->msgr.stopping, 1); in ceph_destroy_client()
769 ceph_messenger_fini(&client->msgr); in ceph_destroy_client()
782 ceph_messenger_reset_nonce(&client->msgr); in ceph_reset_client_addr()
H A Dmessenger_v2.c1480 struct ceph_entity_addr *my_addr = &con->msgr->inst.addr; in prepare_client_ident()
1481 struct ceph_client *client = from_msgr(con->msgr); in prepare_client_ident()
1532 struct ceph_entity_addr *my_addr = &con->msgr->inst.addr; in prepare_session_reconnect()
1873 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_read_data()
1894 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_read_data_cont()
1913 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_read_data_cont()
1940 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_sparse_read_cont()
1964 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_sparse_read_cont()
2012 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_sparse_read_cont()
2224 struct ceph_entity_addr *my_addr = &con->msgr in process_hello()
[all...]
H A Dauth_x.c1033 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_sign_message()
1052 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_check_message_signature()
H A Dmon_client.c1203 &monc->client->msgr); in ceph_monc_init()
1243 * flush msgr queue before we destroy ourselves to ensure that: in ceph_monc_stop()
1291 monc->client->msgr.inst.name.type = CEPH_ENTITY_TYPE_CLIENT; in finish_auth()
1292 monc->client->msgr.inst.name.num = in finish_auth()
/kernel/linux/linux-5.10/net/ceph/
H A Dmessenger.c222 static void encode_my_addr(struct ceph_messenger *msgr) in encode_my_addr() argument
224 memcpy(&msgr->my_enc_addr, &msgr->inst.addr, sizeof(msgr->my_enc_addr)); in encode_my_addr()
225 ceph_encode_banner_addr(&msgr->my_enc_addr); in encode_my_addr()
277 ceph_msgr_wq = alloc_workqueue("ceph-msgr", WQ_MEM_RECLAIM, 0); in ceph_msgr_init()
370 if (atomic_read(&con->msgr->stopping)) { in ceph_sock_data_ready()
464 ret = sock_create_kern(read_pnet(&con->msgr->net), ss.ss_family, in ceph_tcp_connect()
493 if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELAY)) in ceph_tcp_connect()
720 struct ceph_messenger *msgr) in ceph_con_init()
718 ceph_con_init(struct ceph_connection *con, void *private, const struct ceph_connection_operations *ops, struct ceph_messenger *msgr) ceph_con_init() argument
744 get_global_seq(struct ceph_messenger *msgr, u32 gt) get_global_seq() argument
3030 ceph_messenger_reset_nonce(struct ceph_messenger *msgr) ceph_messenger_reset_nonce() argument
3040 ceph_messenger_init(struct ceph_messenger *msgr, struct ceph_entity_addr *myaddr) ceph_messenger_init() argument
3060 ceph_messenger_fini(struct ceph_messenger *msgr) ceph_messenger_fini() argument
[all...]
H A Dceph_common.c144 if (!net_eq(current->nsproxy->net_ns, read_pnet(&client->msgr.net))) in ceph_compare_options()
658 return &client->msgr.inst.addr; in ceph_client_addr()
699 /* msgr */ in ceph_create_client()
703 ceph_messenger_init(&client->msgr, myaddr); in ceph_create_client()
718 ceph_messenger_fini(&client->msgr); in ceph_create_client()
728 atomic_set(&client->msgr.stopping, 1); in ceph_destroy_client()
733 ceph_messenger_fini(&client->msgr); in ceph_destroy_client()
746 ceph_messenger_reset_nonce(&client->msgr); in ceph_reset_client_addr()
H A Dmon_client.c1136 &monc->client->msgr); in ceph_monc_init()
1178 * flush msgr queue before we destroy ourselves to ensure that: in ceph_monc_stop()
1234 monc->client->msgr.inst.name.type = CEPH_ENTITY_TYPE_CLIENT; in handle_auth_reply()
1235 monc->client->msgr.inst.name.num = in handle_auth_reply()
H A Dauth_x.c876 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_sign_message()
895 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_check_message_signature()
/kernel/linux/linux-5.10/include/linux/ceph/
H A Dmessenger.h259 struct ceph_messenger *msgr; member
338 extern void ceph_messenger_init(struct ceph_messenger *msgr,
340 extern void ceph_messenger_fini(struct ceph_messenger *msgr);
341 extern void ceph_messenger_reset_nonce(struct ceph_messenger *msgr);
345 struct ceph_messenger *msgr);
H A Dlibceph.h139 struct ceph_messenger msgr; /* messenger instance */ member
151 #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>
/kernel/linux/linux-6.6/include/linux/ceph/
H A Dmessenger.h475 struct ceph_messenger *msgr; member
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
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>
/kernel/linux/linux-6.6/fs/ceph/
H A Dsnap.c906 ret = ceph_monc_blocklist_add(&client->monc, &client->msgr.inst.addr); in ceph_update_snap_trace()
909 ceph_pr_addr(&client->msgr.inst.addr), ret); in ceph_update_snap_trace()
912 __func__, ret ? "" : ceph_pr_addr(&client->msgr.inst.addr), in ceph_update_snap_trace()
H A Ddebugfs.c355 struct ceph_entity_inst *inst = &fsc->client->msgr.inst; in status_show()
/kernel/linux/linux-5.10/fs/ceph/
H A Dmds_client.c747 ceph_con_init(&s->s_con, s, &mds_con_ops, &mdsc->fsc->client->msgr); in register_session()

Completed in 37 milliseconds

12