/linux-4.1.27/net/ceph/ |
H A D | osd_client.c | 817 * We keep osd requests in an rbtree, sorted by ->r_tid. 829 if (new->r_tid < req->r_tid) __insert_request() 831 else if (new->r_tid > req->r_tid) __insert_request() 849 if (tid < req->r_tid) __lookup_request() 851 else if (tid > req->r_tid) __lookup_request() 868 if (tid < req->r_tid) { __lookup_request_ge() 872 } else if (tid > req->r_tid) { __lookup_request_ge() 908 dout("%s requeueing %p tid %llu\n", __func__, req, req->r_tid); __kick_linger_request() 951 req->r_tid); __kick_osd_requests() 1217 req->r_tid = ++osdc->last_tid; __register_request() 1218 req->r_request->hdr.tid = cpu_to_le64(req->r_tid); __register_request() 1219 dout("__register_request %p tid %lld\n", req, req->r_tid); __register_request() 1237 req, req->r_tid); __unregister_request() 1241 dout("__unregister_request %p tid %lld\n", req, req->r_tid); __unregister_request() 1279 dout("%s %p tid %llu\n", __func__, req, req->r_tid); __register_linger_request() 1296 req->r_tid); __unregister_linger_request() 1300 dout("%s %p tid %llu\n", __func__, req, req->r_tid); __unregister_linger_request() 1381 dout("%s %p tid %llu to osd%d\n", __func__, req, req->r_tid, __enqueue_request() 1412 dout("map_request %p tid %lld\n", req, req->r_tid); __map_request() 1440 req->r_tid, pgid.pool, pgid.seed, o, __map_request() 1487 req, req->r_tid, req->r_osd->o_osd, req->r_flags, __send_request() 1539 " will retry %lld\n", req->r_tid); __ceph_osdc_start_request() 1595 req->r_tid, osd->o_osd); handle_timeout() 1983 req, req->r_tid, kick_requests() 1999 dout("%p tid %llu maps to no osd\n", req, req->r_tid); kick_requests() 2004 req->r_tid, kick_requests() 2023 req, req->r_tid); kick_requests() 2037 req->r_tid, req->r_osd ? req->r_osd->o_osd : -1); kick_requests() 2519 dout("%s %p tid %llu canceled\n", __func__, req, req->r_tid); ceph_osdc_cancel_request() 2531 dout("%s %p tid %llu\n", __func__, req, req->r_tid); ceph_osdc_wait_request() 2535 dout("%s %p tid %llu interrupted\n", __func__, req, req->r_tid); ceph_osdc_wait_request() 2541 dout("%s %p tid %llu result %d\n", __func__, req, req->r_tid, ceph_osdc_wait_request() 2561 if (req->r_tid > last_tid) ceph_osdc_sync() 2564 next_tid = req->r_tid + 1; ceph_osdc_sync() 2571 req->r_tid, last_tid); ceph_osdc_sync()
|
H A D | debugfs.c | 155 seq_printf(s, "%lld\tosd%d\t%lld.%x\t", req->r_tid, osdc_show()
|
/linux-4.1.27/fs/ceph/ |
H A D | debugfs.c | 64 seq_printf(s, "%lld\tmds%d\t", req->r_tid, mdsc_show() 67 seq_printf(s, "%lld\t(no request)\t", req->r_tid); mdsc_show() 69 seq_printf(s, "%lld\t(no session)\t", req->r_tid); mdsc_show()
|
H A D | mds_client.c | 577 if (tid < req->r_tid) __lookup_request() 579 else if (tid > req->r_tid) __lookup_request() 599 if (new->r_tid < req->r_tid) __insert_request() 601 else if (new->r_tid > req->r_tid) __insert_request() 621 req->r_tid = ++mdsc->last_tid; __register_request() 625 dout("__register_request %p tid %lld\n", req, req->r_tid); __register_request() 646 dout("__unregister_request %p tid %lld\n", req, req->r_tid); __unregister_request() 1036 pr_info(" dropping unsafe request %llu\n", req->r_tid); cleanup_session_requests() 1705 return req->r_tid; __get_oldest_tid() 1926 msg->hdr.tid = cpu_to_le64(req->r_tid); create_request_message() 2035 req->r_tid, ceph_mds_op_name(req->r_op), req->r_attempts); __prepare_send_request() 2193 dout(" wake request %p tid %llu\n", req, req->r_tid); __wake_requests() 2217 dout(" kicking tid %llu\n", req->r_tid); kick_requests() 2287 dout("aborted request %lld with %d\n", req->r_tid, err); ceph_mdsc_do_request() 2398 dout("got ESTALE on request %llu", req->r_tid); handle_reply() 2415 dout("have to return ESTALE on request %llu", req->r_tid); handle_reply() 3441 req->r_tid); wait_requests() 3481 while (req && req->r_tid <= want_tid) { wait_unsafe_requests() 3495 req->r_tid, want_tid); wait_unsafe_requests()
|
H A D | locks.c | 128 req->r_tid); ceph_lock_wait_for_completion()
|
H A D | mds_client.h | 183 u64 r_tid; /* transaction id */ member in struct:ceph_mds_request
|
H A D | dir.c | 1252 last_tid = req->r_tid; ceph_dir_fsync() 1259 inode, req->r_tid, last_tid); ceph_dir_fsync() 1278 } while (req->r_tid < last_tid); ceph_dir_fsync()
|
H A D | caps.c | 1874 last_tid = req->r_tid; sync_write_wait() 1880 req->r_tid, last_tid); sync_write_wait() 1893 } while (req->r_tid < last_tid); sync_write_wait()
|
H A D | file.c | 535 dout("%s %p tid %llu %ssafe\n", __func__, req, req->r_tid, ceph_sync_write_unsafe()
|
H A D | inode.c | 1051 req->r_tid, ceph_mds_op_name(rinfo->head->op)); ceph_fill_trace()
|
/linux-4.1.27/include/linux/ceph/ |
H A D | osd_client.h | 122 u64 r_tid; /* unique for this client */ member in struct:ceph_osd_request
|