Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for watchable (0.62 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top