Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 23 for Cortez (0.18 sec)

  1. cmd/erasure-server-pool.go

    		go func(idx int, pool *erasureSets) {
    			defer wg.Done()
    			dobjects[idx], derrs[idx] = pool.DeleteObject(ctx, bucket, object, opts)
    		}(idx, pool)
    	}
    	wg.Wait()
    
    	// the poolIndices array is pre-sorted in order of latest ModTime, we care only about pool with latest object though
    	// the delete call tries to clean up other pools during DeleteObject call.
    	objInfo = dobjects[0]
    	objInfo.Name = decodeDirObject(object)
    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)
  2. cmd/object-handlers.go

    		TagSet: &ObjectTagSet{},
    	}
    
    	var list []tags.Tag
    	for k, v := range ot.ToMap() {
    		list = append(list, tags.Tag{
    			Key:   k,
    			Value: v,
    		})
    	}
    	// Always return in sorted order for tags.
    	sort.Slice(list, func(i, j int) bool {
    		return list[i].Key < list[j].Key
    	})
    	otags.TagSet.Tags = list
    
    	writeSuccessResponseXML(w, encodeResponse(otags))
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/metacache-walk.go

    	DiskID string
    }
    
    // supported FS for Nlink optimization in readdir.
    const (
    	xfs  = "XFS"
    	ext4 = "EXT4"
    )
    
    // WalkDir will traverse a directory and return all entries found.
    // On success a sorted meta cache stream will be returned.
    // Metadata has data stripped, if any.
    func (s *xlStorage) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) {
    	legacyFS := !(s.fsType == xfs || s.fsType == ext4)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  4. internal/logger/logger.go

    	errorFmtFunc = f
    }
    
    // uniq swaps away duplicate elements in data, returning the size of the
    // unique set. data is expected to be pre-sorted, and the resulting set in
    // the range [0:size] will remain in sorted order. Uniq, following a
    // sort.Sort call, can be used to prepare arbitrary inputs for use as sets.
    func uniq(data sort.Interface) (size int) {
    	p, l := 0, data.Len()
    	if l <= 1 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  5. cmd/signature-v4.go

    			if idx > 0 {
    				buf.WriteByte(',')
    			}
    			buf.WriteString(signV4TrimAll(v))
    		}
    		buf.WriteByte('\n')
    	}
    	return buf.String()
    }
    
    // getSignedHeaders generate a string i.e alphabetically sorted, semicolon-separated list of lowercase request header names
    func getSignedHeaders(signedHeaders http.Header) string {
    	var headers []string
    	for k := range signedHeaders {
    		headers = append(headers, strings.ToLower(k))
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  6. internal/store/queuestore.go

    	sort.Slice(l, func(i, j int) bool {
    		return store.entries[l[i]] < store.entries[l[j]]
    	})
    	store.RUnlock()
    
    	return l, nil
    }
    
    // list will read all entries from disk.
    // Entries are returned sorted by modtime, oldest first.
    // Underlying entry list in store is *not* updated.
    func (store *QueueStore[_]) list() ([]os.DirEntry, error) {
    	files, err := os.ReadDir(store.directory)
    	if err != nil {
    		return nil, err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  7. src/cmd/api/main_test.go

    // The satisfied tags are derived from context but only those that
    // matter (the ones listed in the tags argument plus GOOS and GOARCH) are used.
    // The tags list, which came from go/build's Package.AllTags,
    // is known to be sorted.
    func tagKey(dir string, context *build.Context, tags []string) string {
    	ctags := map[string]bool{
    		context.GOOS:   true,
    		context.GOARCH: true,
    	}
    	if context.CgoEnabled {
    		ctags["cgo"] = true
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Apr 09 20:48:51 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2_test.go

    		}
    		xl.sortByModTime()
    		if !sort.SliceIsSorted(xl.versions, func(i, j int) bool {
    			return xl.versions[i].header.ModTime > xl.versions[j].header.ModTime
    		}) {
    			t.Errorf("Contents not sorted")
    		}
    		for i := range xl.versions {
    			hdr := xl.versions[i].header
    			ver, err := xl.getIdx(i)
    			if err != nil {
    				t.Error(err)
    				continue
    			}
    			gotHdr := ver.header()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    			return result, toObjectErr(err, bucket, object)
    		}
    		break
    	}
    
    	for i := range uploadIDs {
    		uploadIDs[i] = strings.TrimSuffix(uploadIDs[i], SlashSeparator)
    	}
    
    	// S3 spec says uploadIDs should be sorted based on initiated time, we need
    	// to read the metadata entry.
    	var uploads []MultipartInfo
    
    	populatedUploadIDs := set.NewStringSet()
    
    	for _, uploadID := range uploadIDs {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  10. cmd/metacache-stream.go

    // 1. Bool. If false at end of stream.
    // 2. String. Name of object. Directories contains a trailing slash.
    // 3. Binary. Blob of metadata. Length 0 on directories.
    // ... Next element.
    //
    // Streams can be assumed to be sorted in ascending order.
    // If the stream ends before a false boolean it can be assumed it was truncated.
    
    const metacacheStreamVersion = 2
    
    // metacacheWriter provides a serializer of metacache objects.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 19.5K bytes
    - Viewed (0)
Back to top