Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,002 for listener2 (0.35 sec)

  1. pilot/pkg/xds/lds_test.go

    	// Expect 2 listeners : 1 for 80, 1 for 443
    	// where 443 listener has 3 filter chains
    	if (len(adsc.GetHTTPListeners()) + len(adsc.GetTCPListeners())) != 2 {
    		t.Fatalf("Expected 2 listeners, got %d\n", len(adsc.GetHTTPListeners())+len(adsc.GetTCPListeners()))
    	}
    
    	// TODO: This is flimsy. The ADSC code treats any listener with http connection manager as a HTTP listener
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/listener_inbound.go

    		// Prepend virtual inbound, as long as we are using redirection.
    		listeners = append([]*listener.Listener{lb.inboundVirtualListener(virtualInboundFilterChains)}, listeners...)
    	}
    
    	return listeners
    }
    
    // inboundVirtualListener builds the virtual inbound listener.
    func (lb *ListenerBuilder) inboundVirtualListener(chains []*listener.FilterChain) *listener.Listener {
    	actualWildcards, _ := getWildcardsAndLocalHost(lb.node.GetIPMode())
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/envoyfilter/listener_patch.go

    	efw *model.EnvoyFilterWrapper,
    	lis []*listener.Listener,
    	skipAdds bool,
    ) (out []*listener.Listener) {
    	defer runtime.HandleCrash(runtime.LogPanic, func(any) {
    		IncrementEnvoyFilterErrorMetric(Listener)
    		log.Errorf("listeners patch %s/%s caused panic, so the patches did not take effect", efw.Namespace, efw.Name)
    	})
    	// In case the patches cause panic, use the listeners generated before to reduce the influence.
    	out = lis
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 15:39:29 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  4. maven-core/src/main/java/org/apache/maven/internal/impl/EventSpyImpl.java

                        InternalMavenSession.from(ee.getSession().getSession());
                Collection<Listener> listeners = session.getListeners();
                if (!listeners.isEmpty()) {
                    Event event = new DefaultEvent(session, ee);
                    for (Listener listener : listeners) {
                        listener.onEvent(event);
                    }
                }
            }
        }
    
        @Override
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Fri Apr 12 10:50:18 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. subprojects/core/src/test/groovy/org/gradle/configuration/project/LifecycleProjectEvaluatorTest.groovy

            project.path >> project.projectPath.toString()
            project.identityPath >> Path.path(":project1")
            project.stepEvaluationListener(listener, _) >> { listener, step ->
                step.execute(listener)
                null
            }
            project.getOwner() >> mutationState
            mutationState.applyToMutableState(_) >> { Consumer consumer -> consumer.accept(project) }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Mar 08 13:46:07 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  6. tensorflow/compiler/jit/xla_activity_listener_test.cc

    class XlaActivityListenerTest : public ::testing::Test {
     protected:
      XlaActivityListenerTest() {
        auto listener = std::make_unique<TestListener>();
        listener_ = listener.get();
        RegisterXlaActivityListener(std::move(listener));
      }
    
      TestListener* listener() const { return listener_; }
    
     private:
      TestListener* listener_;
    };
    
    GraphDef CreateGraphDef() {
      Scope root = Scope::NewRootScope().ExitOnError().WithAssignedDevice(
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 08:47:20 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        if (!isDone()) {
          Listener oldHead = listeners;
          if (oldHead != Listener.TOMBSTONE) {
            Listener newNode = new Listener(listener, executor);
            do {
              newNode.next = oldHead;
              if (ATOMIC_HELPER.casListeners(this, oldHead, newNode)) {
                return;
              }
              oldHead = listeners; // re-read
            } while (oldHead != Listener.TOMBSTONE);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  8. subprojects/core/src/integTest/groovy/org/gradle/configuration/project/LifecycleProjectEvaluatorIntegrationTest.groovy

            with(operations.only(NotifyProjectBeforeEvaluatedBuildOperationType, { it.details.projectPath == ':foo' })) {
                displayName == 'Notify beforeEvaluate listeners of :foo'
                children*.displayName == ["Execute Project.beforeEvaluate listener"]
                children.first().children*.displayName == ["Apply script '${relativePath('foo/before.gradle')}' to project ':foo'"]
                parentId == configOp.id
            }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 03 15:21:23 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractFuture.java

        if (!isDone()) {
          Listener oldHead = listeners;
          if (oldHead != Listener.TOMBSTONE) {
            Listener newNode = new Listener(listener, executor);
            do {
              newNode.next = oldHead;
              if (ATOMIC_HELPER.casListeners(this, oldHead, newNode)) {
                return;
              }
              oldHead = listeners; // re-read
            } while (oldHead != Listener.TOMBSTONE);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 62.8K bytes
    - Viewed (1)
  10. tensorflow/compiler/jit/tests/device_compiler_test_helper.h

    class DeviceCompilerSerializeTest : public ::testing::Test {
     protected:
      DeviceCompilerSerializeTest() {
        auto listener = std::make_unique<JitCompilationListener>();
        listener_ = listener.get();
        RegisterXlaActivityListener(std::move(listener));
      }
    
      JitCompilationListener* listener() const { return listener_; }
    
      // Returns a test graph that will split into two XLA clusters (due to a node
      // with _XlaCompile = false).
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri Feb 09 08:24:16 UTC 2024
    - 3.6K bytes
    - Viewed (0)
Back to top