- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 329 for recorded (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)