Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 210 for CONTINUE (0.06 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 Nov 03 19:28:11 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

            // If there's a "Expect: 100-continue" header on the request, wait for a "HTTP/1.1 100
            // Continue" response before transmitting the request body. If we don't get that, return
            // what we did get (such as a 4xx response) without ever transmitting the request body.
            if ("100-continue".equals(request.header("Expect"), ignoreCase = true)) {
              exchange.flushRequest()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. src/archive/zip/fuzz_test.go

    		}
    		files := []file{}
    
    		for _, f := range r.File {
    			fr, err := f.Open()
    			if err != nil {
    				continue
    			}
    			content, err := io.ReadAll(fr)
    			if err != nil {
    				continue
    			}
    			files = append(files, file{header: &f.FileHeader, content: content})
    			if _, err := r.Open(f.Name); err != nil {
    				continue
    			}
    		}
    
    		// If we were unable to read anything out of the archive don't
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jan 13 18:06:33 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  5. cmd/untar.go

    		// if the header is nil, just skip it (not sure how this happens)
    		case header == nil:
    			continue
    		}
    
    		name := header.Name
    		switch path.Clean(name) {
    		case ".", slashSeparator:
    			continue
    		}
    
    		switch header.Typeflag {
    		case tar.TypeDir: // = directory
    			if o.ignoreDirs {
    				continue
    			}
    			name = trimLeadingSlash(pathJoin(name, slashSeparator))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. cmd/os_windows.go

    				// file/directory.
    				if osIsNotExist(err) || isSysErrPathNotFound(err) ||
    					isSysErrTooManySymlinks(err) {
    					continue
    				}
    				return err
    			}
    
    			if fi.IsDir() {
    				// Ignore symlinked directories.
    				continue
    			}
    
    			typ = fi.Mode()
    		case data.FileAttributes&syscall.FILE_ATTRIBUTE_DIRECTORY != 0:
    			typ = os.ModeDir
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/collect/WriteReplaceOverridesTest.java

        for (ClassInfo info : ClassPath.from(getClass().getClassLoader()).getAllClasses()) {
          if (!GUAVA_PACKAGES.contains(info.getPackageName())) {
            continue;
          }
          if (info.getName().endsWith("GwtSerializationDependencies")) {
            continue; // These classes exist only for the GWT compiler, not to be used.
          }
          if (
          /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 18:53:31 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. cmd/mrf.go

    				// No MRF needed for temporary objects
    				if wildcard.Match("buckets/*/.metacache/*", u.Object) {
    					continue
    				}
    				if wildcard.Match("tmp/*", u.Object) {
    					continue
    				}
    				if wildcard.Match("multipart/*", u.Object) {
    					continue
    				}
    				if wildcard.Match("tmp-old/*", u.Object) {
    					continue
    				}
    			}
    
    			now := time.Now()
    			if now.Sub(u.Queued) < time.Second {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. cmd/metacache-marker.go

    	tag := strings.Trim(s[start:end], "[]")
    	tags := strings.Split(tag, ",")
    	for _, tag := range tags {
    		kv := strings.Split(tag, ":")
    		if len(kv) < 2 {
    			continue
    		}
    		switch kv[0] {
    		case "minio_cache":
    			if kv[1] != markerTagVersion {
    				continue
    			}
    		case "id":
    			o.ID = kv[1]
    		case "return":
    			o.ID = mustGetUUID()
    			o.Create = true
    		case "p": // pool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  10. internal/s3select/sql/timestampfuncs_test.go

    		if err != nil {
    			t.Errorf("Case %d: Unexpected error: %v", i+1, err)
    			continue
    		}
    		if !tval.Equal(tc.t) {
    			t.Errorf("Case %d: Expected %v got %v", i+1, tc.t, tval)
    			continue
    		}
    
    		tstr := FormatSQLTimestamp(tc.t)
    		if tstr != tc.s {
    			t.Errorf("Case %d: Expected %s got %s", i+1, tc.s, tstr)
    			continue
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.2K bytes
    - Viewed (0)
Back to top