Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for file_watcher (0.18 sec)

  1. platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/NonHierarchicalFileWatcherUpdater.java

        private final FileWatcher fileWatcher;
        private final Multiset<String> watchedDirectories = HashMultiset.create();
        private final Map<String, String> watchedDirectoryForSnapshot = new HashMap<>();
        private final Set<String> watchedWatchableHierarchies = new HashSet<>();
    
        public NonHierarchicalFileWatcherUpdater(
            FileWatcher fileWatcher,
            FileWatcherProbeRegistry probeRegistry,
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 17 04:59:05 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  2. platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/DefaultFileWatcherRegistry.java

     * limitations under the License.
     */
    
    package org.gradle.internal.watch.registry.impl;
    
    import net.rubygrapefruit.platform.file.FileWatchEvent;
    import net.rubygrapefruit.platform.file.FileWatcher;
    import net.rubygrapefruit.platform.internal.jni.AbstractNativeFileEventFunctions;
    import net.rubygrapefruit.platform.internal.jni.NativeLogger;
    import org.gradle.internal.snapshot.FileSystemLocationSnapshot;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jan 25 15:08:33 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  3. pilot/pkg/bootstrap/certcontroller.go

    					}
    				case <-s.fileWatcher.Events(tlsOptions.CertFile):
    					if keyCertTimerC == nil {
    						keyCertTimerC = time.After(watchDebounceDelay)
    					}
    				case <-s.fileWatcher.Events(tlsOptions.KeyFile):
    					if keyCertTimerC == nil {
    						keyCertTimerC = time.After(watchDebounceDelay)
    					}
    				case err := <-s.fileWatcher.Errors(tlsOptions.CertFile):
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  4. pkg/istio-agent/agent.go

    	envoyAgent *envoy.Agent
    
    	sdsServer   SDSService
    	secretCache *cache.SecretManagerClient
    
    	// Used when proxying envoy xds via istio-agent is enabled.
    	xdsProxy    *XdsProxy
    	fileWatcher filewatcher.FileWatcher
    
    	// local DNS Server that processes DNS requests locally and forwards to upstream DNS if needed.
    	localDNSServer *dnsClient.LocalDNSServer
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 10:02:56 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  5. platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/HierarchicalFileWatcherUpdaterTest.groovy

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package org.gradle.internal.watch.registry.impl
    
    import net.rubygrapefruit.platform.file.FileWatcher
    import org.gradle.internal.file.FileMetadata.AccessType
    import org.gradle.internal.snapshot.MissingFileSnapshot
    import org.gradle.internal.watch.registry.FileWatcherUpdater
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jan 23 13:24:54 UTC 2024
    - 12K bytes
    - Viewed (0)
  6. pilot/pkg/bootstrap/server.go

    	// If the address os empty, the webhooks will be set on the default httpPort.
    	httpsMux *http.ServeMux // webhooks
    
    	// fileWatcher used to watch mesh config, networks and certificates.
    	fileWatcher filewatcher.FileWatcher
    
    	// certWatcher watches the certificates for changes and triggers a notification to Istiod.
    	cacertsWatcher *fsnotify.Watcher
    	dnsNames       []string
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  7. pilot/pkg/bootstrap/server_test.go

    func TestReloadIstiodCert(t *testing.T) {
    	dir := t.TempDir()
    	stop := make(chan struct{})
    	s := &Server{
    		fileWatcher:             filewatcher.NewWatcher(),
    		server:                  server.New(),
    		istiodCertBundleWatcher: keycertbundle.NewWatcher(),
    	}
    
    	defer func() {
    		close(stop)
    		_ = s.fileWatcher.Close()
    	}()
    
    	certFile := filepath.Join(dir, "cert-file.yaml")
    	keyFile := filepath.Join(dir, "key-file.yaml")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/AbstractFileWatcherUpdaterTest.groovy

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package org.gradle.internal.watch.registry.impl
    
    
    import net.rubygrapefruit.platform.file.FileWatcher
    import org.gradle.api.internal.cache.StringInterner
    import org.gradle.api.internal.file.TestFiles
    import org.gradle.api.internal.file.TestVirtualFileSystem
    import org.gradle.internal.file.FileMetadata.AccessType
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jan 25 15:08:33 UTC 2024
    - 21.5K bytes
    - Viewed (0)
Back to top