Lines Matching refs:th
93 struct ceph_x_ticket_handler *th;
99 th = rb_entry(parent, struct ceph_x_ticket_handler, node);
100 if (service < th->service)
102 else if (service > th->service)
105 return th;
109 th = kzalloc(sizeof(*th), GFP_NOFS);
110 if (!th)
112 th->service = service;
113 rb_link_node(&th->node, parent, p);
114 rb_insert_color(&th->node, &xi->ticket_handlers);
115 return th;
119 struct ceph_x_ticket_handler *th)
123 dout("remove_ticket_handler %p %d\n", th, th->service);
124 rb_erase(&th->node, &xi->ticket_handlers);
125 ceph_crypto_key_destroy(&th->session_key);
126 if (th->ticket_blob)
127 ceph_buffer_put(th->ticket_blob);
128 kfree(th);
161 struct ceph_x_ticket_handler *th;
183 th = get_ticket_handler(ac, type);
184 if (IS_ERR(th)) {
185 ret = PTR_ERR(th);
204 memcpy(&old_key, &th->session_key, sizeof(old_key));
245 ceph_crypto_key_destroy(&th->session_key);
246 if (th->ticket_blob)
247 ceph_buffer_put(th->ticket_blob);
248 th->session_key = new_session_key;
249 th->ticket_blob = new_ticket_blob;
250 th->validity = new_validity;
251 th->secret_id = new_secret_id;
252 th->expires = new_expires;
253 th->renew_after = new_renew_after;
255 type, ceph_entity_type_name(type), th->secret_id,
256 (int)th->ticket_blob->vec.iov_len);
257 xi->have_keys |= th->service;
273 struct ceph_x_ticket_handler *th,
282 (th->ticket_blob ? th->ticket_blob->vec.iov_len : 0);
285 ceph_entity_type_name(th->service), au);
299 au->service = th->service;
304 msg_a->service_id = cpu_to_le32(th->service);
306 msg_a->ticket_blob.secret_id = cpu_to_le64(th->secret_id);
309 memcpy(msg_a->ticket_blob.blob, th->ticket_blob->vec.iov_base,
310 th->ticket_blob->vec.iov_len);
312 dout(" th %p secret_id %lld %lld\n", th, th->secret_id,
322 ret = ceph_x_encrypt(&th->session_key, &msg_b, sizeof(msg_b),
339 static int ceph_x_encode_ticket(struct ceph_x_ticket_handler *th,
344 ceph_encode_64(p, th->secret_id);
345 if (th->ticket_blob) {
346 const char *buf = th->ticket_blob->vec.iov_base;
347 u32 len = th->ticket_blob->vec.iov_len;
369 struct ceph_x_ticket_handler *th;
377 th = get_ticket_handler(ac, service);
379 if (IS_ERR(th)) {
384 if (get_seconds() >= th->renew_after)
386 if (get_seconds() >= th->expires)
399 struct ceph_x_ticket_handler *th =
402 if (IS_ERR(th))
403 return PTR_ERR(th);
441 ret = ceph_x_encode_ticket(th, &p, end);
456 ret = ceph_x_build_authorizer(ac, th, &xi->auth_authorizer);
476 struct ceph_x_ticket_handler *th;
509 th = get_ticket_handler(ac, CEPH_ENTITY_TYPE_AUTH);
510 if (IS_ERR(th))
511 return PTR_ERR(th);
512 ret = ceph_x_proc_ticket_reply(ac, &th->session_key,
533 struct ceph_x_ticket_handler *th;
536 th = get_ticket_handler(ac, peer_type);
537 if (IS_ERR(th))
538 return PTR_ERR(th);
544 ret = ceph_x_build_authorizer(ac, th, au);
562 struct ceph_x_ticket_handler *th;
568 th = get_ticket_handler(ac, au->service);
569 if (IS_ERR(th))
570 return PTR_ERR(th);
571 ret = ceph_x_decrypt(&th->session_key, &p, end, &reply, sizeof(reply));
614 struct ceph_x_ticket_handler *th =
616 remove_ticket_handler(ac, th);
629 struct ceph_x_ticket_handler *th;
631 th = get_ticket_handler(ac, peer_type);
632 if (!IS_ERR(th))
633 remove_ticket_handler(ac, th);