New packet P_ZERO_OUT for zero out device.

Signed-off-by: Nick Wang <nw...@suse.com>
CC: Philipp Reisner <philipp.reis...@linbit.com>
CC: Lars Ellenberg <lars.ellenb...@linbit.com>
CC: drbd-...@lists.linbit.com
CC: linux-kernel@vger.kernel.org

---
 drbd/drbd_protocol.h |  1 +
 drbd/drbd_receiver.c | 34 ++++++++++++++++++++++++++++++++++
 2 files changed, 35 insertions(+)

diff --git a/drbd/drbd_protocol.h b/drbd/drbd_protocol.h
index 405b181..3a82442 100644
--- a/drbd/drbd_protocol.h
+++ b/drbd/drbd_protocol.h
@@ -59,6 +59,7 @@ enum drbd_packet {
        /* REQ_DISCARD. We used "discard" in different contexts before,
         * which is why I chose TRIM here, to disambiguate. */
        P_TRIM                = 0x31,
+       P_ZERO_OUT            = 0x32,
 
        P_MAY_IGNORE          = 0x100, /* Flag to test if (cmd > P_MAY_IGNORE) 
... */
        P_MAX_OPT_CMD         = 0x101,
diff --git a/drbd/drbd_receiver.c b/drbd/drbd_receiver.c
index 47b8fe5..41c958a 100644
--- a/drbd/drbd_receiver.c
+++ b/drbd/drbd_receiver.c
@@ -4404,6 +4404,39 @@ static union drbd_state convert_state(union drbd_state 
ps)
        return ms;
 }
 
+static int receive_zero_out_state(struct drbd_connection *connection, struct 
packet_info *pi)
+{
+       struct drbd_peer_device *peer_device;
+       struct drbd_device *device;
+       struct p_state *p = pi->data;
+       unsigned int isfail;
+
+       peer_device = conn_peer_device(connection, pi->vnr);
+       if (!peer_device)
+               return -EIO;
+       device = peer_device->device;
+
+       isfail = be32_to_cpu(p->state);
+
+       if (isfail) {
+               drbd_info(device, "Failed to zero out peer device\n");
+               set_bit(ZERO_FAIL, &device->flags);
+       } else {
+               drbd_info(device, "Finished zero out peer device\n");
+               if (test_and_clear_bit(ZERO_DONE, &device->flags)) {
+                       spin_lock_irq(&device->resource->req_lock);
+                       _drbd_set_state(_NS2(device, disk, D_UP_TO_DATE,
+                               pdsk, D_UP_TO_DATE), CS_VERBOSE, NULL);
+                       spin_unlock_irq(&device->resource->req_lock);
+               } else {
+                       /* waiting for local device finished */
+                       set_bit(ZERO_DONE, &device->flags);
+               }
+       }
+
+       return 0;
+}
+
 static int receive_req_state(struct drbd_connection *connection, struct 
packet_info *pi)
 {
        struct drbd_peer_device *peer_device;
@@ -5029,6 +5062,7 @@ static struct data_cmd drbd_cmd_handler[] = {
        [P_CONN_ST_CHG_REQ] = { 0, sizeof(struct p_req_state), 
receive_req_conn_state },
        [P_PROTOCOL_UPDATE] = { 1, sizeof(struct p_protocol), receive_protocol 
},
        [P_TRIM]            = { 0, sizeof(struct p_trim), receive_Data },
+       [P_ZERO_OUT]        = { 0, sizeof(struct p_state), 
receive_zero_out_state },
 };
 
 static void drbdd(struct drbd_connection *connection)
-- 
1.8.4.5

--
To unsubscribe from this list: send the line "unsubscribe linux-kernel" in
the body of a message to majord...@vger.kernel.org
More majordomo info at  http://vger.kernel.org/majordomo-info.html
Please read the FAQ at  http://www.tux.org/lkml/

Reply via email to