- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 515 for if (0.28 sec)
-
cmd/erasure-decode.go
blockOffset = 0 blockLength = e.blockSize } if blockLength == 0 { break } var err error bufs, err = reader.Read(bufs) if len(bufs) > 0 { // Set only if there are be enough data for reconstruction. // and only for expected errors, also set once. if errors.Is(err, errFileNotFound) || errors.Is(err, errFileCorrupt) { if derr == nil { derr = err } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/api-headers.go
// Set Etag if available. if objInfo.ETag != "" { w.Header()[xhttp.ETag] = []string{"\"" + objInfo.ETag + "\""} } if objInfo.ContentType != "" { w.Header().Set(xhttp.ContentType, objInfo.ContentType) } if objInfo.ContentEncoding != "" { w.Header().Set(xhttp.ContentEncoding, objInfo.ContentEncoding) } if !objInfo.Expires.IsZero() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.9K bytes - Viewed (1) -
cmd/healthcheck-handler.go
// return how many drives are being healed if any if result.HealingDrives > 0 { w.Header().Set(xhttp.MinIOHealingDrives, strconv.Itoa(result.HealingDrives)) } if !result.Healthy { // As a maintenance call we are purposefully asked to be taken // down, this is for orchestrators to know if we can safely // take this server down, return appropriate error. if opts.Maintenance {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
Status string } // Verify returns true if the passed host matches the filter fields func (e *EndpointFilter) Verify(ep *endpoint.LbEndpoint, cluster string) bool { if e.Address == "" && e.Port == 0 && e.Cluster == "" && e.Status == "" { return true } if e.Address != "" && !strings.EqualFold(retrieveEndpointAddress(ep), e.Address) { return false } if e.Port != 0 && retrieveEndpointPort(ep) != e.Port { return false
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
_, err := pager.NextPage(&gcsObjects) if err != nil { return false, gcsToObjectError(err, gcs.Bucket, gcs.Prefix) } if len(gcsObjects) > 0 { return true, nil } return false, nil } func newWarmBackendGCS(conf madmin.TierGCS, tier string) (*warmBackendGCS, error) { // Validation code if conf.Creds == "" { return nil, errors.New("empty credentials unsupported") }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 5.9K bytes - Viewed (0) -
cmd/xl-storage-format-v2-legacy.go
zb0001, bts, err = msgp.ReadArrayHeaderBytes(bts) if err != nil { err = msgp.WrapError(err) return } if zb0001 != 4 { err = msgp.ArrayError{Wanted: 4, Got: zb0001} return } bts, err = msgp.ReadExactBytes(bts, (x.VersionID)[:]) if err != nil { err = msgp.WrapError(err, "VersionID") return } x.ModTime, bts, err = msgp.ReadInt64Bytes(bts) if err != nil { err = msgp.WrapError(err, "ModTime")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 5.7K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache_test.go
netns1, err := p.UpsertPodCache(pod, nspath1) if err != nil { t.Fatalf("unexpected error: %v", err) } netns2, err := p.UpsertPodCache(pod, nspath2) if err != nil { t.Fatalf("unexpected error: %v", err) } if !reflect.DeepEqual(netns1, netns2) { t.Fatalf("Expected the same Netns for the same uid, got %v and %v", netns1, netns2) } if counter.Load() != 2 {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/grid/grid.go
func GetByteBufferCap(wantSz int) []byte { if wantSz < defaultBufferSize { b := GetByteBuffer()[:0] if cap(b) >= wantSz { return b } PutByteBuffer(b) } if wantSz <= maxBufferSize { b := *internal32KByteBuffer.Get().(*[]byte) if cap(b) >= wantSz { return b[:0] } internal32KByteBuffer.Put(&b) } return make([]byte, 0, wantSz)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 02 15:56:18 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/net_test.go
for i, testCase := range testCases { host, port, err := extractHostPort(testCase.addr) if testCase.expectedErr == nil && err != nil { t.Fatalf("Test %d: should succeed but failed with err: %v", i+1, err) } if testCase.expectedErr != nil && err == nil { t.Fatalf("Test %d:, should fail but succeeded.", i+1) } if err == nil { if host != testCase.host {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 08:43:09 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/grid/muxserver.go
func (m *muxServer) message(msg message) { if debugPrint { fmt.Printf("muxServer: received message %d, length %d\n", msg.Seq, len(msg.Payload)) } m.recvMu.Lock() defer m.recvMu.Unlock() if cap(m.inbound) == 0 { m.disconnect("did not expect inbound message") return } if !m.checkSeq(msg.Seq) { return } // Note, on EOF no value can be sent. if msg.Flags&FlagEOF != 0 { if len(msg.Payload) > 0 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0)