Search Options

Results per page
Sort
Preferred Languages
Advance

Results 391 - 400 of 796 for Arrange (2.8 sec)

  1. src/bytes/buffer_test.go

    	{"alpha\nbeta\ngamma", '\n', []string{"alpha\n", "beta\n", "gamma"}, io.EOF},
    }
    
    func TestReadBytes(t *testing.T) {
    	for _, test := range readBytesTests {
    		buf := NewBufferString(test.buffer)
    		var err error
    		for _, expected := range test.expected {
    			var bytes []byte
    			bytes, err = buf.ReadBytes(test.delim)
    			if string(bytes) != expected {
    				t.Errorf("expected %q, got %q", expected, bytes)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon May 19 16:13:04 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  2. cmd/metacache-server-pool.go

    	allAtEOF := true
    	var inputs []chan metaCacheEntry
    	mu.Lock()
    	// Ask all sets and merge entries.
    	listCtx, cancelList := context.WithCancel(ctx)
    	defer cancelList()
    	for _, pool := range z.serverPools {
    		for _, set := range pool.sets {
    			wg.Add(1)
    			innerResults := make(chan metaCacheEntry, 100)
    			inputs = append(inputs, innerResults)
    			go func(i int, set *erasureObjects) {
    				defer wg.Done()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  3. cmd/data-scanner-metric.go

    	m.LifeTimeOps = make(map[string]uint64, scannerMetricLast)
    	for i := range scannerMetricLast {
    		if n := atomic.LoadUint64(&p.operations[i]); n > 0 {
    			m.LifeTimeOps[i.String()] = n
    		}
    	}
    	if len(m.LifeTimeOps) == 0 {
    		m.LifeTimeOps = nil
    	}
    
    	m.LastMinute.Actions = make(map[string]madmin.TimedAction, scannerMetricLastRealtime)
    	for i := range scannerMetricLastRealtime {
    		lm := p.lastMinute(i)
    		if lm.N > 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  4. cmd/signature-v4.go

    	var headers []string
    	vals := make(http.Header, len(signedHeaders))
    	for k, vv := range signedHeaders {
    		k = strings.ToLower(k)
    		headers = append(headers, k)
    		vals[k] = vv
    	}
    	sort.Strings(headers)
    
    	var buf bytes.Buffer
    	for _, k := range headers {
    		buf.WriteString(k)
    		buf.WriteByte(':')
    		for idx, v := range vals[k] {
    			if idx > 0 {
    				buf.WriteByte(',')
    			}
    			buf.WriteString(signV4TrimAll(v))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Dec 13 22:19:12 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  5. callbacks/helper_test.go

    			input: map[string]interface{}{
    				"active": true,
    			},
    			expect: clause.Values{
    				Columns: []clause.Column{{Name: "active"}},
    				Values:  [][]interface{}{{true}},
    			},
    		},
    	}
    
    	for _, tc := range testCase {
    		t.Run(tc.name, func(t *testing.T) {
    			actual := ConvertMapToValuesForCreate(&gorm.Statement{}, tc.input)
    			if !reflect.DeepEqual(actual, tc.expect) {
    				t.Errorf("expect %v got %v", tc.expect, actual)
    			}
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Mar 05 02:22:57 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    		}
    
    		versioned := vcfg != nil && vcfg.Versioned(item.objectPath())
    		objInfos := make([]ObjectInfo, len(fivs.Versions))
    		for i, fi := range fivs.Versions {
    			objInfos[i] = fi.ToObjectInfo(item.bucket, item.objectPath(), versioned)
    		}
    		sizeS := sizeSummary{}
    		for _, tier := range globalTierConfigMgr.ListTiers() {
    			if sizeS.tiers == nil {
    				sizeS.tiers = make(map[string]tierStats)
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  7. src/archive/tar/strconv.go

    func isASCII(s string) bool {
    	for _, c := range s {
    		if c >= 0x80 || c == 0x00 {
    			return false
    		}
    	}
    	return true
    }
    
    // toASCII converts the input to an ASCII C-style string.
    // This is a best effort conversion, so invalid characters are dropped.
    func toASCII(s string) string {
    	if isASCII(s) {
    		return s
    	}
    	b := make([]byte, 0, len(s))
    	for _, c := range s {
    		if c < 0x80 && c != 0x00 {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Sep 08 17:08:20 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  8. src/archive/zip/reader_test.go

    	}
    
    	// test read of each file
    	for i, ft := range zt.File {
    		readTestFile(t, zt, ft, z.File[i], raw)
    	}
    	if t.Failed() {
    		return
    	}
    
    	// test simultaneous reads
    	n := 0
    	done := make(chan bool)
    	for i := 0; i < 5; i++ {
    		for j, ft := range zt.File {
    			go func(j int, ft ZipTestFile) {
    				readTestFile(t, zt, ft, z.File[j], raw)
    				done <- true
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Mar 11 22:19:38 UTC 2025
    - 56.6K bytes
    - Viewed (0)
  9. cmd/server-startup-msg.go

    	if len(apiEndpoints) == 1 {
    		return apiEndpoints
    	}
    	newAPIEndpoints = make([]string, len(apiEndpoints))
    	// Check all API endpoints for standard ports and strip them.
    	for i, apiEndpoint := range apiEndpoints {
    		_, err := xnet.ParseHTTPURL(apiEndpoint)
    		if err != nil {
    			continue
    		}
    		u, err := url.Parse(apiEndpoint)
    		if err != nil {
    			continue
    		}
    		if host == "" && isIPv6(u.Hostname()) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  10. cmd/common-main_test.go

    		expectedValue string
    	}{
    		{
    			"value\n",
    			false,
    			"value",
    		},
    		{
    			" \t\n Hello, Gophers \n\t\r\n",
    			false,
    			"Hello, Gophers",
    		},
    	}
    
    	for _, testCase := range testCases {
    		t.Run("", func(t *testing.T) {
    			tmpfile, err := os.CreateTemp(t.TempDir(), "testfile")
    			if err != nil {
    				t.Error(err)
    			}
    			tmpfile.WriteString(testCase.content)
    			tmpfile.Sync()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.7K bytes
    - Viewed (0)
Back to top