Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 900 for makeAs (0.07 sec)

  1. src/archive/tar/strconv.go

    // using octal encoding with the appropriate NUL terminator.
    func fitsInOctal(n int, x int64) bool {
    	octBits := uint(n-1) * 3
    	return x >= 0 && (n >= 22 || x < 1<<octBits)
    }
    
    // parsePAXTime takes a string of the form %d.%d as described in the PAX
    // specification. Note that this implementation allows for negative timestamps,
    // which is allowed for by the PAX specification, but not always portable.
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Aug 01 14:28:42 UTC 2023
    - 9K bytes
    - Viewed (0)
  2. cmd/site-replication-utils.go

    	// map peer deployment ID to resync ID
    	peerResyncMap map[string]resyncState
    }
    
    func newSiteResyncMetrics(ctx context.Context) *siteResyncMetrics {
    	s := siteResyncMetrics{
    		resyncStatus:  make(map[string]SiteResyncStatus),
    		peerResyncMap: make(map[string]resyncState),
    	}
    	go s.save(ctx)
    	go s.init(ctx)
    	return &s
    }
    
    // init site resync metrics
    func (sm *siteResyncMetrics) init(ctx context.Context) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (1)
  3. cmd/local-locker.go

    func (l *localLocker) DupLockMap() localLockMap {
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    
    	lockCopy := make(map[string][]lockRequesterInfo, len(l.lockMap))
    	for k, v := range l.lockMap {
    		if len(v) == 0 {
    			delete(l.lockMap, k)
    			continue
    		}
    		lockCopy[k] = append(make([]lockRequesterInfo, 0, len(v)), v...)
    	}
    	return lockCopy
    }
    
    func (l *localLocker) Close() error {
    	return nil
    }
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  4. cmd/site-replication-metrics_gen_test.go

    	v := RStat{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgRStat(b *testing.B) {
    	v := RStat{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		bts, _ = v.MarshalMsg(bts[0:0])
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 30 08:00:59 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  5. internal/grid/msg_gen_test.go

    	v := connectReq{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgconnectReq(b *testing.B) {
    	v := connectReq{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		bts, _ = v.MarshalMsg(bts[0:0])
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  6. 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 {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  7. cmd/erasure-metadata_test.go

    			}
    		}
    		return fis
    	}
    
    	commonSuccModTime := time.Date(2023, time.August, 25, 0, 0, 0, 0, time.UTC)
    	succModTimesInQuorum := make([]time.Time, 16)
    	succModTimesNoQuorum := make([]time.Time, 16)
    	commonNumVersions := 2
    	numVersionsInQuorum := make([]int, 16)
    	numVersionsNoQuorum := make([]int, 16)
    	for i := 0; i < 16; i++ {
    		if i < 4 {
    			continue
    		}
    		succModTimesInQuorum[i] = commonSuccModTime
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  8. 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))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (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,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (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.PtrTo(fieldType)
    					}
    
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Tue Apr 11 03:06:13 UTC 2023
    - 14.3K bytes
    - Viewed (0)
Back to top