Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 49 for recordRead (0.06 seconds)

  1. cmd/utils.go

    // profilerWrapper is created because pkg/profiler doesn't
    // provide any API to calculate the profiler file path in the
    // disk since the name of this latter is randomly generated.
    type profilerWrapper struct {
    	// Profile recorded at start of benchmark.
    	records map[string][]byte
    	stopFn  func() ([]byte, error)
    	ext     string
    }
    
    // record will record the profile and store it as the base.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

      }
    
      public void testServiceStartupTimes_selfStartingServices() {
        // This tests to ensure that:
        // 1. service times are accurate when the service is started by the manager
        // 2. service times are recorded when the service is not started by the manager (but they may
        // not be accurate).
        Service b =
            new NoOpDelayedService(353) {
              @Override
              protected void doStart() {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 25.5K bytes
    - Click Count (0)
  3. cmd/bucket-stats.go

    	minutes := time.Now().Unix() / 60
    	l.forwardTo(minutes)
    	winIdx := minutes % 60
    	l.Totals[winIdx].merge(AccElem{Total: minutes, Size: sz, N: 1})
    	l.LastMin = minutes
    }
    
    // Merge all recorded counts of last hour into one
    func (l *ReplicationLastHour) getTotal() AccElem {
    	var res AccElem
    	minutes := time.Now().Unix() / 60
    	l.forwardTo(minutes)
    	for _, elem := range l.Totals[:] {
    		res.merge(elem)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  4. src/archive/tar/strconv.go

    	}
    	copy(b, s)
    	if len(s) < len(b) {
    		b[len(s)] = 0
    	}
    
    	// Some buggy readers treat regular files with a trailing slash
    	// in the V7 path field as a directory even though the full path
    	// recorded elsewhere (e.g., via PAX record) contains no trailing slash.
    	if len(s) > len(b) && b[len(b)-1] == '/' {
    		n := len(strings.TrimRight(s[:len(b)-1], "/"))
    		b[n] = 0 // Replace trailing slash with NUL terminator
    	}
    }
    
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Sep 08 17:08:20 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/cache/Cache.java

       * created using {@link CacheBuilder} only does so if the {@link CacheBuilder#recordStats} method
       * was called. If statistics are not being recorded, a {@code CacheStats} instance with zero for
       * all values is returned.
       *
       */
      CacheStats stats();
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8.3K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      /**
       * Records an exception so that it can be rethrown later in the test harness thread, triggering a
       * test case failure. Only the first failure is recorded; subsequent calls to this method from
       * within the same test have no effect.
       */
      public void threadRecordFailure(Throwable t) {
        threadFailure.compareAndSet(null, t);
      }
    
      @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 37.8K bytes
    - Click Count (0)
  7. cmd/http-stats.go

    	if stats == nil {
    		return 0
    	}
    
    	stats.RLock()
    	defer stats.RUnlock()
    
    	val, ok := stats.apiStats[api]
    	if ok {
    		return val
    	}
    
    	return 0
    }
    
    // Load returns the recorded stats.
    func (stats *HTTPAPIStats) Load(toLower bool) map[string]int {
    	if stats == nil {
    		return map[string]int{}
    	}
    
    	stats.RLock()
    	defer stats.RUnlock()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Sep 24 17:13:00 GMT 2024
    - 11.4K bytes
    - Click Count (0)
  8. cmd/metacache-server-pool.go

    			saveCh <- entry
    		}
    		if !returned {
    			xioutil.SafeClose(outCh)
    		}
    		xioutil.SafeClose(saveCh)
    	}()
    
    	entries, err = filteredResults()
    	if err == nil {
    		// Check if listing recorded an error.
    		err = meta.getErr()
    	}
    	return entries, err
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/base/Ascii.java

      /**
       * End of Medium: A control character associated with the sent data which may be used to identify
       * the physical end of the medium, or the end of the used, or wanted, portion of information
       * recorded on a medium. (The position of this character does not necessarily correspond to the
       * physical end of the medium.)
       *
       * @since 8.0
       */
      public static final byte EM = 25;
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  10. src/archive/tar/writer.go

    			paxHdrs[paxGNUSparseName] = realName
    			paxHdrs[paxGNUSparseRealSize] = strconv.FormatInt(realSize, 10)
    			paxHdrs[paxSize] = strconv.FormatInt(hdr.Size, 10)
    			delete(paxHdrs, paxPath) // Recorded by paxGNUSparseName
    		}
    	*/
    	_ = realSize
    
    	// Write PAX records to the output.
    	isGlobal := hdr.Typeflag == TypeXGlobalHeader
    	if len(paxHdrs) > 0 || isGlobal {
    		// Write each record to a buffer.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Feb 03 16:38:43 GMT 2025
    - 19.7K bytes
    - Click Count (0)
Back to Top