assert IOE

tlrx · tlrx · commit c20bf75e9f58 · 2020-11-17T13:21:12.000+01:00
diff --git a/x-pack/plugin/searchable-snapshots/src/main/java/org/elasticsearch/xpack/searchablesnapshots/cache/CacheService.java b/x-pack/plugin/searchable-snapshots/src/main/java/org/elasticsearch/xpack/searchablesnapshots/cache/CacheService.java
@@ -28,6 +28,7 @@
 import org.elasticsearch.index.store.cache.CacheKey;
 import org.elasticsearch.threadpool.ThreadPool;
 
+import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.util.HashSet;
@@ -268,13 +269,15 @@ protected void synchronizeCache() {
                             IOUtils.fsync(cacheDir, true, false);
                             logger.trace("cache directory [{}] synchronized", cacheDir);
                         } catch (Exception e) {
+                            assert e instanceof IOException : e;
                             logger.warn(() -> new ParameterizedMessage("failed to synchronize cache directory [{}]", cacheDir), e);
                         }
                     }
                     // TODO Index searchable snapshot shard information + cache file ranges in Lucene
                     count += 1L;
                 }
             } catch (Exception e) {
+                assert e instanceof IOException : e;
                 logger.warn(() -> new ParameterizedMessage("failed to fsync cache file [{}]", cacheFilePath.getFileName()), e);
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -28,6 +28,7 @@`
`28`	`28`	`import org.elasticsearch.index.store.cache.CacheKey;`
`29`	`29`	`import org.elasticsearch.threadpool.ThreadPool;`
`30`	`30`
	`31`	`+import java.io.IOException;`
`31`	`32`	`import java.nio.file.Files;`
`32`	`33`	`import java.nio.file.Path;`
`33`	`34`	`import java.util.HashSet;`
`@@ -268,13 +269,15 @@ protected void synchronizeCache() {`
`268`	`269`	`IOUtils.fsync(cacheDir, true, false);`
`269`	`270`	`logger.trace("cache directory [{}] synchronized", cacheDir);`
`270`	`271`	`} catch (Exception e) {`
	`272`	`+ assert e instanceof IOException : e;`
`271`	`273`	`logger.warn(() -> new ParameterizedMessage("failed to synchronize cache directory [{}]", cacheDir), e);`
`272`	`274`	`}`
`273`	`275`	`}`
`274`	`276`	`// TODO Index searchable snapshot shard information + cache file ranges in Lucene`
`275`	`277`	`count += 1L;`
`276`	`278`	`}`
`277`	`279`	`} catch (Exception e) {`
	`280`	`+ assert e instanceof IOException : e;`
`278`	`281`	`logger.warn(() -> new ParameterizedMessage("failed to fsync cache file [{}]", cacheFilePath.getFileName()), e);`
`279`	`282`	`}`
`280`	`283`	`}`