ceph_x_validate_tickets(ac, &need);
missing = ac->want_keys & ~xi->have_keys;
WARN_ON((need & missing) != missing);
- dout("%s want 0x%x have 0x%x missing 0x%x -> %d\n", __func__,
+ dout("want 0x%x have 0x%x missing 0x%x -> %d\n",
ac->want_keys, xi->have_keys, missing, !missing);
return !missing;
}
int need;
ceph_x_validate_tickets(ac, &need);
- dout("%s want 0x%x have 0x%x need 0x%x -> %d\n", __func__,
+ dout("want 0x%x have 0x%x need 0x%x -> %d\n",
ac->want_keys, xi->have_keys, need, !!need);
return !!need;
}
return ret;
if (le64_to_cpu(hdr->magic) != CEPHX_ENC_MAGIC) {
- pr_err("%s bad magic\n", __func__);
+ pr_err("bad magic\n");
return -EINVAL;
}
return PTR_ERR(th);
ceph_x_validate_tickets(ac, &need);
- dout("%s want 0x%x have 0x%x need 0x%x\n", __func__, ac->want_keys,
+ dout("want 0x%x have 0x%x need 0x%x\n", ac->want_keys,
xi->have_keys, need);
if (need & CEPH_ENTITY_TYPE_AUTH) {
}
static const struct ceph_auth_client_ops ceph_x_ops = {
+ .name = "x",
.is_authenticated = ceph_x_is_authenticated,
.should_authenticate = ceph_x_should_authenticate,
.build_request = ceph_x_build_request,
.add_authorizer_challenge = ceph_x_add_authorizer_challenge,
.verify_authorizer_reply = ceph_x_verify_authorizer_reply,
.invalidate_authorizer = ceph_x_invalidate_authorizer,
- .reset = ceph_x_reset,
+ .reset = ceph_x_reset,
.destroy = ceph_x_destroy,
.sign_message = ceph_x_sign_message,
.check_message_signature = ceph_x_check_message_signature,
};
-
int ceph_x_init(struct ceph_auth_client *ac)
{
struct ceph_x_info *xi;
m->footer.flags |= CEPH_MSG_FOOTER_COMPLETE;
- dout("prepare_write_message_footer %p\n", con);
+ dout("%p msg %p\n", con, m);
con_out_kvec_add(con, sizeof_footer(con), &m->footer);
if (con->peer_features & CEPH_FEATURE_MSG_AUTH) {
if (con->ops->sign_message)
ceph_con_get_out_msg(con);
m = con->out_msg;
- dout("prepare_write_message %p seq %lld type %d len %d+%d+%zd\n",
+ dout("%p seq %lld type %d len %d+%d+%zd\n",
m, con->out_seq, le16_to_cpu(m->hdr.type),
le32_to_cpu(m->hdr.front_len), le32_to_cpu(m->hdr.middle_len),
m->data_length);
con->out_msg->footer.middle_crc = cpu_to_le32(crc);
} else
con->out_msg->footer.middle_crc = 0;
- dout("%s front_crc %u middle_crc %u\n", __func__,
+ dout("front_crc %u middle_crc %u\n",
le32_to_cpu(con->out_msg->footer.front_crc),
le32_to_cpu(con->out_msg->footer.middle_crc));
con->out_msg->footer.flags = 0;
*/
static void prepare_write_ack(struct ceph_connection *con)
{
- dout("prepare_write_ack %p %llu -> %llu\n", con,
+ dout("%p %llu -> %llu\n", con,
con->in_seq_acked, con->in_seq);
con->in_seq_acked = con->in_seq;
*/
static void prepare_write_seq(struct ceph_connection *con)
{
- dout("prepare_write_seq %p %llu -> %llu\n", con,
+ dout("%p %llu -> %llu\n", con,
con->in_seq_acked, con->in_seq);
con->in_seq_acked = con->in_seq;
*/
static void prepare_write_keepalive(struct ceph_connection *con)
{
- dout("prepare_write_keepalive %p\n", con);
+ dout("%p\n", con);
con_out_kvec_reset(con);
if (con->peer_features & CEPH_FEATURE_MSGR_KEEPALIVE2) {
struct timespec64 now;
BUG();
}
- dout("prepare_write_connect %p cseq=%d gseq=%d proto=%d\n", con,
+ dout("%p cseq=%d gseq=%d proto=%d\n", con,
con->v1.connect_seq, global_seq, proto);
con->v1.out_connect.features =
{
int ret;
- dout("write_partial_kvec %p %d left\n", con, con->v1.out_kvec_bytes);
+ dout("%p %d left\n", con, con->v1.out_kvec_bytes);
while (con->v1.out_kvec_bytes > 0) {
ret = ceph_tcp_sendmsg(con->sock, con->v1.out_kvec_cur,
con->v1.out_kvec_left,
con->v1.out_kvec_left = 0;
ret = 1;
out:
- dout("write_partial_kvec %p %d left in %d kvecs ret = %d\n", con,
+ dout("%p %d left in %d kvecs ret = %d\n", con,
con->v1.out_kvec_bytes, con->v1.out_kvec_left, ret);
return ret; /* done! */
}
bool do_datacrc = !ceph_test_opt(from_msgr(con->msgr), NOCRC);
u32 crc;
- dout("%s %p msg %p\n", __func__, con, msg);
+ dout("%p msg %p\n", con, msg);
if (!msg->num_data_items)
return -EINVAL;
ceph_msg_data_advance(cursor, (size_t)ret);
}
- dout("%s %p msg %p done\n", __func__, con, msg);
+ dout("%p msg %p done\n", con, msg);
/* prepare and queue up footer, too */
if (do_datacrc)
{
int ret;
- dout("%s %p %d left\n", __func__, con, con->v1.out_skip);
+ dout("%p %d left\n", con, con->v1.out_skip);
while (con->v1.out_skip > 0) {
size_t size = min(con->v1.out_skip, (int)PAGE_SIZE);
*/
static void prepare_read_banner(struct ceph_connection *con)
{
- dout("prepare_read_banner %p\n", con);
+ dout("%p\n", con);
con->v1.in_base_pos = 0;
}
static void prepare_read_connect(struct ceph_connection *con)
{
- dout("prepare_read_connect %p\n", con);
+ dout("%p\n", con);
con->v1.in_base_pos = 0;
}
static void prepare_read_ack(struct ceph_connection *con)
{
- dout("prepare_read_ack %p\n", con);
+ dout("%p\n", con);
con->v1.in_base_pos = 0;
}
static void prepare_read_seq(struct ceph_connection *con)
{
- dout("prepare_read_seq %p\n", con);
+ dout("%p\n", con);
con->v1.in_base_pos = 0;
con->v1.in_tag = CEPH_MSGR_TAG_SEQ;
}
static void prepare_read_tag(struct ceph_connection *con)
{
- dout("prepare_read_tag %p\n", con);
+ dout("%p\n", con);
con->v1.in_base_pos = 0;
con->v1.in_tag = CEPH_MSGR_TAG_READY;
}
static void prepare_read_keepalive_ack(struct ceph_connection *con)
{
- dout("prepare_read_keepalive_ack %p\n", con);
+ dout("%p\n", con);
con->v1.in_base_pos = 0;
}
*/
static int prepare_read_message(struct ceph_connection *con)
{
- dout("prepare_read_message %p\n", con);
+ dout("%p\n", con);
BUG_ON(con->in_msg != NULL);
con->v1.in_base_pos = 0;
con->in_front_crc = con->in_middle_crc = con->in_data_crc = 0;
u64 seq;
u32 crc;
- dout("read_partial_message con %p msg %p\n", con, m);
+ dout("%p msg %p\n", con, m);
/* header */
size = sizeof(con->v1.in_hdr);
con->v1.out_skip += con_out_kvec_skip(con);
con->v1.out_skip += con_out_kvec_skip(con);
- dout("%s con %p out_kvec_bytes %d out_skip %d\n", __func__, con,
+ dout("con %p out_kvec_bytes %d out_skip %d\n", con,
con->v1.out_kvec_bytes, con->v1.out_skip);
}
con->v1.in_tag = CEPH_MSGR_TAG_READY;
con->in_seq++;
- dout("%s con %p in_base_pos %d\n", __func__, con, con->v1.in_base_pos);
+ dout("con %p in_base_pos %d\n", con, con->v1.in_base_pos);
}
bool ceph_con_v1_opened(struct ceph_connection *con)