Lines Matching refs:tid

416 	struct ceph_mon_client *monc, u64 tid)  in __lookup_generic_req()  argument
423 if (tid < req->tid) in __lookup_generic_req()
425 else if (tid > req->tid) in __lookup_generic_req()
443 if (new->tid < req->tid) in __insert_generic_request()
445 else if (new->tid > req->tid) in __insert_generic_request()
484 u64 tid = le64_to_cpu(hdr->tid); in get_generic_reply() local
488 req = __lookup_generic_req(monc, tid); in get_generic_reply()
490 dout("get_generic_reply %lld dne\n", tid); in get_generic_reply()
494 dout("get_generic_reply %lld got %p\n", tid, req->reply); in get_generic_reply()
507 static int __do_generic_request(struct ceph_mon_client *monc, u64 tid, in __do_generic_request() argument
513 req->tid = tid != 0 ? tid : ++monc->last_tid; in __do_generic_request()
514 req->request->hdr.tid = cpu_to_le64(req->tid); in __do_generic_request()
551 u64 tid = le64_to_cpu(msg->hdr.tid); in handle_statfs_reply() local
555 dout("handle_statfs_reply %p tid %llu\n", msg, tid); in handle_statfs_reply()
558 req = __lookup_generic_req(monc, tid); in handle_statfs_reply()
572 pr_err("corrupt statfs reply, tid %llu\n", tid); in handle_statfs_reply()
622 u64 tid = le64_to_cpu(msg->hdr.tid); in handle_get_version_reply() local
627 dout("%s %p tid %llu\n", __func__, msg, tid); in handle_get_version_reply()
631 if (tid != 0 && tid != handle) in handle_get_version_reply()
649 pr_err("corrupt mon_get_version reply, tid %llu\n", tid); in handle_get_version_reply()
663 u64 tid; in ceph_monc_do_get_version() local
694 tid = ++monc->last_tid; in ceph_monc_do_get_version()
695 ceph_encode_64(&p, tid); /* handle */ in ceph_monc_do_get_version()
698 err = __do_generic_request(monc, tid, req); in ceph_monc_do_get_version()
1035 if (le64_to_cpu(hdr->tid) != 0) in mon_alloc_msg()