Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 69 for quitting (0.03 sec)

  1. cmd/global-heal.go

    			bytes:   sz,
    			skipped: true,
    		}
    	}
    
    	// Collect updates to tracker from concurrent healEntry calls
    	results := make(chan healEntryResult, 1000)
    	quitting := make(chan struct{})
    	defer func() {
    		close(results)
    		<-quitting
    	}()
    
    	go func() {
    		for res := range results {
    			if res.entryDone {
    				tracker.setObject(res.name)
    				if time.Since(tracker.getLastUpdate()) > time.Minute {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  2. cmd/admin-heal-ops.go

    	h.mutex.Lock()
    	defer h.mutex.Unlock()
    
    	h.healedItemsMap[healType]++
    	h.lastHealActivity = UTCNow()
    }
    
    // isQuitting - determines if the heal sequence is quitting (due to an
    // external signal)
    func (h *healSequence) isQuitting() bool {
    	select {
    	case <-h.ctx.Done():
    		return true
    	default:
    		return false
    	}
    }
    
    // check if the heal sequence has ended
    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. cmd/batch-expire.go

    		for !quit {
    			select {
    			case <-saveTicker.C:
    			case <-ctx.Done():
    				quit = true
    			case <-saverQuitCh:
    				quit = true
    			}
    
    			if quit {
    				// save immediately if we are quitting
    				after = 0
    			}
    
    			ctx, cancel := context.WithTimeout(GlobalContext, 30*time.Second) // independent context
    			batchLogIf(ctx, ri.updateAfter(ctx, api, after, job))
    			cancel()
    		}
    	}()
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Apr 22 11:16:32 UTC 2025
    - 23K bytes
    - Viewed (0)
  4. internal/bpool/bpool_test.go

    		t.Fatalf("bytepool size invalid: got %v want %v", len(bp.c), size)
    	}
    
    	// lets drain the buf channel first before we validate invalid buffers.
    	for range size {
    		bp.Get() // discard
    	}
    
    	// Try putting some invalid buffers into pool
    	bp.Put(make([]byte, bp.w, bp.wcap-1)) // wrong capacity is rejected (less)
    	bp.Put(make([]byte, bp.w, bp.wcap+1)) // wrong capacity is rejected (more)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  5. CLAUDE.md

    │   ├── user/                  # User index
    │   ├── exbhv/                 # Extended behaviors (repositories)
    │   └── exentity/              # Extended entities (domain models)
    ├── helper/                    # Cross-cutting utilities
    ├── crawler/                   # Crawling engine
    ├── sso/                       # SSO implementations
    └── ds/                        # Data store connectors
    
    src/main/resources/
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  6. docs/ja/llm-prompt.md

    2) Do not add a trailing period at the end of headings.
    
    ### Quotes
    
    1) Prefer Japanese corner brackets 「」 in normal prose when quoting a term.
    2) Do not change quotes inside inline code, code blocks, URLs, or file paths.
    
    ### Ellipsis
    
    1) Keep ellipsis style consistent with existing Japanese docs (commonly `...`).
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 20 17:30:52 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  7. cmd/dynamic-timeouts.go

    			failures++
    		} else if dur > maxDur {
    			maxDur = dur
    		}
    	}
    
    	failPct := float64(failures) / float64(len(entries))
    
    	if failPct > dynamicTimeoutIncreaseThresholdPct {
    		// We are hitting the timeout too often, so increase the timeout by 25%
    		timeout := min(
    			// Set upper cap.
    			atomic.LoadInt64(&dt.timeout)*125/100, int64(maxDynamicTimeout))
    		// Safety, shouldn't happen
    		if timeout < dt.minimum {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  8. docs/en/docs/deployment/index.md

    ## What Does Deployment Mean { #what-does-deployment-mean }
    
    To **deploy** an application means to perform the necessary steps to make it **available to the users**.
    
    For a **web API**, it normally involves putting it in a **remote machine**, with a **server program** that provides good performance, stability, etc, so that your **users** can **access** the application efficiently and without interruptions or problems.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Mon Nov 17 19:33:53 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/PomInlinerTransformer.java

    import org.eclipse.aether.installation.InstallRequest;
    
    import static java.util.Objects.requireNonNull;
    
    /**
     * Inliner POM transformer. The goal of this transformer is to fix Maven 3 issue about emitting (installing, deploying)
     * unusable POMs when using CI Friendly Versions.
     *
     * @since TBD
     */
    @Singleton
    @Named
    class PomInlinerTransformer extends TransformerSupport {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 20:01:00 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/math/MathBenchmarking.java

        74,
        72,
        70,
        69,
        68,
        67,
        67,
        66,
        66,
        66,
        66
      };
    
      /**
       * Generates values in a distribution equivalent to randomNonNegativeBigInteger but omitting zero.
       */
      static BigInteger randomPositiveBigInteger(int numBits) {
        BigInteger result;
        do {
          result = randomNonNegativeBigInteger(numBits);
        } while (result.signum() == 0);
        return result;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 4.2K bytes
    - Viewed (0)
Back to top