Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 86 for quitting (0.05 seconds)

  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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (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()
    		}
    	}()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 22 11:16:32 GMT 2025
    - 23K bytes
    - Click Count (0)
  4. configure.py

          one from the check_success function.
        resolve_symlinks: (Bool) Translate symbolic links into the real filepath.
        n_ask_attempts: (Integer) Number of times to query for valid input before
          raising an error and quitting.
    
      Returns:
        [String] The value of var_name after querying for input.
    
      Raises:
        UserInputError: if a query has been attempted n_ask_attempts times without
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Wed Apr 30 15:18:54 GMT 2025
    - 48.3K bytes
    - Click Count (0)
  5. architecture/standards/0004-use-a-platform-architecture.md

    This platform provides specific support for Swift, C++ and C.
    
    ### Cross-cutting architecture modules
    
    There are some additional cross-cutting architecture modules that aren't themselves platforms:
    
    #### Enterprise integration
    
    Provides cross-cutting integration with Gradle's commercial product.
    
    #### IDE integration
    
    Provides cross-cutting integration with IDEs and other tooling.
    
    #### Build infrastructure
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Sun Feb 25 22:19:29 GMT 2024
    - 4.5K bytes
    - Click Count (0)
  6. architecture/platforms.md

    This platform provides specific support for Swift, C++ and C.
    
    ## Cross-cutting architecture modules
    
    There are some additional cross-cutting architecture modules that aren't platforms:
    
    ### Enterprise integration
    
    Provides cross-cutting integration with Gradle's commercial product.
    
    ### IDE integration
    
    Provides cross-cutting integration with IDEs and other tooling.
    
    ### Build infrastructure
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu May 02 06:42:46 GMT 2024
    - 5.4K bytes
    - Click Count (0)
  7. 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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  8. 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/
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  9. lib/wasm/go_js_wasm_exec

    	[[ $SOURCE != /* ]] && SOURCE="$DIR/$SOURCE"
    done
    DIR="$( cd -P "$( dirname "$SOURCE" )" && pwd )"
    
    # Increase the V8 stack size from the default of 984K
    # to 8192K to ensure all tests can pass without hitting
    # stack size limits.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Aug 30 19:15:21 GMT 2024
    - 603 bytes
    - Click Count (0)
  10. 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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.5K bytes
    - Click Count (0)
Back to Top