Lines Matching refs:tid

432 	struct ceph_mon_client *monc, u64 tid)  in __lookup_generic_req()  argument
439 if (tid < req->tid) in __lookup_generic_req()
441 else if (tid > req->tid) in __lookup_generic_req()
459 if (new->tid < req->tid) in __insert_generic_request()
461 else if (new->tid > req->tid) in __insert_generic_request()
500 u64 tid = le64_to_cpu(hdr->tid); in get_generic_reply() local
504 req = __lookup_generic_req(monc, tid); in get_generic_reply()
506 dout("get_generic_reply %lld dne\n", tid); in get_generic_reply()
510 dout("get_generic_reply %lld got %p\n", tid, req->reply); in get_generic_reply()
523 static int __do_generic_request(struct ceph_mon_client *monc, u64 tid, in __do_generic_request() argument
529 req->tid = tid != 0 ? tid : ++monc->last_tid; in __do_generic_request()
530 req->request->hdr.tid = cpu_to_le64(req->tid); in __do_generic_request()
567 u64 tid = le64_to_cpu(msg->hdr.tid); in handle_statfs_reply() local
571 dout("handle_statfs_reply %p tid %llu\n", msg, tid); in handle_statfs_reply()
574 req = __lookup_generic_req(monc, tid); in handle_statfs_reply()
588 pr_err("corrupt statfs reply, tid %llu\n", tid); in handle_statfs_reply()
638 u64 tid = le64_to_cpu(msg->hdr.tid); in handle_get_version_reply() local
643 dout("%s %p tid %llu\n", __func__, msg, tid); in handle_get_version_reply()
647 if (tid != 0 && tid != handle) in handle_get_version_reply()
665 pr_err("corrupt mon_get_version reply, tid %llu\n", tid); in handle_get_version_reply()
679 u64 tid; in ceph_monc_do_get_version() local
710 tid = ++monc->last_tid; in ceph_monc_do_get_version()
711 ceph_encode_64(&p, tid); /* handle */ in ceph_monc_do_get_version()
714 err = __do_generic_request(monc, tid, req); in ceph_monc_do_get_version()
1063 if (le64_to_cpu(hdr->tid) != 0) in mon_alloc_msg()