diff options
Diffstat (limited to 'fs/ceph')
-rw-r--r-- | fs/ceph/osd_client.c | 12 | ||||
-rw-r--r-- | fs/ceph/osd_client.h | 2 |
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; |