Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 189208
b: refs/heads/master
c: 3dd72fc
h: refs/heads/master
v: v3
  • Loading branch information
Sage Weil committed Mar 23, 2010
1 parent 128de61 commit ee79209
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 8 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 3c3f2e32effd4c6acc3a9434bd7eecb0af653d89
refs/heads/master: 3dd72fc0e6dc49c79fa9e7cd7c654deac7ccaa29
12 changes: 6 additions & 6 deletions trunk/fs/ceph/osd_client.c
Original file line number Diff line number Diff line change
Expand Up @@ -633,7 +633,7 @@ static int __send_request(struct ceph_osd_client *osdc,
reqhead->flags |= cpu_to_le32(req->r_flags); /* e.g., RETRY */
reqhead->reassert_version = req->r_reassert_version;

req->r_sent_stamp = jiffies;
req->r_stamp = jiffies;
list_move_tail(&osdc->req_lru, &req->r_req_lru_item);

ceph_msg_get(req->r_request); /* send consumes a ref */
Expand All @@ -660,7 +660,7 @@ static void handle_timeout(struct work_struct *work)
unsigned long timeout = osdc->client->mount_args->osd_timeout * HZ;
unsigned long keepalive =
osdc->client->mount_args->osd_keepalive_timeout * HZ;
unsigned long last_sent = 0;
unsigned long last_stamp = 0;
struct rb_node *p;
struct list_head slow_osds;

Expand Down Expand Up @@ -697,12 +697,12 @@ static void handle_timeout(struct work_struct *work)
req = list_entry(osdc->req_lru.next, struct ceph_osd_request,
r_req_lru_item);

if (time_before(jiffies, req->r_sent_stamp + timeout))
if (time_before(jiffies, req->r_stamp + timeout))
break;

BUG_ON(req == last_req && req->r_sent_stamp == last_sent);
BUG_ON(req == last_req && req->r_stamp == last_stamp);
last_req = req;
last_sent = req->r_sent_stamp;
last_stamp = req->r_stamp;

osd = req->r_osd;
BUG_ON(!osd);
Expand All @@ -718,7 +718,7 @@ static void handle_timeout(struct work_struct *work)
*/
INIT_LIST_HEAD(&slow_osds);
list_for_each_entry(req, &osdc->req_lru, r_req_lru_item) {
if (time_before(jiffies, req->r_sent_stamp + keepalive))
if (time_before(jiffies, req->r_stamp + keepalive))
break;

osd = req->r_osd;
Expand Down
2 changes: 1 addition & 1 deletion trunk/fs/ceph/osd_client.h
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ struct ceph_osd_request {

char r_oid[40]; /* object name */
int r_oid_len;
unsigned long r_sent_stamp;
unsigned long r_stamp; /* send OR check time */
bool r_resend; /* msg send failed, needs retry */

struct ceph_file_layout r_file_layout;
Expand Down

0 comments on commit ee79209

Please sign in to comment.