Lines Matching refs:con
2223 if (CEPH_HAVE_FEATURE(msg->con->peer_features, RESEND_ON_SPLIT)) { in encode_request_finish()
2226 ceph_encode_64(&p, msg->con->peer_features); in encode_request_finish()
4273 static void osd_fault(struct ceph_connection *con) in osd_fault() argument
4275 struct ceph_osd *osd = con->private; in osd_fault()
5352 static void osd_dispatch(struct ceph_connection *con, struct ceph_msg *msg) in osd_dispatch() argument
5354 struct ceph_osd *osd = con->private; in osd_dispatch()
5403 static struct ceph_msg *get_reply(struct ceph_connection *con, in get_reply() argument
5407 struct ceph_osd *osd = con->private; in get_reply()
5496 static struct ceph_msg *osd_alloc_msg(struct ceph_connection *con, in osd_alloc_msg() argument
5500 struct ceph_osd *osd = con->private; in osd_alloc_msg()
5510 return get_reply(con, hdr, skip); in osd_alloc_msg()
5522 static struct ceph_connection *osd_get_con(struct ceph_connection *con) in osd_get_con() argument
5524 struct ceph_osd *osd = con->private; in osd_get_con()
5526 return con; in osd_get_con()
5530 static void osd_put_con(struct ceph_connection *con) in osd_put_con() argument
5532 struct ceph_osd *osd = con->private; in osd_put_con()
5545 osd_get_authorizer(struct ceph_connection *con, int *proto, int force_new) in osd_get_authorizer() argument
5547 struct ceph_osd *o = con->private; in osd_get_authorizer()
5561 static int osd_add_authorizer_challenge(struct ceph_connection *con, in osd_add_authorizer_challenge() argument
5564 struct ceph_osd *o = con->private; in osd_add_authorizer_challenge()
5572 static int osd_verify_authorizer_reply(struct ceph_connection *con) in osd_verify_authorizer_reply() argument
5574 struct ceph_osd *o = con->private; in osd_verify_authorizer_reply()
5584 static int osd_invalidate_authorizer(struct ceph_connection *con) in osd_invalidate_authorizer() argument
5586 struct ceph_osd *o = con->private; in osd_invalidate_authorizer()
5594 static int osd_get_auth_request(struct ceph_connection *con, in osd_get_auth_request() argument
5598 struct ceph_osd *o = con->private; in osd_get_auth_request()
5613 static int osd_handle_auth_reply_more(struct ceph_connection *con, in osd_handle_auth_reply_more() argument
5618 struct ceph_osd *o = con->private; in osd_handle_auth_reply_more()
5633 static int osd_handle_auth_done(struct ceph_connection *con, in osd_handle_auth_done() argument
5638 struct ceph_osd *o = con->private; in osd_handle_auth_done()
5647 static int osd_handle_auth_bad_method(struct ceph_connection *con, in osd_handle_auth_bad_method() argument
5652 struct ceph_osd *o = con->private; in osd_handle_auth_bad_method()
5678 struct ceph_osd *o = msg->con->private; in osd_sign_message()
5686 struct ceph_osd *o = msg->con->private; in osd_check_message_signature()
5709 static int prep_next_sparse_read(struct ceph_connection *con, in prep_next_sparse_read() argument
5712 struct ceph_osd *o = con->private; in prep_next_sparse_read()
5718 req = lookup_request(&o->o_requests, le64_to_cpu(con->in_msg->hdr.tid)); in prep_next_sparse_read()
5795 static int osd_sparse_read(struct ceph_connection *con, in osd_sparse_read() argument
5799 struct ceph_osd *o = con->private; in osd_sparse_read()
5808 ret = prep_next_sparse_read(con, cursor); in osd_sparse_read()