Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 969 for continueCh (0.2 sec)

  1. internal/bucket/replication/replication.go

    		if rule.Status == Disabled {
    			continue
    		}
    
    		if obj.TargetArn != "" && rule.Destination.ARN != obj.TargetArn && c.RoleArn != obj.TargetArn {
    			continue
    		}
    		// Ignore other object level and prefix filters for resyncing target/listing bucket targets
    		if obj.OpType == ResyncReplicationType || obj.OpType == AllReplicationType {
    			rules = append(rules, rule)
    			continue
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Mar 28 17:44:56 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. docs/debugging/s3-check-md5/main.go

    			if object.Err != nil {
    				log.Println("FAILED: LIST with error:", object.Err)
    				continue
    			}
    			if !minModTime.IsZero() && object.LastModified.Before(minModTime) {
    				continue
    			}
    			if object.IsDeleteMarker {
    				log.Println("SKIPPED: DELETE marker object:", objFullPath(object))
    				continue
    			}
    			if _, ok := object.UserMetadata["X-Amz-Server-Side-Encryption-Customer-Algorithm"]; ok {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. tensorflow/compiler/mlir/tf2xla/internal/passes/hoist_broadcast_read.cc

        if (!scope->isProperAncestor(replicate)) continue;
        bool has_conflicting_write = false;
        for (OpOperand& use : res.getUses()) {
          Operation* using_op = use.getOwner();
          if (using_op == read) continue;
          if (!replicate->isProperAncestor(using_op)) continue;
          Operation* peer = GetAncestorBelow(using_op, replicate);
          if (read->isBeforeInBlock(peer)) continue;
          if (llvm::isa<ReadVariableOp>(peer)) continue;
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/lister_watcher_test.go

    	}
    	if limit1.Continue == "" {
    		t.Errorf("Expected list to have Continue but got none")
    	}
    	obj2, err := lw.List(metav1.ListOptions{Limit: 2, Continue: limit1.Continue})
    	if err != nil {
    		t.Fatalf("List failed: %v", err)
    	}
    	limit2, ok := obj2.(*example.PodList)
    	if !ok {
    		t.Fatalf("Expected PodList but got %v", limit2)
    	}
    	if limit2.Continue != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 11:51:06 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  5. src/cmd/vendor/golang.org/x/tools/go/analysis/passes/framepointer/framepointer.go

    				active = true
    				continue
    			}
    			if !active {
    				continue
    			}
    
    			if asmWriteBP.MatchString(line) { // clobber of BP, function is not OK
    				pass.Reportf(analysisutil.LineStart(tf, lineno), "frame pointer is clobbered before saving")
    				active = false
    				continue
    			}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 02:38:00 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  6. platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/testng/TestNGFailurePolicyIntegrationTest.groovy

            expect:
            fails "test"
    
            and:
            testResults.assertConfigMethodFailed("fail")
            testResults.assertTestSkipped("someTest")
        }
    
        def "can be configured to continue executing tests after a config method failure"() {
            when:
            assumeTrue(supportConfigFailurePolicy())
    
            buildFile << """
                testing {
                    suites {
                        test {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Sep 18 20:52:40 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  7. platforms/software/resources-http/src/main/java/org/gradle/internal/resource/transport/http/ApacheDirectoryListingParser.java

                if (parsedURI.getHost() != null && !parsedURI.getHost().equals(baseURIHost)) {
                    continue;
                }
                if (parsedURI.getScheme() != null && !parsedURI.getScheme().equals(baseURIScheme)) {
                    continue;
                }
                if (parsedURI.getPort() != baseURIPort) {
                    continue;
                }
                if (parsedURI.getPath() != null && !parsedURI.getPath().startsWith(prefixPath)) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Oct 12 19:38:08 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/typeconverter.go

    			group, ok = gvkMap["group"].(string)
    			if !ok {
    				continue
    			}
    			version, ok = gvkMap["version"].(string)
    			if !ok {
    				continue
    			}
    			kind, ok = gvkMap["kind"].(string)
    			if !ok {
    				continue
    			}
    
    		} else if gvkMap, ok := gvk.(map[string]interface{}); ok {
    			group, ok = gvkMap["group"].(string)
    			if !ok {
    				continue
    			}
    			version, ok = gvkMap["version"].(string)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:55:50 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  9. tensorflow/compiler/mlir/tensorflow/transforms/freeze_global_tensors.cc

          if (!mlir::isa<TF::ResourceType>(getElementTypeOrSelf(val.getType())))
            continue;
    
          // Check that there is only a single global tensor associated with arg.
          const TF::ResourceDataflowState *latticeElement =
              solver.lookupState<TF::ResourceDataflowState>(val);
          if (!latticeElement || latticeElement->getValue().ops.size() != 1)
            continue;
    
          // Don't freeze mutable tensors.
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  10. src/internal/poll/writev.go

    	var n int64
    	var err error
    	for len(*v) > 0 {
    		iovecs = iovecs[:0]
    		for _, chunk := range *v {
    			if len(chunk) == 0 {
    				continue
    			}
    			iovecs = append(iovecs, newIovecWithBase(&chunk[0]))
    			if fd.IsStream && len(chunk) > 1<<30 {
    				iovecs[len(iovecs)-1].SetLen(1 << 30)
    				break // continue chunk on next writev
    			}
    			iovecs[len(iovecs)-1].SetLen(len(chunk))
    			if len(iovecs) == maxVec {
    				break
    			}
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 27 18:23:49 UTC 2024
    - 1.8K bytes
    - Viewed (0)
Back to top