Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 510 for locks (0.04 sec)

  1. internal/disk/stat_solaris.go

    	s := unix.Statvfs_t{}
    	if err = unix.Statvfs(path, &s); err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := uint64(s.Bfree) - uint64(s.Bavail)
    	info = Info{
    		Total:  uint64(s.Frsize) * (uint64(s.Blocks) - reservedBlocks),
    		Free:   uint64(s.Frsize) * uint64(s.Bavail),
    		Files:  uint64(s.Files),
    		Ffree:  uint64(s.Ffree),
    		FSType: getFSType(s.Fstr[:]),
    	}
    	if info.Free > info.Total {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  2. internal/bucket/bandwidth/monitor.go

    			return
    		}
    	}
    }
    
    func (m *Monitor) updateMovingAvg() {
    	m.mlock.Lock()
    	defer m.mlock.Unlock()
    	for _, bucketMeasurement := range m.bucketsMeasurement {
    		bucketMeasurement.updateExponentialMovingAverage(time.Now())
    	}
    }
    
    func (m *Monitor) init(opts BucketOptions) {
    	m.mlock.Lock()
    	defer m.mlock.Unlock()
    
    	_, ok := m.bucketsMeasurement[opts]
    	if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  3. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BlocksRenderer.java

            parent.appendChild(summarySection);
    
            Element title = document.createElement("title");
            summarySection.appendChild(title);
            title.appendChild(document.createTextNode("Script blocks"));
    
            Collection<BlockDoc> classBlocks = classDoc.getClassBlocks();
            if (!classBlocks.isEmpty()) {
                Element table = document.createElement("table");
                summarySection.appendChild(table);
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 4K bytes
    - Viewed (0)
  4. cmd/auth-handler.go

    	if cred.AccessKey == "" {
    		return ErrAccessDenied
    	}
    
    	conditions := getConditionValues(r, "", cred)
    	conditions["object-lock-mode"] = []string{string(retMode)}
    	conditions["object-lock-retain-until-date"] = []string{retDate.UTC().Format(time.RFC3339)}
    	if retDays > 0 {
    		conditions["object-lock-remaining-retention-days"] = []string{strconv.Itoa(retDays)}
    	}
    	if retMode == objectlock.RetGovernance && byPassSet {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  5. internal/disk/stat_bsd.go

    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := s.Bfree - s.Bavail
    	info = Info{
    		Total:  uint64(s.Bsize) * (s.Blocks - reservedBlocks),
    		Free:   uint64(s.Bsize) * s.Bavail,
    		Files:  s.Files,
    		Ffree:  s.Ffree,
    		FSType: getFSType(s.Fstypename[:]),
    	}
    	if info.Free > info.Total {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/hash/BloomFilterStrategies.java

            if (!bits.get(combinedHash % bitSize)) {
              return false;
            }
          }
          return true;
        }
      },
      /**
       * This strategy uses all 128 bits of {@link Hashing#murmur3_128} when hashing. It looks different
       * from the implementation in MURMUR128_MITZ_32 because we're avoiding the multiplication in the
       * loop and doing a (much simpler) += hash2. We're also changing the index to a positive number by
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 10 19:45:10 UTC 2022
    - 10.7K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/measurement.go

    func (m *bucketMeasurement) updateExponentialMovingAverage(endTime time.Time) {
    	// 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)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 03 20:41:51 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  8. internal/disk/stat_linux_s390x.go

    	s := syscall.Statfs_t{}
    	err = syscall.Statfs(path, &s)
    	if err != nil {
    		return Info{}, err
    	}
    	reservedBlocks := s.Bfree - s.Bavail
    	info = Info{
    		Total:  uint64(s.Frsize) * (s.Blocks - reservedBlocks),
    		Free:   uint64(s.Frsize) * s.Bavail,
    		Files:  s.Files,
    		Ffree:  s.Ffree,
    		FSType: getFSType(s.Type),
    	}
    	// Check for overflows.
    	// https://github.com/minio/minio/issues/8035
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. common/config/sass-lint.yml

        - 2
        -
          include: false
      bem-depth: 2
      border-zero: 2
      brace-style: 2
      class-name-format: 2
      clean-import-paths: 2
      declarations-before-nesting: 2
      empty-args: 2
      empty-line-between-blocks: 2
      extends-before-declarations: 2
      extends-before-mixins: 2
      final-newline: 2
      force-attribute-nesting: 0
      force-element-nesting: 0
      force-pseudo-nesting: 0
      function-name-format: 2
      hex-length: 0
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 11 23:32:21 UTC 2019
    - 2K bytes
    - Viewed (0)
  10. internal/ringbuffer/ring_buffer.go

    	// ErrIsNotEmpty is returned when the buffer is not empty and not blocking.
    	ErrIsNotEmpty = errors.New("ringbuffer is not empty")
    
    	// ErrAcquireLock is returned when the lock is not acquired on Try operations.
    	ErrAcquireLock = errors.New("unable to acquire lock")
    
    	// ErrWriteOnClosed is returned when write on a closed ringbuffer.
    	ErrWriteOnClosed = errors.New("write on closed ringbuffer")
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
Back to top