Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 329 for recorded (0.07 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
      fun <T : ConnectionEvent> removeUpToEvent(eventClass: Class<T>): T {
        val fullEventSequence = eventSequence.toList()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. cmd/utils.go

    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.
    func (p *profilerWrapper) record(profileType string, debug int, recordName string) {
    	var buf bytes.Buffer
    	if p.records == nil {
    		p.records = make(map[string][]byte)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/RecordedResponse.kt

    import assertk.assertions.isNull
    import assertk.assertions.isTrue
    import java.io.IOException
    import java.text.SimpleDateFormat
    import java.util.Date
    
    /**
     * A received response or failure recorded by the response recorder.
     */
    class RecordedResponse(
      @JvmField val request: Request,
      val response: Response?,
      val webSocket: WebSocket?,
      val body: String?,
      val failure: IOException?,
    ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt

       * multiple requests, each request is assigned its own sequence number.
       */
      val sequenceNumber: Int,
      socket: Socket,
      /**
       * The failure MockWebServer recorded when attempting to decode this request. If, for example,
       * the inbound request was truncated, this exception will be non-null.
       */
      val failure: IOException? = null,
    ) {
      val method: String?
      val path: String?
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. 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)
  6. 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();
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Aug 07 02:38:22 UTC 2022
    - 7.9K bytes
    - Viewed (0)
  7. src/archive/tar/strconv.go

    	if len(record) != size {
    		size = len(record)
    		record = strconv.Itoa(size) + " " + k + "=" + v + "\n"
    	}
    	return record, nil
    }
    
    // validPAXRecord reports whether the key-value pair is valid where each
    // record is formatted as:
    //
    //	"%d %s=%s\n" % (size, key, value)
    //
    // Keys and values should be UTF-8, but the number of bad writers out there
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 01 14:28:42 UTC 2023
    - 9K bytes
    - Viewed (0)
  8. cmd/last-minute.go

    }
    
    // Add  a new duration data
    func (l *lastMinuteLatency) addAll(sec int64, a AccElem) {
    	l.forwardTo(sec)
    	winIdx := sec % 60
    	l.Totals[winIdx].merge(a)
    	l.LastSec = sec
    }
    
    // Merge all recorded latencies of last minute into one
    func (l *lastMinuteLatency) getTotal() AccElem {
    	var res AccElem
    	sec := time.Now().Unix()
    	l.forwardTo(sec)
    	for _, elem := range l.Totals[:] {
    		res.merge(elem)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 05 17:40:45 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top