Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1151 - 1160 of 1,361 for before (0.53 seconds)

  1. cmd/peer-s3-server.go

    		SetCount:  -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    	// mutate only if not a dry-run
    	if opts.DryRun {
    		return res, nil
    	}
    
    	for i := range beforeState {
    		res.Before.Drives = append(res.Before.Drives, madmin.HealDriveInfo{
    			UUID:     "",
    			Endpoint: localDrives[i].Endpoint().String(),
    			State:    beforeState[i],
    		})
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/MapMakerInternalMap.java

      /** Number of (unsynchronized) retries in the containsValue method. */
      static final int CONTAINS_VALUE_RETRIES = 3;
    
      /**
       * Number of cache access operations that can be buffered per segment before the cache's recency
       * ordering information is updated. This is used to avoid lock contention by recording a memento
       * of reads and delaying a lock acquisition until the threshold is crossed or a mutation occurs.
       *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 89.9K bytes
    - Click Count (0)
  3. cmd/erasure-multipart.go

    			Initiated: startTime,
    		})
    		populatedUploadIDs.Add(uploadID)
    	}
    
    	sort.Slice(uploads, func(i int, j int) bool {
    		return uploads[i].Initiated.Before(uploads[j].Initiated)
    	})
    
    	uploadIndex := 0
    	if uploadIDMarker != "" {
    		for uploadIndex < len(uploads) {
    			if uploads[uploadIndex].UploadID != uploadIDMarker {
    				uploadIndex++
    				continue
    			}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  4. src/archive/tar/writer_test.go

    	// Simple test to make sure PAX extensions are in effect
    	if !bytes.Contains(buf.Bytes(), []byte("PaxHeaders.0")) {
    		t.Fatal("Expected at least one PAX header to be written.")
    	}
    
    	// xattr bar should always appear before others
    	indices := []int{
    		bytes.Index(buf.Bytes(), []byte("bar=bar")),
    		bytes.Index(buf.Bytes(), []byte("baz=baz")),
    		bytes.Index(buf.Bytes(), []byte("foo=foo")),
    		bytes.Index(buf.Bytes(), []byte("qux=qux")),
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 15 16:34:13 GMT 2025
    - 40.2K bytes
    - Click Count (0)
  5. docs/ko/docs/deployment/docker.md

    **컨테이너당 여러 프로세스**를 실행한다면, 시작되는 프로세스 수가 사용 가능한 것보다 **더 많은 메모리를 소비하지** 않는지 확인해야 합니다.
    
    ## 시작 전 단계와 컨테이너 { #previous-steps-before-starting-and-containers }
    
    컨테이너(예: Docker, Kubernetes)를 사용한다면, 사용할 수 있는 주요 접근 방식은 두 가지입니다.
    
    ### 여러 컨테이너 { #multiple-containers }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:06:26 GMT 2026
    - 32.6K bytes
    - Click Count (0)
  6. src/cmd/api/main_test.go

    	}
    
    	f, err := parser.ParseFile(fset, filename, nil, parser.ParseComments)
    	if err != nil {
    		return nil, err
    	}
    	parsedFileCache[filename] = f
    
    	return f, nil
    }
    
    // Disable before debugging non-obvious errors from the type-checker.
    const usePkgCache = true
    
    var (
    	pkgCache = map[string]*apiPackage{} // map tagKey to package
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Mar 02 13:20:41 GMT 2026
    - 31.4K bytes
    - Click Count (0)
  7. internal/bucket/bandwidth/measurement.go

    	// Calculate aggregate avg bandwidth and exp window avg
    	m.lock.Lock()
    	defer func() {
    		m.startTime = endTime
    		m.lock.Unlock()
    	}()
    
    	if m.startTime.IsZero() {
    		return
    	}
    
    	if endTime.Before(m.startTime) {
    		return
    	}
    
    	duration := endTime.Sub(m.startTime)
    
    	bytesSinceLastWindow := atomic.SwapUint64(&m.bytesSinceLastWindow, 0)
    
    	if m.expMovingAvg == 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Jun 03 20:41:51 GMT 2023
    - 2.9K bytes
    - Click Count (0)
  8. src/archive/zip/reader.go

    		if readDirectoryHeader(&File{}, rs) == nil {
    			baseOffset = 0
    		}
    	}
    
    	return d, baseOffset, nil
    }
    
    // findDirectory64End tries to read the zip64 locator just before the
    // directory end and returns the offset of the zip64 directory end if
    // found.
    func findDirectory64End(r io.ReaderAt, directoryEndOffset int64) (int64, error) {
    	locOffset := directoryEndOffset - directory64LocLen
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Jan 15 18:35:56 GMT 2026
    - 28.5K bytes
    - Click Count (0)
  9. src/archive/zip/reader_test.go

    			{
    				Name:     "readonly",
    				Content:  []byte("important \r\n"),
    				Modified: time.Date(2011, 12, 8, 10, 6, 8, 0, timeZone(0)),
    				Mode:     0444,
    			},
    		},
    	},
    	{
    		// created by Go, before we wrote the "optional" data
    		// descriptor signatures (which are required by macOS).
    		// Use obscured file to avoid Apple’s notarization service
    		// rejecting the toolchain due to an inability to unzip this archive.
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Jan 15 18:35:56 GMT 2026
    - 57.9K bytes
    - Click Count (0)
  10. cmd/xl-storage-disk-id-check.go

    	return p.storage.ReadParts(ctx, volume, partMetaPaths...)
    }
    
    // ReadMultiple will read multiple files and send each files as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context will return an error.
    func (p *xlStorageDiskIDCheck) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) (err error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
Back to Top