Searched refs:r_tid (Results 1 - 11 of 11) sorted by relevance

/linux-4.1.27/net/ceph/
H A Dosd_client.c817 * 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 Ddebugfs.c155 seq_printf(s, "%lld\tosd%d\t%lld.%x\t", req->r_tid, osdc_show()
/linux-4.1.27/fs/ceph/
H A Ddebugfs.c64 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 Dmds_client.c577 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 Dlocks.c128 req->r_tid); ceph_lock_wait_for_completion()
H A Dmds_client.h183 u64 r_tid; /* transaction id */ member in struct:ceph_mds_request
H A Ddir.c1252 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 Dcaps.c1874 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 Dfile.c535 dout("%s %p tid %llu %ssafe\n", __func__, req, req->r_tid, ceph_sync_write_unsafe()
H A Dinode.c1051 req->r_tid, ceph_mds_op_name(rinfo->head->op)); ceph_fill_trace()
/linux-4.1.27/include/linux/ceph/
H A Dosd_client.h122 u64 r_tid; /* unique for this client */ member in struct:ceph_osd_request

Completed in 176 milliseconds