Home
last modified time | relevance | path

Searched refs:msgr (Results 1 – 5 of 5) sorted by relevance

/net/ceph/
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()
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()
727 struct ceph_messenger *msgr) in ceph_con_init() argument
733 con->msgr = msgr; in ceph_con_init()
751 static u32 get_global_seq(struct ceph_messenger *msgr, u32 gt) in get_global_seq() argument
755 spin_lock(&msgr->global_seq_lock); in get_global_seq()
[all …]
Dceph_common.c144 if (!net_eq(current->nsproxy->net_ns, read_pnet(&client->msgr.net))) in ceph_compare_options()
628 return &client->msgr.inst.addr; in ceph_client_addr()
673 ceph_messenger_init(&client->msgr, myaddr); in ceph_create_client()
688 ceph_messenger_fini(&client->msgr); in ceph_create_client()
698 atomic_set(&client->msgr.stopping, 1); in ceph_destroy_client()
703 ceph_messenger_fini(&client->msgr); in ceph_destroy_client()
716 ceph_messenger_reset_nonce(&client->msgr); in ceph_reset_client_addr()
Dmon_client.c1089 &monc->client->msgr); in ceph_monc_init()
1185 monc->client->msgr.inst.name.type = CEPH_ENTITY_TYPE_CLIENT; in handle_auth_reply()
1186 monc->client->msgr.inst.name.num = in handle_auth_reply()
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()
Dosd_client.c1241 ceph_con_init(&osd->o_con, osd, &osd_con_ops, &osdc->client->msgr); in create_osd()