Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 1,214 for Take (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/post-policy-fan-out.go

    func fanOutPutObject(ctx context.Context, bucket string, objectAPI ObjectLayer, fanOutEntries []minio.PutObjectFanOutEntry, fanOutBuf []byte, opts fanOutOptions) ([]ObjectInfo, []error) {
    	errs := make([]error, len(fanOutEntries))
    	objInfos := make([]ObjectInfo, len(fanOutEntries))
    
    	var wg sync.WaitGroup
    	for i, req := range fanOutEntries {
    		wg.Add(1)
    		go func(idx int, req minio.PutObjectFanOutEntry) {
    			defer wg.Done()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  2. cmd/erasure-healing-common_test.go

    		deletePart
    		corruptPart
    	)
    
    	timeSentinel := time.Unix(1, 0).UTC()
    	threeNanoSecs := time.Unix(3, 0).UTC()
    	fourNanoSecs := time.Unix(4, 0).UTC()
    	modTimesThreeNone := make([]time.Time, 16)
    	modTimesThreeFour := make([]time.Time, 16)
    	for i := range 16 {
    		// Have 13 good xl.meta, 12 for default parity count = 4 (EC:4) and one
    		// to be tampered with.
    		if i > 12 {
    			modTimesThreeFour[i] = fourNanoSecs
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  3. cmd/erasure-heal_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		data := make([]byte, test.size)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  4. scan.go

    				values[idx] = reflectValue.Addr().Interface()
    			} else {
    				values[idx] = reflectValue.Interface()
    			}
    		}
    	}
    
    	db.RowsAffected++
    	db.AddError(rows.Scan(values...))
    	joinedNestedSchemaMap := make(map[string]interface{})
    	for idx, field := range fields {
    		if field == nil {
    			continue
    		}
    
    		if len(joinFields) == 0 || len(joinFields[idx]) == 0 {
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  5. internal/http/listener.go

    // * controls incoming connections only doing HTTP protocol
    func newHTTPListener(ctx context.Context, serverAddrs []string, opts TCPOptions) (listener *httpListener, listenErrs []error) {
    	listeners := make([]net.Listener, 0, len(serverAddrs))
    	listenErrs = make([]error, len(serverAddrs))
    
    	if opts.Trace == nil {
    		opts.Trace = func(msg string) {} // Noop if not defined.
    	}
    
    	// Unix listener with special TCP options.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  6. internal/config/lambda/event/targetlist.go

    	list.RLock()
    	defer list.RUnlock()
    
    	keys := make([]ARN, 0, len(list.targets))
    	for k := range list.targets {
    		keys = append(keys, k.ToARN(region))
    	}
    
    	return keys
    }
    
    // TargetMap - returns available targets.
    func (list *TargetList) TargetMap() map[TargetID]Target {
    	list.RLock()
    	defer list.RUnlock()
    
    	ntargets := make(map[TargetID]Target, len(list.targets))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  7. impl/maven-core/src/main/java/org/apache/maven/execution/ReactorManager.java

        public static final String FAIL_NEVER = "fail-never";
    
        public static final String MAKE_MODE = "make";
    
        public static final String MAKE_DEPENDENTS_MODE = "make-dependents";
    
        // make projects that depend on me, and projects that I depend on
        public static final String MAKE_BOTH_MODE = "make-both";
    
        private List<String> blackList = new ArrayList<>();
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Dec 12 11:02:17 GMT 2024
    - 6K bytes
    - Click Count (0)
  8. src/cmd/asm/internal/lex/lex.go

    // A Token is a scan token plus its string value.
    // A macro is stored as a sequence of Tokens with spaces stripped.
    type Token struct {
    	ScanToken
    	text string
    }
    
    // Make returns a Token with the given rune (ScanToken) and text representation.
    func Make(token ScanToken, text string) Token {
    	// Substitute the substitutes for . and /.
    	text = strings.ReplaceAll(text, "\u00B7", ".")
    	text = strings.ReplaceAll(text, "\u2215", "/")
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 29 18:31:05 GMT 2023
    - 4.1K bytes
    - Click Count (0)
  9. cmd/bucket-stats.go

    	// read lock before calling Clone()
    
    	c = brs
    	// We need to copy the map, so we do not reference the one in `brs`.
    	c.Stats = make(map[string]*BucketReplicationStat, len(brs.Stats))
    	for arn, st := range brs.Stats {
    		// make a copy of `*st`
    		s := BucketReplicationStat{
    			ReplicatedSize:                   st.ReplicatedSize,
    			ReplicaSize:                      st.ReplicaSize,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  10. callbacks/associations.go

    								}
    							}
    						}
    					}
    				}
    
    				switch db.Statement.ReflectValue.Kind() {
    				case reflect.Slice, reflect.Array:
    					var (
    						rValLen   = db.Statement.ReflectValue.Len()
    						objs      = make([]reflect.Value, 0, rValLen)
    						fieldType = rel.Field.FieldType
    						isPtr     = fieldType.Kind() == reflect.Ptr
    					)
    
    					if !isPtr {
    						fieldType = reflect.PointerTo(fieldType)
    					}
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Feb 13 06:16:26 GMT 2025
    - 14.4K bytes
    - Click Count (0)
Back to Top