Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 416 for connectat (0.32 sec)

  1. pilot/pkg/xds/debug.go

    	adsClients.Total = len(connections)
    
    	for _, c := range connections {
    		adsClient := AdsClient{
    			ConnectionID: c.ID(),
    			ConnectedAt:  c.ConnectedAt(),
    			PeerAddress:  c.Peer(),
    		}
    		adsClients.Connected = append(adsClients.Connected, adsClient)
    	}
    	writeJSON(w, adsClients, req)
    }
    
    // adsz implements a status and debug interface for ADS.
    // It is mapped to /debug/adsz
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  2. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r65/ToolingApiShutdownCrossVersionSpec.groovy

        }
    
        def "cannot create new project connection after disconnect"() {
            setup:
            def connector = toolingApi.connector()
            withConnection(connector) { connection ->
                connection.getModel(EclipseProject)
            }
            connector.disconnect()
    
            when:
            connector.connect()
    
            then:
            def e = thrown(RuntimeException)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 16 10:10:39 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/graph/Network.java

      Graph<N> asGraph();
    
      //
      // Network properties
      //
    
      /**
       * Returns true if the edges in this network are directed. Directed edges connect a {@link
       * EndpointPair#source() source node} to a {@link EndpointPair#target() target node}, while
       * undirected edges connect a pair of nodes to each other.
       */
      boolean isDirected();
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jan 22 17:29:38 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  4. platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ToolingApi.groovy

        }
    
        def <T> T withConnection(@DelegatesTo(ProjectConnection) Closure<T> cl) {
            def connector = connector()
            withConnection(connector, cl)
        }
    
        def <T> T withConnection(connector, @DelegatesTo(ProjectConnection) Closure<T> cl) {
            return withConnectionRaw(connector, cl)
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 14 10:07:23 UTC 2024
    - 12K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/RangeMap.java

       * same value those two ranges will be coalesced.
       *
       * <p><b>Note:</b> coalescing requires calling {@code .equals()} on any connected values, which
       * may be expensive depending on the value type. Using this method on range maps with large values
       * such as {@link Collection} types is discouraged.
       *
       * @since 22.0
       */
      void putCoalescing(Range<K> range, V value);
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  6. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/HttpServerFixture.groovy

            def port = connector.port
            server.removeConnector(connector)
            connector.stop()
            portAllocator.releasePort(port)
        }
    
        private boolean createConnector() {
            def assignedPort = portAllocator.assignPort()
            connector = new ServerConnector(server)
            connector.port = assignedPort
            server.addConnector(connector)
            try {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DefaultDaemonConnectorTest.groovy

            expect:
            def connection = connector.connect({it.pid != 0} as DummyExplainingSpec)
            connection == null
    
            and:
            numAllDaemons == 1
        }
    
        def "suspect address is removed from the registry on connect failure"() {
            given:
            startIdleDaemon()
            assert !registry.all.empty
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 10:50:51 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  8. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r213/ModelsWithGradleProjectCrossVersionSpec.groovy

            def connector = connector()
            connector.forProjectDirectory(rootDir.absoluteFile)
            connector.searchUpwards(searchUpwards)
            def model = withConnection(connector) { it.getModel(modelType) }
            return toGradleProject(model)
        }
    
        private <T> T getModelWithProjectConnection(TestFile rootDir, Class<T> modelType) {
            def connector = connector()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 16 10:10:39 UTC 2024
    - 9K bytes
    - Viewed (0)
  9. platforms/core-runtime/daemon-services/src/main/java/org/gradle/api/internal/tasks/userinput/UserQuestions.java

         *
         * @param question The text of the question.
         * @param defaultValue The option to present to the user as the default choice, and the value to use when not connected to a console
         * @return the answer or the given default if not connected to a console.
         */
        boolean askBooleanQuestion(String question, boolean defaultValue);
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 09 04:50:46 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        assertEvents(
          "plan 1 TCP connected",
          "plan 0 cancel",
          "plan 1 TLS connecting...",
          "plan 1 TLS connect failed",
          "plan 2 TCP connecting...",
          "plan 2 TCP connected",
          "plan 2 TLS connecting...",
          "plan 2 TLS connected",
        )
    
        taskFaker.advanceUntil(270.ms)
        assertEvents(
          "plan 0 TCP connect canceled",
        )
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top