File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed
server/src/main/java/org/elasticsearch/index/engine Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -304,9 +304,15 @@ public InternalEngine(EngineConfig engineConfig) {
304304 // don't allow commits until we are done with recovering
305305 pendingTranslogRecovery .set (true );
306306 for (ReferenceManager .RefreshListener listener : engineConfig .getExternalRefreshListener ()) {
307+ if (listener instanceof EngineAwareRefreshListener engineListener ) {
308+ engineListener .onNewEngine (this );
309+ }
307310 this .externalReaderManager .addListener (listener );
308311 }
309312 for (ReferenceManager .RefreshListener listener : engineConfig .getInternalRefreshListener ()) {
313+ if (listener instanceof EngineAwareRefreshListener engineListener ) {
314+ engineListener .onNewEngine (this );
315+ }
310316 this .internalReaderManager .addListener (listener );
311317 }
312318 this .lastRefreshedCheckpointListener = new LastRefreshedCheckpointListener (localCheckpointTracker .getProcessedCheckpoint ());
You can’t perform that action at this time.
0 commit comments