drbd: debugfs: add callback_history

Add a per-connection worker thread callback_history
with timing details, call site and callback function.

Signed-off-by: Philipp Reisner <philipp.reisner@linbit.com>
Signed-off-by: Lars Ellenberg <lars.ellenberg@linbit.com>

1 files changed, 6 insertions, 0 deletions

diff --git a/drivers/block/drbd/drbd_receiver.c b/drivers/block/drbd/drbd_receiver.c
index 9f6ed240e075..f972988291c5 100644
--- a/drivers/block/drbd/drbd_receiver.c
+++ b/drivers/block/drbd/drbd_receiver.c
@@ -2682,9 +2682,11 @@ static int receive_DataRequest(struct drbd_connection *connection, struct packet
         list_add_tail(&peer_req->w.list, &device->read_ee);
         spin_unlock_irq(&device->resource->req_lock);
 
+        update_receiver_timing_details(connection, drbd_rs_should_slow_down);
         if (device->state.peer != R_PRIMARY
         && drbd_rs_should_slow_down(device, sector, false))
                 schedule_timeout_uninterruptible(HZ/10);
+        update_receiver_timing_details(connection, drbd_rs_begin_io);
         if (drbd_rs_begin_io(device, sector))
                 goto out_free_e;
 
@@ -2692,6 +2694,7 @@ submit_for_resync:
         atomic_add(size >> 9, &device->rs_sect_ev);
 
 submit:
+        update_receiver_timing_details(connection, drbd_submit_peer_request);
         inc_unacked(device);
         if (drbd_submit_peer_request(device, peer_req, READ, fault_type) == 0)
                 return 0;
@@ -4601,6 +4604,7 @@ static void drbdd(struct drbd_connection *connection)
                 struct data_cmd *cmd;
 
                 drbd_thread_current_set_cpu(&connection->receiver);
+                update_receiver_timing_details(connection, drbd_recv_header);
                 if (drbd_recv_header(connection, &pi))
                         goto err_out;
 
@@ -4619,12 +4623,14 @@ static void drbdd(struct drbd_connection *connection)
                 }
 
                 if (shs) {
+                        update_receiver_timing_details(connection, drbd_recv_all_warn);
                         err = drbd_recv_all_warn(connection, pi.data, shs);
                         if (err)
                                 goto err_out;
                         pi.size -= shs;
                 }
 
+                update_receiver_timing_details(connection, cmd->fn);
                 err = cmd->fn(connection, &pi);
                 if (err) {
                         drbd_err(connection, "error receiving %s, e: %d l: %d!\n",