Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 123 for recorded (0.08 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

        Formatter logFormatter =
            new Formatter() {
              @Override
              public String format(LogRecord record) {
                return formatMessage(record);
              }
            };
        for (LogRecord record : logHandler.getStoredLogRecords()) {
          assertThat(logFormatter.format(record)).doesNotContain("NoOpService");
        }
      }
    
      public void testStartupFailureOutput() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  2. cmd/bucket-stats.go

    	min := time.Now().Unix() / 60
    	l.forwardTo(min)
    	winIdx := min % 60
    	l.Totals[winIdx].merge(AccElem{Total: min, Size: sz, N: 1})
    	l.LastMin = min
    }
    
    // Merge all recorded counts of last hour into one
    func (l *ReplicationLastHour) getTotal() AccElem {
    	var res AccElem
    	min := time.Now().Unix() / 60
    	l.forwardTo(min)
    	for _, elem := range l.Totals[:] {
    		res.merge(elem)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      private final AtomicReference<Throwable> threadFailure = new AtomicReference<>(null);
    
      /**
       * 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) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  4. cmd/http-stats.go

    			totalS35xxErrors:  &HTTPAPIStats{},
    		}
    	}
    
    	if w == nil { // when response recorder nil, this is an active request
    		hstats.currentS3Requests.Inc(api)
    		bh.httpStats[bucket] = hstats
    		return
    	} // else {
    	hstats.currentS3Requests.Dec(api) // decrement this once we have the response recorder.
    
    	hstats.totalS3Requests.Inc(api)
    	code := w.StatusCode
    
    	switch {
    	case code == 0:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      private final AtomicReference<Throwable> threadFailure = new AtomicReference<>(null);
    
      /**
       * 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) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 37.9K bytes
    - Viewed (0)
  6. src/archive/tar/writer.go

    			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.
    		var buf strings.Builder
    		// Sort keys for deterministic ordering.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  7. cmd/object-handlers_test.go

    	err = decoder.Decode(multipartResponse)
    	if err != nil {
    		t.Fatalf("Error decoding the recorded response Body")
    	}
    	uploadID := multipartResponse.UploadID
    
    	a := 0
    	b := globalMinPartSize
    	var parts []CompletePart
    	for partNumber := 1; partNumber <= 2; partNumber++ {
    		// initialize HTTP NewRecorder, this records any mutations to response writer inside the handler.
    		rec := httptest.NewRecorder()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/cache/CacheBuilder.java

       * of this method requires a corresponding call to {@link #maximumWeight(long)} prior to calling
       * {@link #build}. Weights are measured and recorded when entries are inserted into the cache, and
       * are thus effectively static during the lifetime of a cache entry.
       *
       * <p>When the weight of an entry is zero it will not be considered for size-based eviction
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  9. cmd/data-usage-cache.go

    	root := d.find(path)
    	if root == nil || len(root.Children) == 0 {
    		return root
    	}
    	flat := d.flatten(*root)
    	return &flat
    }
    
    // totalChildrenRec returns the total number of children recorded.
    func (d *dataUsageCache) totalChildrenRec(path string) int {
    	root := d.find(path)
    	if root == nil || len(root.Children) == 0 {
    		return 0
    	}
    	n := len(root.Children)
    	for ch := range root.Children {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  10. src/bytes/bytes.go

    			if start < 0 {
    				start = i
    			}
    		}
    		i += size
    	}
    
    	// Last field might end at EOF.
    	if start >= 0 {
    		spans = append(spans, span{start, len(s)})
    	}
    
    	// Create subslices from recorded field indices.
    	a := make([][]byte, len(spans))
    	for i, span := range spans {
    		a[i] = s[span.start:span.end:span.end]
    	}
    
    	return a
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 35.6K bytes
    - Viewed (0)
Back to top