Skip to content

Commit de66ed3

Browse files
authored
Guard refresh against engine resets (#129253)
Relates ES-11387
1 parent 0df634b commit de66ed3

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

server/src/main/java/org/elasticsearch/index/shard/IndexShard.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1326,12 +1326,15 @@ private Engine.GetResult innerGet(Engine.Get get, boolean translogOnly, Function
13261326
public Engine.RefreshResult refresh(String source) {
13271327
verifyNotClosed();
13281328
logger.trace("refresh with source [{}]", source);
1329-
return getEngine().refresh(source);
1329+
return withEngine(engine -> engine.refresh(source));
13301330
}
13311331

13321332
public void externalRefresh(String source, ActionListener<Engine.RefreshResult> listener) {
13331333
verifyNotClosed();
1334-
getEngine().externalRefresh(source, listener);
1334+
withEngine(engine -> {
1335+
engine.externalRefresh(source, listener);
1336+
return null;
1337+
});
13351338
}
13361339

13371340
/**

0 commit comments

Comments
 (0)