aboutsummaryrefslogtreecommitdiffstats
path: root/drivers/block/drbd/drbd_receiver.c
diff options
context:
space:
mode:
Diffstat (limited to 'drivers/block/drbd/drbd_receiver.c')
-rw-r--r--drivers/block/drbd/drbd_receiver.c13
1 files changed, 8 insertions, 5 deletions
diff --git a/drivers/block/drbd/drbd_receiver.c b/drivers/block/drbd/drbd_receiver.c
index f21b0efff6d8..02fa1b25dce5 100644
--- a/drivers/block/drbd/drbd_receiver.c
+++ b/drivers/block/drbd/drbd_receiver.c
@@ -65,7 +65,7 @@ static int drbd_do_auth(struct drbd_tconn *tconn);
65static int drbd_disconnected(int vnr, void *p, void *data); 65static int drbd_disconnected(int vnr, void *p, void *data);
66 66
67static enum finish_epoch drbd_may_finish_epoch(struct drbd_conf *, struct drbd_epoch *, enum epoch_event); 67static enum finish_epoch drbd_may_finish_epoch(struct drbd_conf *, struct drbd_epoch *, enum epoch_event);
68static int e_end_block(struct drbd_conf *, struct drbd_work *, int); 68static int e_end_block(struct drbd_work *, int);
69 69
70 70
71#define GFP_TRY (__GFP_HIGHMEM | __GFP_NOWARN) 71#define GFP_TRY (__GFP_HIGHMEM | __GFP_NOWARN)
@@ -420,7 +420,7 @@ static int drbd_process_done_ee(struct drbd_conf *mdev)
420 */ 420 */
421 list_for_each_entry_safe(peer_req, t, &work_list, w.list) { 421 list_for_each_entry_safe(peer_req, t, &work_list, w.list) {
422 /* list_del not necessary, next/prev members not touched */ 422 /* list_del not necessary, next/prev members not touched */
423 ok = peer_req->w.cb(mdev, &peer_req->w, !ok) && ok; 423 ok = peer_req->w.cb(&peer_req->w, !ok) && ok;
424 drbd_free_ee(mdev, peer_req); 424 drbd_free_ee(mdev, peer_req);
425 } 425 }
426 wake_up(&mdev->ee_wait); 426 wake_up(&mdev->ee_wait);
@@ -1447,9 +1447,10 @@ static int recv_dless_read(struct drbd_conf *mdev, struct drbd_request *req,
1447 1447
1448/* e_end_resync_block() is called via 1448/* e_end_resync_block() is called via
1449 * drbd_process_done_ee() by asender only */ 1449 * drbd_process_done_ee() by asender only */
1450static int e_end_resync_block(struct drbd_conf *mdev, struct drbd_work *w, int unused) 1450static int e_end_resync_block(struct drbd_work *w, int unused)
1451{ 1451{
1452 struct drbd_peer_request *peer_req = (struct drbd_peer_request *)w; 1452 struct drbd_peer_request *peer_req = (struct drbd_peer_request *)w;
1453 struct drbd_conf *mdev = w->mdev;
1453 sector_t sector = peer_req->i.sector; 1454 sector_t sector = peer_req->i.sector;
1454 int ok; 1455 int ok;
1455 1456
@@ -1584,9 +1585,10 @@ static int receive_RSDataReply(struct drbd_conf *mdev, enum drbd_packet cmd,
1584/* e_end_block() is called via drbd_process_done_ee(). 1585/* e_end_block() is called via drbd_process_done_ee().
1585 * this means this function only runs in the asender thread 1586 * this means this function only runs in the asender thread
1586 */ 1587 */
1587static int e_end_block(struct drbd_conf *mdev, struct drbd_work *w, int cancel) 1588static int e_end_block(struct drbd_work *w, int cancel)
1588{ 1589{
1589 struct drbd_peer_request *peer_req = (struct drbd_peer_request *)w; 1590 struct drbd_peer_request *peer_req = (struct drbd_peer_request *)w;
1591 struct drbd_conf *mdev = w->mdev;
1590 sector_t sector = peer_req->i.sector; 1592 sector_t sector = peer_req->i.sector;
1591 int ok = 1, pcmd; 1593 int ok = 1, pcmd;
1592 1594
@@ -1621,9 +1623,10 @@ static int e_end_block(struct drbd_conf *mdev, struct drbd_work *w, int cancel)
1621 return ok; 1623 return ok;
1622} 1624}
1623 1625
1624static int e_send_discard_ack(struct drbd_conf *mdev, struct drbd_work *w, int unused) 1626static int e_send_discard_ack(struct drbd_work *w, int unused)
1625{ 1627{
1626 struct drbd_peer_request *peer_req = (struct drbd_peer_request *)w; 1628 struct drbd_peer_request *peer_req = (struct drbd_peer_request *)w;
1629 struct drbd_conf *mdev = w->mdev;
1627 int ok = 1; 1630 int ok = 1;
1628 1631
1629 D_ASSERT(mdev->tconn->net_conf->wire_protocol == DRBD_PROT_C); 1632 D_ASSERT(mdev->tconn->net_conf->wire_protocol == DRBD_PROT_C);