Cross Reference: /net/ceph/mon

Lines Matching refs:req
391 	struct ceph_mon_generic_request *req;
395 		req = rb_entry(n, struct ceph_mon_generic_request, node);
396 		if (tid < req->tid)
398 		else if (tid > req->tid)
401 			return req;
411 	struct ceph_mon_generic_request *req = NULL;
415 		req = rb_entry(parent, struct ceph_mon_generic_request, node);
416 		if (new->tid < req->tid)
418 		else if (new->tid > req->tid)
430 	struct ceph_mon_generic_request *req =
433 	if (req->reply)
434 		ceph_msg_put(req->reply);
435 	if (req->request)
436 		ceph_msg_put(req->request);
438 	kfree(req);
441 static void put_generic_request(struct ceph_mon_generic_request *req)
443 	kref_put(&req->kref, release_generic_request);
446 static void get_generic_request(struct ceph_mon_generic_request *req)
448 	kref_get(&req->kref);
456 	struct ceph_mon_generic_request *req;
461 	req = __lookup_generic_req(monc, tid);
462 	if (!req) {
467 		dout("get_generic_reply %lld got %p\n", tid, req->reply);
469 		m = ceph_msg_get(req->reply);
481 			      struct ceph_mon_generic_request *req)
487 	req->tid = ++monc->last_tid;
488 	req->request->hdr.tid = cpu_to_le64(req->tid);
489 	__insert_generic_request(monc, req);
491 	ceph_con_send(&monc->con, ceph_msg_get(req->request));
494 	err = wait_for_completion_interruptible(&req->completion);
497 	rb_erase(&req->node, &monc->generic_request_tree);
502 		err = req->result;
512 	struct ceph_mon_generic_request *req;
521 	req = __lookup_generic_req(monc, tid);
522 	if (req) {
523 		*(struct ceph_statfs *)req->buf = reply->st;
524 		req->result = 0;
525 		get_generic_request(req);
528 	if (req) {
529 		complete_all(&req->completion);
530 		put_generic_request(req);
544 	struct ceph_mon_generic_request *req;
548 	req = kzalloc(sizeof(*req), GFP_NOFS);
549 	if (!req)
552 	kref_init(&req->kref);
553 	req->buf = buf;
554 	req->buf_len = sizeof(*buf);
555 	init_completion(&req->completion);
558 	req->request = ceph_msg_new(CEPH_MSG_STATFS, sizeof(*h), GFP_NOFS,
560 	if (!req->request)
562 	req->reply = ceph_msg_new(CEPH_MSG_STATFS_REPLY, 1024, GFP_NOFS,
564 	if (!req->reply)
568 	h = req->request->front.iov_base;
574 	err = do_generic_request(monc, req);
577 	kref_put(&req->kref, release_generic_request);
604 	struct ceph_mon_generic_request *req;
613 	req = __lookup_generic_req(monc, tid);
614 	if (req) {
615 		if (req->buf_len &&
618 				     req->buf, req->buf_len) < 0) {
622 		req->result = le32_to_cpu(reply->reply_code);
623 		get_generic_request(req);
626 	if (req) {
627 		complete(&req->completion);
628 		put_generic_request(req);
644 	struct ceph_mon_generic_request *req;
648 	req = kzalloc(sizeof(*req), GFP_NOFS);
649 	if (!req)
652 	kref_init(&req->kref);
653 	req->buf = buf;
654 	req->buf_len = len;
655 	init_completion(&req->completion);
658 	req->request = ceph_msg_new(CEPH_MSG_POOLOP, sizeof(*h), GFP_NOFS,
660 	if (!req->request)
662 	req->reply = ceph_msg_new(CEPH_MSG_POOLOP_REPLY, 1024, GFP_NOFS,
664 	if (!req->reply)
668 	req->request->hdr.version = cpu_to_le16(2);
669 	h = req->request->front.iov_base;
680 	err = do_generic_request(monc, req);
683 	kref_put(&req->kref, release_generic_request);
709 	struct ceph_mon_generic_request *req;
713 		req = rb_entry(p, struct ceph_mon_generic_request, node);
714 		ceph_msg_revoke(req->request);
715 		ceph_msg_revoke_incoming(req->reply);
716 		ceph_con_send(&monc->con, ceph_msg_get(req->request));