Home
last modified time | relevance | path

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

/linux/net/ceph/
H A Dmessenger.c199 if (!ceph_msgr2(from_msgr(msgr))) { in ceph_encode_my_addr()
476 if (ceph_test_opt(from_msgr(con->msgr), TCP_NODELAY)) in ceph_tcp_connect()
529 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_reset_protocol()
567 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_reset_session()
623 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_opened()
1528 if (!ceph_msgr2(from_msgr(con->msgr)) && con->v1.auth_retry) { in con_fault_finish()
1574 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_workfn()
1587 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_con_workfn()
1720 if (!ceph_msgr2(from_msgr(con->msgr))) in clear_standby()
1796 if (ceph_msgr2(from_msgr(con->msgr))) in ceph_msg_revoke()
[all …]
H A Dmessenger_v1.c396 cpu_to_le64(from_msgr(con->msgr)->supported_features); in prepare_write_connect()
465 bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); in write_partial_message_data()
742 u64 sup_feat = from_msgr(con->msgr)->supported_features; in process_connect()
743 u64 req_feat = from_msgr(con->msgr)->required_features; in process_connect()
994 bool do_bounce = ceph_test_opt(from_msgr(con->msgr), RXBOUNCE); in read_partial_sparse_msg_extent()
1029 bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); in read_partial_sparse_msg_data()
1066 bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); in read_partial_msg_data()
1150 bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC); in read_partial_message()
1255 else if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) in read_partial_message()
H A Dmessenger_v2.c1450 struct ceph_client *client = from_msgr(con->msgr); in prepare_client_ident()
1842 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_read_data()
1863 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_read_data_cont()
1882 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_sparse_read_cont()
1933 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_sparse_read_cont()
1981 if (ceph_test_opt(from_msgr(con->msgr), RXBOUNCE)) { in prepare_sparse_read_cont()
2478 struct ceph_client *client = from_msgr(con->msgr); in process_server_ident()
2562 struct ceph_client *client = from_msgr(con->msgr); in process_ident_missing_features()
H A Dauth_x.c1117 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_sign_message()
1136 if (ceph_test_opt(from_msgr(msg->con->msgr), NOMSGSIGN)) in ceph_x_check_message_signature()
/linux/include/linux/ceph/
H A Dlibceph.h144 #define from_msgr(ms) container_of(ms, struct ceph_client, msgr) macro