Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for channel (0.05 sec)

  1. cmd/erasure-object.go

    		Healing:          false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    	go func() {
    		ctx, cancel := context.WithCancel(ctx)
    		defer cancel()
    
    		wg := sync.WaitGroup{}
    		for i, disk := range disks {
    			if disk == nil {
    				done <- false
    				continue
    			}
    			if !disk.IsOnline() {
    				done <- false
    				continue
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  2. .github/workflows/ci.yml

                java: 21
                root-pom: pom.xml
        runs-on: ${{ matrix.os }}
        env:
          ROOT_POM: ${{ matrix.root-pom }}
        steps:
          # Cancel any previous runs for the same branch that are still running.
          - name: 'Cancel previous runs'
            uses: styfle/cancel-workflow-action@85880fa0301c86cca9da44039ee3bb12d3bedbfa # 0.12.1
            with:
              access_token: ${{ github.token }}
          - name: 'Check out repository'
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Sep 03 19:19:31 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  3. statement.go

    	}
    }
    
    // Changed check model changed or not when updating
    func (stmt *Statement) Changed(fields ...string) bool {
    	modelValue := stmt.ReflectValue
    	switch modelValue.Kind() {
    	case reflect.Slice, reflect.Array:
    		modelValue = stmt.ReflectValue.Index(stmt.CurDestIndex)
    	}
    
    	selectColumns, restricted := stmt.SelectAndOmitColumns(false, true)
    	changed := func(field *schema.Field) bool {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Sep 04 13:13:16 UTC 2025
    - 20.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/reflect/Types.java

       * {@link TypeVariableImpl#equals(Object)} is changed to no longer be equal to custom TypeVariable
       * implementations. As a result, we need to make sure our TypeVariable implementation respects
       * symmetry. Moreover, we don't want to reconstruct a native type variable {@code <A>} using our
       * implementation unless some of its bounds have changed in resolution. This avoids creating
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Sep 03 14:03:14 UTC 2025
    - 23.5K bytes
    - Viewed (0)
  5. fess-crawler/src/test/java/org/codelibs/fess/crawler/transformer/impl/AbstractTransformerTest.java

            // Newline characters
            testTransformer.setName("name\nwith\nnewlines");
            assertEquals("name\nwith\nnewlines", testTransformer.getName());
        }
    
        /**
         * Test multiple name changes
         */
        public void test_multipleNameChanges() {
            String[] names = { "first", "second", "third", "fourth", "fifth" };
    
            for (String name : names) {
                testTransformer.setName(name);
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 20.8K bytes
    - Viewed (0)
  6. .github/workflows/contributor-pr.yml

      group: ${{ (github.ref == 'refs/heads/master' || github.ref == 'refs/heads/release' ) && format('contributor-pr-base-{0}', github.sha) || format('contributor-pr-{0}', github.ref) }}
      cancel-in-progress: false
    
    env:
      # Set the DEVELOCITY_ACCESS_KEY so that a Build Scan is generated
      DEVELOCITY_ACCESS_KEY: ${{ secrets.DEVELOCITY_ACCESS_KEY }}
      # Enable debug for the `gradle-build-action` cache operations
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Thu Sep 04 22:13:34 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  7. fess-crawler/src/test/java/org/codelibs/fess/crawler/rule/impl/AbstractRuleTest.java

            assertSame(processor1, registeredRule.getResponseProcessor());
    
            // Change properties after registration
            TestResponseProcessor processor2 = new TestResponseProcessor();
            testRule.setRuleId("changedId");
            testRule.setResponseProcessor(processor2);
    
            // Verify changes are reflected (same object reference)
            assertEquals("changedId", registeredRule.getRuleId());
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 21.9K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/reflect/Types.java

       * {@link TypeVariableImpl#equals(Object)} is changed to no longer be equal to custom TypeVariable
       * implementations. As a result, we need to make sure our TypeVariable implementation respects
       * symmetry. Moreover, we don't want to reconstruct a native type variable {@code <A>} using our
       * implementation unless some of its bounds have changed in resolution. This avoids creating
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Sep 03 14:03:14 UTC 2025
    - 23.6K bytes
    - Viewed (0)
  9. docs/en/docs/release-notes.md

    These last **three consecutive releases** are independent so that you can **migrate gradually**:
    
    * First to FastAPI `0.68.2`, with no breaking changes, but upgrading all the sub-dependencies.
    * Next to FastAPI `0.69.0`, which upgrades Starlette to `0.15.0`, with AnyIO support, and a higher chance of having breaking changes in your code.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:45 UTC 2025
    - 544.1K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-rebalance.go

    	z.rebalMu.Lock()
    	defer z.rebalMu.Unlock()
    
    	r := z.rebalMeta
    	if r == nil { // rebalance not running in this node, nothing to do
    		return nil
    	}
    
    	if cancel := r.cancel; cancel != nil {
    		// cancel != nil only on pool leaders
    		r.cancel = nil
    		cancel()
    	}
    	return nil
    }
    
    // for rebalance trace support
    type rebalanceMetrics struct{}
    
    var globalRebalanceMetrics rebalanceMetrics
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
Back to top