- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for watchable (0.62 sec)
-
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/AbstractFileWatcherUpdaterTest.groovy
then: 0 * _ !vfsHasSnapshotsAt(fileOutsideOfWatchableHierarchies) } def "retains files in hierarchies ignored for watching"() { def watchableHierarchy = file("watchable").createDir() def fileOutsideOfWatchableHierarchy = file("outside").file("someFile.txt").createFile() def fileInDirectoryIgnoredForWatching = file("cache/some-cache/someFile.txt").createFile()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 21.5K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/WatchableHierarchies.java
// Remove previously unwatchable files, since they may become watchable. // If we register a watchable hierarchy, then there mustn't be anything in the VFS at that location. newRoot = invalidateUnwatchableHierarchies(newRoot, invalidator, oldUnwatchableFiles); // Remove current unwatchable files, since they still may be watched.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 17:02:39 UTC 2024 - 15.8K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/HierarchicalFileWatcherUpdaterTest.groovy
} @Override int getIfNonHierarchical() { 0 } def "does not watch hierarchy to watch if no snapshot is inside"() { def watchableHierarchy = file("watchable").createDir() def secondWatchableHierarchy = file("watchable2").createDir() def fileInWatchableHierarchy = watchableHierarchy.file("some/path/file.txt").createFile() when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 23 13:24:54 UTC 2024 - 12K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/vfs/impl/WatchingVirtualFileSystemTest.groovy
0 * _ watchingVirtualFileSystem.root == nonEmptySnapshotHierarchy } def "collects hierarchies to watch and notifies the vfs"() { def watchableHierarchy = new File("watchable") def watcherProbe = new File(watchableHierarchy, ".gradle/watch-probe") def anotherWatchableHierarchy = new File("anotherWatchable")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 12.4K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/vfs/impl/WatchingVirtualFileSystem.java
private final FileChangeListeners fileChangeListeners; private final List<File> unsupportedFileSystems = new ArrayList<>(); private Logger warningLogger = LOGGER; /** * Watchable hierarchies registered before the {@link FileWatcherRegistry} has been started. */ private final Set<File> watchableHierarchiesRegisteredEarly = new LinkedHashSet<>(); private FileWatcherRegistry watchRegistry;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 02 16:22:15 UTC 2024 - 25.2K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/DefaultConfigurationCache.kt
} } private fun checkFingerprint(entryDetails: EntryDetails, layout: ConfigurationCacheRepository.Layout): CheckedFingerprint { // Register all included build root directories as watchable hierarchies, // so we can load the fingerprint for build scripts and other files from included builds // without violating file system invariants. registerWatchableBuildDirectories(entryDetails.rootDirs)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 24.3K bytes - Viewed (0) -
pkg/log/config.go
return err } *logger = newLogger closeFns = append(closeFns, closeFn) } } pt := patchTable{ write: func(ent zapcore.Entry, fields []zapcore.Field) error { err := baseLogger.Write(ent, fields) if ent.Level == zapcore.FatalLevel { funcs.Load().(patchTable).exitProcess(1) } return err }, sync: baseLogger.Sync, exitProcess: os.Exit,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 26 20:38:10 UTC 2024 - 12.1K bytes - Viewed (0) -
pilot/pkg/xds/lds_test.go
InterceptionMode: model.InterceptionNone, HTTP10: "1", }, IPAddresses: []string{"10.11.0.1"}, // matches none.yaml s1tcp.none ConfigNamespace: "none", }, nil, watchAll) err := adscon.Save(wd + "/none") if err != nil { t.Fatal(err) } // 7071 (inbound), 2001 (service - also as http proxy), 18010 (fortio) if len(adscon.GetHTTPListeners()) != 3 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
mustReadFile(t, "tests/testdata/config/static-weighted-se.yaml"), }) ads := s.Connect(nil, nil, watchAll) t.Run("Full Push", func(t *testing.T) { s.Discovery.Push(&model.PushRequest{Full: true}) if _, err := ads.Wait(time.Second*5, watchAll...); err != nil { t.Fatal(err) } }) t.Run("Incremental Push with updated services", func(t *testing.T) { ads.WaitClear()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters.go
} } if ipAddr == nil { ipAddr, err = utilnet.ResolveBindAddress(nodeIP) } } if ipAddr == nil { // We tried everything we could, but the IP address wasn't fetchable; error out return fmt.Errorf("can't get ip address of node %s. error: %v", node.Name, err) } node.Status.Addresses = []v1.NodeAddress{ {Type: v1.NodeInternalIP, Address: ipAddr.String()},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 12:12:04 UTC 2024 - 30.5K bytes - Viewed (0)