diff options
author | Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com> | 2020-03-05 04:32:40 +0000 |
---|---|---|
committer | Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com> | 2020-03-05 04:32:40 +0000 |
commit | e50b3b756101b544da2b0d62041d91547ce14a00 (patch) | |
tree | f8cbc802a806455c5fdfeab7f696c63641b9f9f5 /jimfs/src/main/java/com/google/common/jimfs/WatchServiceConfiguration.java | |
parent | 68591711a9034281d5fe11fc7a30e535bbce125c (diff) | |
parent | c5f71e95df2f3189f2b68140ebac0c76a238190f (diff) | |
download | jimfs-e50b3b756101b544da2b0d62041d91547ce14a00.tar.gz |
Initial merge with upstream am: cef92d673c am: c5f71e95df
Change-Id: I78d1f8b680646deee89918ad5ff43a8615945c35
Diffstat (limited to 'jimfs/src/main/java/com/google/common/jimfs/WatchServiceConfiguration.java')
-rw-r--r-- | jimfs/src/main/java/com/google/common/jimfs/WatchServiceConfiguration.java | 76 |
1 files changed, 76 insertions, 0 deletions
diff --git a/jimfs/src/main/java/com/google/common/jimfs/WatchServiceConfiguration.java b/jimfs/src/main/java/com/google/common/jimfs/WatchServiceConfiguration.java new file mode 100644 index 0000000..5a28627 --- /dev/null +++ b/jimfs/src/main/java/com/google/common/jimfs/WatchServiceConfiguration.java @@ -0,0 +1,76 @@ +/* + * Copyright 2016 Google Inc. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package com.google.common.jimfs; + +import static com.google.common.base.Preconditions.checkArgument; +import static com.google.common.base.Preconditions.checkNotNull; +import static java.util.concurrent.TimeUnit.SECONDS; + +import java.nio.file.WatchService; +import java.util.concurrent.TimeUnit; + +/** + * Configuration for the {@link WatchService} implementation used by a file system. + * + * @author Colin Decker + * @since 1.1 + */ +public abstract class WatchServiceConfiguration { + + /** The default configuration that's used if the user doesn't provide anything more specific. */ + static final WatchServiceConfiguration DEFAULT = polling(5, SECONDS); + + /** + * Returns a configuration for a {@link WatchService} that polls watched directories for changes + * every {@code interval} of the given {@code timeUnit} (e.g. every 5 {@link TimeUnit#SECONDS + * seconds}). + */ + @SuppressWarnings("GoodTime") // should accept a java.time.Duration + public static WatchServiceConfiguration polling(long interval, TimeUnit timeUnit) { + return new PollingConfig(interval, timeUnit); + } + + WatchServiceConfiguration() {} + + /** Creates a new {@link AbstractWatchService} implementation. */ + // return type and parameters of this method subject to change if needed for any future + // implementations + abstract AbstractWatchService newWatchService(FileSystemView view, PathService pathService); + + /** Implementation for {@link #polling}. */ + private static final class PollingConfig extends WatchServiceConfiguration { + + private final long interval; + private final TimeUnit timeUnit; + + private PollingConfig(long interval, TimeUnit timeUnit) { + checkArgument(interval > 0, "interval (%s) must be positive", interval); + this.interval = interval; + this.timeUnit = checkNotNull(timeUnit); + } + + @Override + AbstractWatchService newWatchService(FileSystemView view, PathService pathService) { + return new PollingWatchService(view, pathService, view.state(), interval, timeUnit); + } + + @Override + public String toString() { + return "WatchServiceConfiguration.polling(" + interval + ", " + timeUnit + ")"; + } + } +} |