- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 969 for continueCh (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)