Search Options

Results per page
Sort
Preferred Languages
Advance

Results 401 - 410 of 1,206 for before (0.04 sec)

  1. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.cache-miss-monitor.gradle.kts

    // 4. buildScanPerformance test, which doesn't depend on compileAll
    // 5. Compile All for the experimental build cache NG
    // 6. BuildCommitDistribution may build a commit which is not built before
        isInBuild(
            "Check_CompileAllBuild",
            "Component_GradlePlugin_Performance_PerformanceLatestMaster",
            "Component_GradlePlugin_Performance_PerformanceLatestReleased",
            "Check_Gradleception",
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Fri Apr 11 20:57:49 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  2. cmd/admin-heal-ops.go

    	for {
    		select {
    		case <-periodicTimer.C:
    			now := UTCNow()
    			ahs.Lock()
    			for path, h := range ahs.healSeqMap {
    				if h.hasEnded() && h.endTime.Add(keepHealSeqStateDuration).Before(now) {
    					delete(ahs.healSeqMap, path)
    				}
    			}
    			ahs.Unlock()
    
    			periodicTimer.Reset(time.Minute * 5)
    		case <-ctx.Done():
    			// server could be restarting - need
    			// to exit immediately
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  3. internal/lru/lru.go

    	if diff < 0 {
    		diff = 0
    	}
    	for i := 0; i < diff; i++ {
    		c.removeOldest()
    	}
    	c.size = size
    	return diff
    }
    
    // Close destroys cleanup goroutine. To clean up the cache, run Purge() before Close().
    // func (c *LRU[K, V]) Close() {
    //	c.mu.Lock()
    //	defer c.mu.Unlock()
    //	select {
    //	case <-c.done:
    //		return
    //	default:
    //	}
    //	close(c.done)
    // }
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  4. internal/logger/target/http/http.go

    			}
    
    			// If we are doing batching, we should wait
    			// at least for a second, before sending.
    			// Even if there is nothing in the queue.
    			if h.batchSize > 1 && time.Since(lastBatchProcess) < time.Second {
    				continue
    			}
    		}
    
    		// if we have reached the count send at once
    		// or we have crossed last second before batch was sent, send at once
    		lastBatchProcess = time.Now()
    
    		var retries int
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  5. internal/ringbuffer/ring_buffer.go

    // If block is false, Read and Write will return ErrIsEmpty or ErrIsFull immediately.
    // By default, the ring buffer is not blocking.
    // This setting should be called before any Read or Write operation or after a Reset.
    func (r *RingBuffer) SetBlocking(block bool) *RingBuffer {
    	r.block = block
    	if block {
    		r.readCond = sync.NewCond(&r.mu)
    		r.writeCond = sync.NewCond(&r.mu)
    	}
    	return r
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      private var reader: WebSocketReader? = null
    
      // All mutable web socket state is guarded by this.
    
      /** Null until this web socket is connected. Note that messages may be enqueued before that. */
      private var writer: WebSocketWriter? = null
    
      /** Used for writes, pings, and close timeouts. */
      private var taskQueue = taskRunner.newQueue()
    
      /** Names this web socket for observability and debugging. */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt

      /** All headers. */
      public val headers: Headers,
      /** The body of this request, or null if it has none. This may be truncated. */
      public val body: ByteString?,
      /** The total size of the body of this request (before truncation).*/
      public val bodySize: Long,
      /**
       * The sizes of the chunks of this request's body, or null if the request's body was not encoded
       * with chunked encoding.
       */
      public val chunkSizes: List<Int>?,
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Jun 21 20:36:35 UTC 2025
    - 3.2K bytes
    - Viewed (1)
  8. android/guava-tests/test/com/google/common/escape/EscapersTest.java

        builder.setSafeRange('a', 'z');
        builder.setUnsafeReplacement("X");
        builder.addEscape(' ', "_");
        Escaper first = builder.build();
        // Modify one of the existing mappings before creating a new escaper.
        builder.addEscape(' ', "-");
        builder.addEscape('!', "$");
        Escaper second = builder.build();
        // This should have no effect on existing escapers.
        builder.addEscape(' ', "*");
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  9. CONTRIBUTING.md

    ```sh
    $ cd minio
    $ git remote add upstream https://github.com/minio/minio
    $ git fetch upstream
    $ git merge upstream/master
    ...
    ```
    
    ### Create your feature branch
    
    Before making code changes, make sure you create a separate branch for these changes
    
    ```
    git checkout -b my-new-feature
    ```
    
    ### Test MinIO server changes
    
    After your code changes, make sure
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Aug 05 18:35:53 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. internal/config/certsinfo.go

    	buf.WriteString(color.Blue("%4sIssuer: ", ""))
    	printName(cert.Issuer.Names, &buf)
    
    	// Validity information
    	buf.WriteString(color.Blue("%4sValidity\n", ""))
    	buf.WriteString(color.Bold(fmt.Sprintf("%8sNot Before: %s\n", "", cert.NotBefore.Format(http.TimeFormat))))
    	buf.WriteString(color.Bold(fmt.Sprintf("%8sNot After : %s\n", "", cert.NotAfter.Format(http.TimeFormat))))
    
    	return buf.String()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 3.1K bytes
    - Viewed (0)
Back to top