Skip to content

Commit d877eb8

Browse files
committed
Guard refresh against engine resets
1 parent a859f37 commit d877eb8

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
@@ -1323,12 +1323,15 @@ private Engine.GetResult innerGet(Engine.Get get, boolean translogOnly, Function
13231323
public Engine.RefreshResult refresh(String source) {
13241324
verifyNotClosed();
13251325
logger.trace("refresh with source [{}]", source);
1326-
return getEngine().refresh(source);
1326+
return withEngine(engine -> engine.refresh(source));
13271327
}
13281328

13291329
public void externalRefresh(String source, ActionListener<Engine.RefreshResult> listener) {
13301330
verifyNotClosed();
1331-
getEngine().externalRefresh(source, listener);
1331+
withEngine(engine -> {
1332+
engine.externalRefresh(source, listener);
1333+
return null;
1334+
});
13321335
}
13331336

13341337
/**

0 commit comments

Comments
 (0)