Search Options

Results per page
Sort
Preferred Languages
Advance

Results 501 - 510 of 1,387 for Take (0.02 sec)

  1. cmd/bucket-replication-utils_gen_test.go

    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBucketReplicationResyncStatus(b *testing.B) {
    	v := BucketReplicationResyncStatus{}
    	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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 23K bytes
    - Viewed (0)
  2. .github/workflows/codeql-analysis.yml

        #    and modify them (or add more) to build your code if your project
        #    uses a compiled language
    
        #- run: |
        #   make bootstrap
        #   make release
    
        - name: Perform CodeQL Analysis
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Thu Nov 20 13:34:13 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  3. cmd/api-response.go

    	listMultipartUploadsResponse.CommonPrefixes = make([]CommonPrefix, len(multipartsInfo.CommonPrefixes))
    	for index, commonPrefix := range multipartsInfo.CommonPrefixes {
    		listMultipartUploadsResponse.CommonPrefixes[index] = CommonPrefix{
    			Prefix: s3EncodeName(commonPrefix, encodingType),
    		}
    	}
    	listMultipartUploadsResponse.Uploads = make([]Upload, len(multipartsInfo.Uploads))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:19 UTC 2025
    - 35K bytes
    - Viewed (0)
  4. .github/CONTRIBUTING.md

    ============
    
    If you would like to contribute code to OkHttp you can do so through GitHub by
    forking the repository and sending a pull request.
    
    When submitting code, please make every effort to follow existing conventions
    and style in order to keep the code as readable as possible. Please also make
    sure your code compiles by running `./gradlew check`. Checkstyle failures
    during compilation indicate errors in your style and can be viewed in the
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Mar 17 04:16:26 UTC 2019
    - 1.4K bytes
    - Viewed (0)
  5. cmd/bootstrap-peer-server_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "CmdLines")
    				return
    			}
    			if cap(z.CmdLines) >= int(zb0002) {
    				z.CmdLines = (z.CmdLines)[:zb0002]
    			} else {
    				z.CmdLines = make([]string, zb0002)
    			}
    			for za0001 := range z.CmdLines {
    				z.CmdLines[za0001], err = dc.ReadString()
    				if err != nil {
    					err = msgp.WrapError(err, "CmdLines", za0001)
    					return
    				}
    			}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  6. cmd/local-locker.go

    func (l *localLocker) DupLockMap() localLockMap {
    	defer l.getMutex()()
    
    	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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 12K bytes
    - Viewed (0)
  7. LICENSES/OWNERS

    # See the OWNERS docs at https://go.k8s.io/owners
    
    options:
      # make root approval non-recursive
      no_parent_owners: true
    approvers:
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Mon Oct 10 12:26:53 UTC 2022
    - 151 bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    		workers:         make([]chan ReplicationWorkerOperation, 0, workers),
    		lrgworkers:      make([]chan ReplicationWorkerOperation, 0, maxLWorkers),
    		mrfReplicaCh:    make(chan ReplicationWorkerOperation, 100000),
    		mrfWorkerKillCh: make(chan struct{}, failedWorkers),
    		resyncer:        newresyncer(),
    		mrfSaveCh:       make(chan MRFReplicateEntry, 100000),
    		mrfStopCh:       make(chan struct{}, 1),
    		ctx:             ctx,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  9. internal/ringbuffer/README.md

    	"github.com/smallnest/ringbuffer"
    )
    
    func main() {
    	rb := ringbuffer.New(1024)
    
    	// write
    	rb.Write([]byte("abcd"))
    	fmt.Println(rb.Length())
    	fmt.Println(rb.Free())
    
    	// read
    	buf := make([]byte, 4)
    	rb.Read(buf)
    	fmt.Println(string(buf))
    }
    ```
    
    It is possible to use an existing buffer with by replacing `New` with `NewBuffer`.
    
    
    # Blocking vs Non-blocking
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  10. schema/schema.go

    		Name:             modelType.Name(),
    		ModelType:        modelType,
    		Table:            tableName,
    		DBNames:          make([]string, 0, 10),
    		Fields:           make([]*Field, 0, 10),
    		FieldsByName:     make(map[string]*Field, 10),
    		FieldsByBindName: make(map[string]*Field, 10),
    		FieldsByDBName:   make(map[string]*Field, 10),
    		Relationships:    Relationships{Relations: map[string]*Relationship{}},
    		cacheStore:       cacheStore,
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Oct 31 12:13:56 UTC 2025
    - 13.1K bytes
    - Viewed (0)
Back to top