Home
last modified time | relevance | path

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

/net/ceph/
A Dmessenger.c199 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()
633 struct ceph_messenger *msgr) in ceph_con_init() argument
639 con->msgr = msgr; in ceph_con_init()
661 if (msgr->global_seq < gt) in ceph_get_global_seq()
662 msgr->global_seq = gt; in ceph_get_global_seq()
663 ret = ++msgr->global_seq; in ceph_get_global_seq()
1663 ceph_encode_my_addr(msgr); in ceph_messenger_reset_nonce()
1691 ceph_encode_my_addr(msgr); in ceph_messenger_init()
1693 atomic_set(&msgr->stopping, 0); in ceph_messenger_init()
[all …]
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 …]
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()
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()
A Dmessenger_v2.c1476 struct ceph_entity_addr *my_addr = &con->msgr->inst.addr; in prepare_client_ident()
1477 struct ceph_client *client = from_msgr(con->msgr); in prepare_client_ident()
1528 struct ceph_entity_addr *my_addr = &con->msgr->inst.addr; in prepare_session_reconnect()
1869 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_read_data()
1890 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_read_data_cont()
1909 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_read_data_cont()
1936 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_sparse_read_cont()
1960 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_sparse_read_cont()
2008 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_sparse_read_cont()
2505 struct ceph_client *client = from_msgr(con->msgr); in process_server_ident()
[all …]
A Dmon_client.c1211 &monc->client->msgr); in ceph_monc_init()
1301 monc->client->msgr.inst.name.type = CEPH_ENTITY_TYPE_CLIENT; in finish_auth()
1302 monc->client->msgr.inst.name.num = in finish_auth()
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()
A Dosd_client.c1275 ceph_con_init(&osd->o_con, osd, &osd_con_ops, &osdc->client->msgr); in create_osd()

Completed in 34 milliseconds