Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 250 for dispatch (2.01 sec)

  1. cmd/metacache-entries.go

    func (e metaCacheEntry) hasPrefix(s string) bool {
    	return strings.HasPrefix(e.name, s)
    }
    
    // matches returns if the entries have the same versions.
    // If strict is false we allow signatures to mismatch.
    func (e *metaCacheEntry) matches(other *metaCacheEntry, strict bool) (prefer *metaCacheEntry, matches bool) {
    	if e == nil && other == nil {
    		return nil, true
    	}
    	if e == nil {
    		return other, false
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  2. src/bufio/bufio.go

    // ReadWriter stores pointers to a [Reader] and a [Writer].
    // It implements [io.ReadWriter].
    type ReadWriter struct {
    	*Reader
    	*Writer
    }
    
    // NewReadWriter allocates a new [ReadWriter] that dispatches to r and w.
    func NewReadWriter(r *Reader, w *Writer) *ReadWriter {
    	return &ReadWriter{r, w}
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Sep 03 14:04:47 UTC 2025
    - 22K bytes
    - Viewed (0)
  3. cmd/api-errors.go

    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrSiteReplicationIAMConfigMismatch: {
    		Code:           "XMinioSiteReplicationIAMConfigMismatch",
    		Description:    "IAM configuration mismatch between sites",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrAdminRebalanceAlreadyStarted: {
    		Code:           "XMinioAdminRebalanceAlreadyStarted",
    		Description:    "Pool rebalance is already started",
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 93K bytes
    - Viewed (3)
  4. cmd/site-replication.go

    		Cause: err,
    		Code:  ErrSiteReplicationConfigMissing,
    	}
    }
    
    func errSRIAMConfigMismatch(peer1, peer2 string, s1, s2 madmin.IDPSettings) SRError {
    	return SRError{
    		Cause: fmt.Errorf("IAM/IDP settings mismatch between %s and %s: %#v vs %#v", peer1, peer2, s1, s2),
    		Code:  ErrSiteReplicationIAMConfigMismatch,
    	}
    }
    
    var errSRObjectLayerNotReady = SRError{
    	Cause: fmt.Errorf("object layer not ready"),
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 184.8K bytes
    - Viewed (1)
  5. src/archive/zip/reader_test.go

    			rd, err := f.Open()
    			if err != nil {
    				t.Fatal(err)
    			}
    			defer rd.Close()
    
    			_, err = io.Copy(io.Discard, rd)
    			if err != ErrFormat {
    				t.Fatalf("Error mismatch\n\tGot:  %v\n\tWant: %v", err, ErrFormat)
    			}
    		})
    	}
    }
    
    func TestIssue54801(t *testing.T) {
    	for _, input := range []string{"testdata/readme.zip", "testdata/dd.zip"} {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Oct 17 20:10:27 UTC 2025
    - 56.5K bytes
    - Viewed (0)
  6. cmd/server_test.go

    	timeNow := time.Now().UTC()
    	c.Assert(creationTime.Before(timeNow), true)
    	c.Assert(timeNow.Sub(creationTime) < time.Minute*5, true)
    }
    
    // This tests validate if PUT handler can successfully detect signature mismatch.
    func (s *TestSuiteCommon) TestValidateSignature(c *check) {
    	// generate a random bucket name.
    	bucketName := getRandomBucketName()
    	// HTTP request to create the bucket.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118.1K bytes
    - Viewed (0)
  7. cmd/object-api-utils.go

    	failOnErr(s2Reader.Skip(skip))
    	got, err := io.ReadAll(s2Reader)
    	failOnErr(err)
    	if !bytes.Equal(got, data[skip:]) {
    		logger.Fatal(errSelfTestFailure, "compress: self-test roundtrip mismatch.")
    	}
    }
    
    // getDiskInfos returns the disk information for the provided disks.
    // If a disk is nil or an error is returned the result will be nil as well.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  8. docs/recipes.md

    === ":material-language-kotlin: Kotlin"
        ```kotlin
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  9. CHANGELOG.md

        compressed file (like a JAR or APK), so compressing its internal data was redundant.
    
     *  Fix: Call `ProxySelector.connectFailed()` when a connection's initial TCP handshake fails.
    
     *  Fix: Change the signature of `Dispatcher` to accept a nullable `ExecutorService`. Changing this
        parameter to be non-null was an unintended signature change in OkHttp 4.0.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
  10. cmd/erasure-multipart.go

    		if opts.WantChecksum != nil && !opts.WantChecksum.Type.Is(checksumType) {
    			return oi, InvalidArgument{
    				Bucket: bucket,
    				Object: fi.Name,
    				Err:    fmt.Errorf("checksum type mismatch. got %q (%s) expected %q (%s)", checksumType.String(), checksumType.ObjType(), opts.WantChecksum.Type.String(), opts.WantChecksum.Type.ObjType()),
    			}
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 47.1K bytes
    - Viewed (0)
Back to top