Search Options

Results per page
Sort
Preferred Languages
Advance

Results 471 - 480 of 559 for complete (0.09 sec)

  1. prepare_stmt.go

    		return Stmt{}, ErrInvalidDB
    	}
    	// cache preparing stmt first
    	cacheStmt := Stmt{Transaction: isTransaction, prepared: make(chan struct{})}
    	db.Stmts[query] = &cacheStmt
    	db.Mux.Unlock()
    
    	// prepare completed
    	defer close(cacheStmt.prepared)
    
    	// Reason why cannot lock conn.PrepareContext
    	// suppose the maxopen is 1, g1 is creating record and g2 is querying record.
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt

       */
      object ShutdownOutputAtEnd : SocketPolicy
    
      /**
       * After accepting the connection and doing TLS (if configured) don't do HTTP/1.1 or HTTP/2
       * framing. Ignore the socket completely until the server is shut down.
       */
      object StallSocketAtStart : SocketPolicy
    
      /**
       * Read the request but don't respond to it. Just keep the socket open. For testing read response
       * header timeout issue.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. internal/config/lambda/target/webhook.go

    	// No network failure i.e response from the target means its up
    	return true, nil
    }
    
    // Stat - returns lambda webhook target statistics such as
    // current calls in progress, successfully completed functions
    // failed functions.
    func (target *WebhookTarget) Stat() event.TargetStat {
    	return event.TargetStat{
    		ID:             target.id,
    		ActiveRequests: atomic.LoadInt64(&target.activeRequests),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  4. docs/metrics/v3.md

    ## Metrics Request Handling
    
    Each endpoint can be queried as needed via a scrape configuration in Prometheus or a compatible metrics collection tool. You should schedule scrape operations so a prior scrape completes before the next one begins.
    
    For ease of configuration, each (non-empty) parent of the path serves all the metric endpoints at its child paths. For example, to query all system metrics scrape `/minio/metrics/v3/system/`.
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 02 22:30:11 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  5. docs/features/events.md

        .url("https://www.nytimes.com/")
        .build();
    client.newCall(newYorkTimesRequest).enqueue(new Callback() {
      ...
    });
    ```
    
    Running this race over home WiFi shows the Times (`0002`) completes just slightly sooner than the Post (`0001`):
    
    ```
    0001 https://www.washingtonpost.com/
    0001 0.000 callStart
    0002 https://www.nytimes.com/
    0002 0.000 callStart
    0002 0.010 dnsStart
    0001 0.013 dnsStart
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 7.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/AbstractCache.java

         */
        void recordMisses(int count);
    
        /**
         * Records the successful load of a new entry. This should be called when a cache request causes
         * an entry to be loaded, and the loading completes successfully. In contrast to {@link
         * #recordMisses}, this method should only be called by the loading thread.
         *
         * @param loadTime the number of nanoseconds the cache spent computing or retrieving the new
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 15 18:00:07 UTC 2021
    - 9.1K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/FastFallbackTest.kt

          )
        serverIpv4.protocols = listOf(Protocol.H2_PRIOR_KNOWLEDGE)
        serverIpv6.protocols = listOf(Protocol.H2_PRIOR_KNOWLEDGE)
    
        // Yield the first IP address so the second IP address completes first.
        val firstConnectLatch = CountDownLatch(1)
        val socketFactory =
          object : DelegatingSocketFactory(SocketFactory.getDefault()) {
            var first = true
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  8. docs/contribute/concurrency.md

    Since HTTP requests frequently happen in parallel, connection pooling must be thread-safe.
    
    These are the primary classes involved with establishing, sharing, and terminating connections:
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  9. docs/pt/docs/advanced/security/http-basic-auth.md

    <img src="/img/tutorial/security/image12.png">
    
    ## Verifique o usuário
    
    Aqui está um exemplo mais completo.
    
    Utilize uma dependência para verificar se o usuário e a senha estão corretos.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/form/FormScheme.java

        @Override
        public String getRealm() {
            return null;
        }
    
        @Override
        public boolean isConnectionBased() {
            return false;
        }
    
        @Override
        public boolean isComplete() {
            return false;
        }
    
        @Override
        public Header authenticate(final Credentials credentials, final HttpRequest request) throws AuthenticationException {
            return null;
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 11.5K bytes
    - Viewed (0)
Back to top