Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 83 for Kistner (0.33 sec)

  1. istioctl/pkg/writer/envoy/configdump/listener.go

    		return false
    	}
    	return true
    }
    
    func getFilterChains(l *listener.Listener) []*listener.FilterChain {
    	res := l.FilterChains
    	if l.DefaultFilterChain != nil {
    		res = append(res, l.DefaultFilterChain)
    	}
    	return res
    }
    
    // retrieveListenerType classifies a Listener as HTTP|TCP|HTTP+TCP|UNKNOWN
    func retrieveListenerType(l *listener.Listener) string {
    	nHTTP := 0
    	nTCP := 0
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  2. internal/http/listener_test.go

    				}
    			} else if listenErrs[i] == nil {
    				t.Fatalf("Test %d: listenErrs[%d]: expected = %v, got = <nil>", testIdx+1, i, expectedListenErr)
    			}
    		}
    		if listener != nil {
    			listener.Close()
    		}
    	}
    }
    
    func TestHTTPListenerStartClose(t *testing.T) {
    	if runtime.GOOS == "windows" {
    		t.Skip()
    	}
    
    	nonLoopBackIP := getNonLoopBackIP(t)
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Jun 12 16:09:28 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      private static final ListenerCallQueue.Event<Listener> STARTING_EVENT =
          new ListenerCallQueue.Event<Listener>() {
            @Override
            public void call(Listener listener) {
              listener.starting();
            }
    
            @Override
            public String toString() {
              return "starting()";
            }
          };
      private static final ListenerCallQueue.Event<Listener> RUNNING_EVENT =
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        RecordingListener listener = new RecordingListener();
        manager.addListener(listener, directExecutor());
        manager.startAsync().awaitHealthy();
        assertTrue(manager.isHealthy());
        assertTrue(listener.healthyCalled);
        assertFalse(listener.stoppedCalled);
        assertTrue(listener.failedServices.isEmpty());
        manager.stopAsync().awaitStopped();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.9K bytes
    - Viewed (0)
  5. build-logic/documentation/src/test/groovy/gradlebuild/docs/dsl/docbook/JavadocConverterTest.groovy

            when:
            def result = parser.parse(classMetaData, listener)
    
            then:
            format(result.docbook) == '''<para><xref/> <xref/></para>'''
            1 * linkConverter.resolve('someClass', classMetaData, listener) >> document.createElement("xref")
            1 * linkConverter.resolve('otherClass#method(a, b) label', classMetaData, listener) >> document.createElement("xref")
            0 * linkConverter._
        }
    
    Groovy
    - Registered: Wed Apr 17 11:36:08 GMT 2024
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 14.2K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        RecordingListener listener = new RecordingListener();
        manager.addListener(listener, directExecutor());
        manager.startAsync().awaitHealthy();
        assertTrue(manager.isHealthy());
        assertTrue(listener.healthyCalled);
        assertFalse(listener.stoppedCalled);
        assertTrue(listener.failedServices.isEmpty());
        manager.stopAsync().awaitStopped();
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Mon Oct 02 17:20:27 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  7. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/JavadocConverter.java

            private final GenerationListener listener;
    
            private UnknownJavadocTagHandler(DocBookBuilder nodes, Document document, GenerationListener listener) {
                this.nodes = nodes;
                this.document = document;
                this.listener = listener;
            }
    
            @Override
            public boolean onJavadocTag(String tag, String value) {
    Java
    - Registered: Wed Apr 17 11:36:08 GMT 2024
    - Last Modified: Wed Dec 09 08:14:05 GMT 2020
    - 29.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

      private static final ListenerCallQueue.Event<Listener> HEALTHY_EVENT =
          new ListenerCallQueue.Event<Listener>() {
            @Override
            public void call(Listener listener) {
              listener.healthy();
            }
    
            @Override
            public String toString() {
              return "healthy()";
            }
          };
      private static final ListenerCallQueue.Event<Listener> STOPPED_EVENT =
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 30.5K bytes
    - Viewed (0)
  9. maven-api-impl/src/main/java/org/apache/maven/internal/impl/AbstractSession.java

        }
    
        @Override
        public void registerListener(@Nonnull Listener listener) {
            listeners.add(nonNull(listener));
        }
    
        @Override
        public void unregisterListener(@Nonnull Listener listener) {
            listeners.remove(nonNull(listener));
        }
    
        @Nonnull
        @Override
        public Collection<Listener> getListeners() {
            return Collections.unmodifiableCollection(listeners);
    Java
    - Registered: Sun Apr 21 03:35:09 GMT 2024
    - Last Modified: Fri Apr 12 10:50:18 GMT 2024
    - 27.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

          throw exception;
        }
      }
    
      private static class RecordingListener extends Listener {
        static RecordingListener record(Service service) {
          RecordingListener listener = new RecordingListener(service);
          service.addListener(listener, directExecutor());
          return listener;
        }
    
        final Service service;
    
        RecordingListener(Service service) {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 29.3K bytes
    - Viewed (0)
Back to top