Fork building snapshot status response off of transport thread (#90651)

This can take O(10s) for tens of thousands of shards, we have to fork it. relates #77466
elastic · Oct 5, 2022 · 0de2cdc · 0de2cdc
1 parent 8f44713
commit 0de2cdc
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 10 deletions.
diff --git a/docs/changelog/90651.yaml b/docs/changelog/90651.yaml
@@ -0,0 +1,5 @@
+pr: 90651
+summary: Fork building snapshot status response off of transport thread
+area: Snapshot/Restore
+type: bug
+issues: []
diff --git a/...g/elasticsearch/action/admin/cluster/snapshots/status/TransportSnapshotsStatusAction.java b/...g/elasticsearch/action/admin/cluster/snapshots/status/TransportSnapshotsStatusAction.java
@@ -13,6 +13,7 @@
 import org.elasticsearch.action.ActionListener;
 import org.elasticsearch.action.StepListener;
 import org.elasticsearch.action.support.ActionFilters;
+import org.elasticsearch.action.support.ThreadedActionListener;
 import org.elasticsearch.action.support.master.TransportMasterNodeAction;
 import org.elasticsearch.client.internal.node.NodeClient;
 import org.elasticsearch.cluster.ClusterState;
@@ -90,7 +91,7 @@ public TransportSnapshotsStatusAction(
             SnapshotsStatusRequest::new,
             indexNameExpressionResolver,
             SnapshotsStatusResponse::new,
-            ThreadPool.Names.SAME
+            ThreadPool.Names.SNAPSHOT_META // building the response is somewhat expensive for large snapshots so we fork
         );
         this.repositoriesService = repositoriesService;
         this.client = client;
@@ -141,16 +142,22 @@ protected void masterOperation(
                 TransportNodesSnapshotsStatus.TYPE,
                 new TransportNodesSnapshotsStatus.Request(nodesIds.toArray(Strings.EMPTY_ARRAY)).snapshots(snapshots)
                     .timeout(request.masterNodeTimeout()),
-                ActionListener.wrap(
-                    nodeSnapshotStatuses -> buildResponse(
-                        snapshotsInProgress,
-                        request,
-                        currentSnapshots,
-                        nodeSnapshotStatuses,
-                        cancellableTask,
-                        listener
+                new ThreadedActionListener<>(
+                    logger,
+                    threadPool,
+                    ThreadPool.Names.SNAPSHOT_META, // fork to snapshot meta since building the response is expensive for large snapshots
+                    ActionListener.wrap(
+                        nodeSnapshotStatuses -> buildResponse(
+                            snapshotsInProgress,
+                            request,
+                            currentSnapshots,
+                            nodeSnapshotStatuses,
+                            cancellableTask,
+                            listener
+                        ),
+                        listener::onFailure
                     ),
-                    listener::onFailure
+                    false
                 )
             );
         } else {