diff options
Diffstat (limited to 'drivers/block/drbd/drbd_receiver.c')
-rw-r--r-- | drivers/block/drbd/drbd_receiver.c | 13 |
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); | |||
65 | static int drbd_disconnected(int vnr, void *p, void *data); | 65 | static int drbd_disconnected(int vnr, void *p, void *data); |
66 | 66 | ||
67 | static enum finish_epoch drbd_may_finish_epoch(struct drbd_conf *, struct drbd_epoch *, enum epoch_event); | 67 | static enum finish_epoch drbd_may_finish_epoch(struct drbd_conf *, struct drbd_epoch *, enum epoch_event); |
68 | static int e_end_block(struct drbd_conf *, struct drbd_work *, int); | 68 | static 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 */ |
1450 | static int e_end_resync_block(struct drbd_conf *mdev, struct drbd_work *w, int unused) | 1450 | static 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 | */ |
1587 | static int e_end_block(struct drbd_conf *mdev, struct drbd_work *w, int cancel) | 1588 | static 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 | ||
1624 | static int e_send_discard_ack(struct drbd_conf *mdev, struct drbd_work *w, int unused) | 1626 | static 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); |