- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 264 for eles (0.12 sec)
-
docs/debugging/reorder-disks/main.go
if err != nil { return nil, err } exp := argP.Expand() if node == "" { for index, e := range exp { result = append(result, localDisk{index: index, path: strings.Join(e, "")}) } } else { for index, e := range exp { u, err := url.Parse(strings.Join(e, "")) if err != nil { return nil, err } if strings.Contains(u.Host, node) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/erasure-heal_test.go
// setup stale disks for the test case staleDisks := make([]StorageAPI, len(disks)) copy(staleDisks, disks) for j := 0; j < len(staleDisks); j++ { if j < test.offDisks { readers[j] = nil } else { staleDisks[j] = nil } } for j := 0; j < test.badDisks; j++ { switch r := readers[test.offDisks+j].(type) { case *streamingBitrotReader: r.disk = badDisk{nil}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/signature-v2_test.go
errCode := doesPresignV2SignatureMatch(req) if errCode != testCase.expected { t.Errorf("(%d) expected to get %s, instead got %s", i, niceError(testCase.expected), niceError(errCode)) } } else { err = preSignV2(req, accessKey, secretKey, now.Unix()+60) if err != nil { t.Fatalf("(%d) failed to preSignV2 http request, got %v", i, err) } // Should be set since we are simulating a http server.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 8K bytes - Viewed (0) -
internal/http/server.go
listenCtx, srv.Addrs, srv.TCPOptions, ) var interfaceFound bool for i := range listenErrs { if listenErrs[i] != nil { listenErrCallback(srv.Addrs[i], listenErrs[i]) } else { interfaceFound = true } } if !interfaceFound { return nil, errors.New("no available interface found") } // Wrap given handler to do additional
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/bucket-targets.go
if ok { if prev.Online != result.Online || !result.Online { if !prev.lastHCAt.IsZero() { offline = time.Since(prev.lastHCAt) + prev.offlineDuration } else { offline = prev.offlineDuration } } else if result.Online { offline = prev.offlineDuration } } lastOnline = prev.lastOnline if result.Online { lastOnline = time.Now() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/update.go
} // Return the ModTime return fi.ModTime().UTC(), nil } // GetCurrentReleaseTime - returns this process's release time. If it // is official minio version, parsed version is returned else minio // binary's mod time is returned. func GetCurrentReleaseTime() (releaseTime time.Time, err error) { if releaseTime, err = minioVersionToReleaseTime(Version); err == nil { return releaseTime, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/batch-replicate_gen.go
zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "Tags") return } if cap(z.Tags) >= int(zb0002) { z.Tags = (z.Tags)[:zb0002] } else { z.Tags = make([]BatchJobKV, zb0002) } for za0001 := range z.Tags { err = z.Tags[za0001].DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Tags", za0001) return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 18:51:46 GMT 2023 - 40.6K bytes - Viewed (0) -
cmd/erasure-server-pool.go
found++ var r io.ReadCloser if !si.Dir { r, err = disk.ReadFileStream(ctx, volume, si.Name, 0, si.Size) if err != nil { continue } } else { r = io.NopCloser(bytes.NewBuffer([]byte{})) } // Keep disk path instead of ID, to ensure that the downloaded zip file can be // easily automated with `minio server hostname{1...n}/disk{1...m}`.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
e.init.Do(func() { e.cached.Store(&AccElem{}) atomic.StoreInt64(&e.cachedSec, t) }) acc := e.cached.Load() if lastT := atomic.LoadInt64(&e.cachedSec); lastT != t { // Check if lastT was changed by someone else. if atomic.CompareAndSwapInt64(&e.cachedSec, lastT, t) { // Now we swap in a new. newAcc := &AccElem{} old := e.cached.Swap(newAcc) var a AccElem a.Size = atomic.LoadInt64(&old.Size)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/server_test.go
// and If-Unmodified-Since headers set are validated. // If-Modified-Since - Return the object only if it has been modified since the specified time, else return a 304 (not modified). // If-Unmodified-Since - Return the object only if it has not been modified since the specified time, else return a 412 (precondition failed). func (s *TestSuiteCommon) TestHeadOnObjectLastModified(c *check) { // generate a random bucket name.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0)