Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 345815
b: refs/heads/master
c: fbe29de
h: refs/heads/master
i:
  345813: 9cd66a9
  345811: 1055017
  345807: cd2f17a
v: v3
  • Loading branch information
Andreas Gruenbacher authored and Philipp Reisner committed Oct 14, 2011
1 parent 912cfa3 commit 0fc23e9
Show file tree
Hide file tree
Showing 4 changed files with 12 additions and 10 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: df24aa45f4df43e8881c0f80d6a4e2653df7af05
refs/heads/master: fbe29dec98622369c106ba72279500fb2f5aba99
5 changes: 3 additions & 2 deletions trunk/drivers/block/drbd/drbd_int.h
Original file line number Diff line number Diff line change
Expand Up @@ -1532,8 +1532,9 @@ extern void start_resync_timer_fn(unsigned long data);

/* drbd_receiver.c */
extern int drbd_rs_should_slow_down(struct drbd_conf *mdev, sector_t sector);
extern int drbd_submit_ee(struct drbd_conf *, struct drbd_peer_request *,
const unsigned, const int);
extern int drbd_submit_peer_request(struct drbd_conf *,
struct drbd_peer_request *, const unsigned,
const int);
extern int drbd_release_ee(struct drbd_conf *mdev, struct list_head *list);
extern struct drbd_peer_request *drbd_alloc_ee(struct drbd_conf *,
u64, sector_t, unsigned int,
Expand Down
13 changes: 7 additions & 6 deletions trunk/drivers/block/drbd/drbd_receiver.c
Original file line number Diff line number Diff line change
Expand Up @@ -1092,7 +1092,7 @@ void drbd_bump_write_ordering(struct drbd_conf *mdev, enum write_ordering_e wo)
}

/**
* drbd_submit_ee()
* drbd_submit_peer_request()
* @mdev: DRBD device.
* @peer_req: peer request
* @rw: flag field, see bio->bi_rw
Expand All @@ -1108,8 +1108,9 @@ void drbd_bump_write_ordering(struct drbd_conf *mdev, enum write_ordering_e wo)
* on certain Xen deployments.
*/
/* TODO allocate from our own bio_set. */
int drbd_submit_ee(struct drbd_conf *mdev, struct drbd_peer_request *peer_req,
const unsigned rw, const int fault_type)
int drbd_submit_peer_request(struct drbd_conf *mdev,
struct drbd_peer_request *peer_req,
const unsigned rw, const int fault_type)
{
struct bio *bios = NULL;
struct bio *bio;
Expand Down Expand Up @@ -1496,7 +1497,7 @@ static int recv_resync_read(struct drbd_conf *mdev, sector_t sector, int data_si
spin_unlock_irq(&mdev->tconn->req_lock);

atomic_add(data_size >> 9, &mdev->rs_sect_ev);
if (drbd_submit_ee(mdev, peer_req, WRITE, DRBD_FAULT_RS_WR) == 0)
if (drbd_submit_peer_request(mdev, peer_req, WRITE, DRBD_FAULT_RS_WR) == 0)
return true;

/* don't care for the reason here */
Expand Down Expand Up @@ -1936,7 +1937,7 @@ static int receive_Data(struct drbd_conf *mdev, enum drbd_packet cmd,
drbd_al_begin_io(mdev, peer_req->i.sector);
}

if (drbd_submit_ee(mdev, peer_req, rw, DRBD_FAULT_DT_WR) == 0)
if (drbd_submit_peer_request(mdev, peer_req, rw, DRBD_FAULT_DT_WR) == 0)
return true;

/* don't care for the reason here */
Expand Down Expand Up @@ -2193,7 +2194,7 @@ static int receive_DataRequest(struct drbd_conf *mdev, enum drbd_packet cmd,
list_add_tail(&peer_req->w.list, &mdev->read_ee);
spin_unlock_irq(&mdev->tconn->req_lock);

if (drbd_submit_ee(mdev, peer_req, READ, fault_type) == 0)
if (drbd_submit_peer_request(mdev, peer_req, READ, fault_type) == 0)
return true;

/* don't care for the reason here */
Expand Down
2 changes: 1 addition & 1 deletion trunk/drivers/block/drbd/drbd_worker.c
Original file line number Diff line number Diff line change
Expand Up @@ -365,7 +365,7 @@ static int read_for_csum(struct drbd_conf *mdev, sector_t sector, int size)
spin_unlock_irq(&mdev->tconn->req_lock);

atomic_add(size >> 9, &mdev->rs_sect_ev);
if (drbd_submit_ee(mdev, peer_req, READ, DRBD_FAULT_RS_RD) == 0)
if (drbd_submit_peer_request(mdev, peer_req, READ, DRBD_FAULT_RS_RD) == 0)
return 0;

/* If it failed because of ENOMEM, retry should help. If it failed
Expand Down

0 comments on commit 0fc23e9

Please sign in to comment.