diff options
author | Yuexi Ma <yuexima@google.com> | 2020-03-04 18:43:18 -0800 |
---|---|---|
committer | Yuexi Ma <yuexima@google.com> | 2020-03-05 03:04:14 +0000 |
commit | cef92d673c81daab4b0dad931591947c86e0dc8a (patch) | |
tree | f8cbc802a806455c5fdfeab7f696c63641b9f9f5 /jimfs/src/main/java/com/google/common/jimfs/WatchServiceConfiguration.java | |
parent | 68591711a9034281d5fe11fc7a30e535bbce125c (diff) | |
parent | 93a6c6782a9fdf1365face2461876b8644b2a404 (diff) | |
download | jimfs-cef92d673c81daab4b0dad931591947c86e0dc8a.tar.gz |
Initial merge with upstreamandroid-r-preview-4android-r-preview-3android-r-preview-2
Test: n/a
Bug: 150784654
Change-Id: I6fb223f1bd657a6a3d0be1492f63a7774e21943e
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 + ")"; + } + } +} |