- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 143 for recorded (0.08 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
TaskRunner::class.java.name -> recordTaskRunner Http2::class.java.name -> recordFrames "javax.net.ssl" -> recordSslDebug && !sslExcludeFilter.matches(record.message) else -> false } if (recorded) { synchronized(clientEventsList) { clientEventsList.add(record.message) if (record.loggerName == "javax.net.ssl") {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K 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) -
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) -
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) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
randomAccessFile.setLength(0L) result.writeHeader(PREFIX_DIRTY, -1L, -1L) return result } /** * Creates a relay that reads a recorded stream from [file]. * * **Warning:** callers to this method must immediately call [newSource] to create a source and * close that when they're done. Otherwise a handle to [file] will be leaked. */
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.8K bytes - Viewed (0) -
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) -
android/guava/src/com/google/common/base/Ascii.java
* RS, and US is least inclusive. (The content and length of a File, Group, Record, or Unit are * not specified.) * * @since 8.0 */ public static final byte GS = 29; /** * Record Separator: These four information separators may be used within data in optional
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Aug 02 13:50:22 UTC 2024 - 21.7K bytes - Viewed (0) -
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) -
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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 12.7K bytes - Viewed (0)