aboutsummaryrefslogtreecommitdiffstats
path: root/fs/ceph
diff options
context:
space:
mode:
Diffstat (limited to 'fs/ceph')
-rw-r--r--fs/ceph/osd_client.c12
-rw-r--r--fs/ceph/osd_client.h2
2 files changed, 7 insertions, 7 deletions
diff --git a/fs/ceph/osd_client.c b/fs/ceph/osd_client.c
index 221038253e61..04359217ea6c 100644
--- a/fs/ceph/osd_client.c
+++ b/fs/ceph/osd_client.c
@@ -633,7 +633,7 @@ static int __send_request(struct ceph_osd_client *osdc,
633 reqhead->flags |= cpu_to_le32(req->r_flags); /* e.g., RETRY */ 633 reqhead->flags |= cpu_to_le32(req->r_flags); /* e.g., RETRY */
634 reqhead->reassert_version = req->r_reassert_version; 634 reqhead->reassert_version = req->r_reassert_version;
635 635
636 req->r_sent_stamp = jiffies; 636 req->r_stamp = jiffies;
637 list_move_tail(&osdc->req_lru, &req->r_req_lru_item); 637 list_move_tail(&osdc->req_lru, &req->r_req_lru_item);
638 638
639 ceph_msg_get(req->r_request); /* send consumes a ref */ 639 ceph_msg_get(req->r_request); /* send consumes a ref */
@@ -660,7 +660,7 @@ static void handle_timeout(struct work_struct *work)
660 unsigned long timeout = osdc->client->mount_args->osd_timeout * HZ; 660 unsigned long timeout = osdc->client->mount_args->osd_timeout * HZ;
661 unsigned long keepalive = 661 unsigned long keepalive =
662 osdc->client->mount_args->osd_keepalive_timeout * HZ; 662 osdc->client->mount_args->osd_keepalive_timeout * HZ;
663 unsigned long last_sent = 0; 663 unsigned long last_stamp = 0;
664 struct rb_node *p; 664 struct rb_node *p;
665 struct list_head slow_osds; 665 struct list_head slow_osds;
666 666
@@ -697,12 +697,12 @@ static void handle_timeout(struct work_struct *work)
697 req = list_entry(osdc->req_lru.next, struct ceph_osd_request, 697 req = list_entry(osdc->req_lru.next, struct ceph_osd_request,
698 r_req_lru_item); 698 r_req_lru_item);
699 699
700 if (time_before(jiffies, req->r_sent_stamp + timeout)) 700 if (time_before(jiffies, req->r_stamp + timeout))
701 break; 701 break;
702 702
703 BUG_ON(req == last_req && req->r_sent_stamp == last_sent); 703 BUG_ON(req == last_req && req->r_stamp == last_stamp);
704 last_req = req; 704 last_req = req;
705 last_sent = req->r_sent_stamp; 705 last_stamp = req->r_stamp;
706 706
707 osd = req->r_osd; 707 osd = req->r_osd;
708 BUG_ON(!osd); 708 BUG_ON(!osd);
@@ -718,7 +718,7 @@ static void handle_timeout(struct work_struct *work)
718 */ 718 */
719 INIT_LIST_HEAD(&slow_osds); 719 INIT_LIST_HEAD(&slow_osds);
720 list_for_each_entry(req, &osdc->req_lru, r_req_lru_item) { 720 list_for_each_entry(req, &osdc->req_lru, r_req_lru_item) {
721 if (time_before(jiffies, req->r_sent_stamp + keepalive)) 721 if (time_before(jiffies, req->r_stamp + keepalive))
722 break; 722 break;
723 723
724 osd = req->r_osd; 724 osd = req->r_osd;
diff --git a/fs/ceph/osd_client.h b/fs/ceph/osd_client.h
index 1b1a3ca43afc..b0759911e7c3 100644
--- a/fs/ceph/osd_client.h
+++ b/fs/ceph/osd_client.h
@@ -70,7 +70,7 @@ struct ceph_osd_request {
70 70
71 char r_oid[40]; /* object name */ 71 char r_oid[40]; /* object name */
72 int r_oid_len; 72 int r_oid_len;
73 unsigned long r_sent_stamp; 73 unsigned long r_stamp; /* send OR check time */
74 bool r_resend; /* msg send failed, needs retry */ 74 bool r_resend; /* msg send failed, needs retry */
75 75
76 struct ceph_file_layout r_file_layout; 76 struct ceph_file_layout r_file_layout;