- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 123 for peek (0.15 sec)
-
src/test/java/jcifs/tests/RandomAccessFileTest.java
try ( SmbRandomAccessFile raf = new SmbRandomAccessFile(f, "r") ) { raf.seek(10); Assert.assertEquals(-1, raf.read()); } byte[] buf = new byte[4]; try ( SmbRandomAccessFile raf = new SmbRandomAccessFile(f, "r") ) { raf.seek(6); Assert.assertEquals(2, raf.read(buf));
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 11.4K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
} func (rx *XferStats) merge(o XferStats) XferStats { curr := calcAvg(rx.curr(), o.curr(), rx.N, o.N) peak := rx.Peak if o.Peak > peak { peak = o.Peak } if curr > peak { peak = curr } return XferStats{ Avg: calcAvg(rx.Avg, o.Avg, rx.N, o.N), Peak: peak, Curr: curr, measure: rx.measure, N: rx.N + o.N, } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
} private fun connectHttp2( peer: MockHttp2Peer, realConnection: RealConnection, maxConcurrentStreams: Int, ): Http2Connection { // Write the mocking script. val settings1 = Settings() settings1[Settings.MAX_CONCURRENT_STREAMS] = maxConcurrentStreams peer.sendFrame().settings(settings1) peer.acceptFrame() // ACK peer.sendFrame().ping(false, 2, 0)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
.teamcity/performance-tests-ci.json
"per_week" : [ "linux" ] } }, { "testProject" : "mediumMonolithicJavaProject", "coverage" : { "per_week" : [ "linux" ] } } ] }, { "testId" : "org.gradle.performance.experiment.maven.JavaTestGradleVsMavenPerformanceTest.clean test (Gradle vs Maven)", "groups" : [ { "testProject" : "mediumJavaMultiProject", "coverage" : { "per_week" : [ "linux" ]
Json - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Mon May 06 09:01:23 GMT 2024 - 35.5K bytes - Viewed (0) -
cmd/bucket-stats.go
totPeak = math.Max(math.Max(v.XferRateLrg.Peak, v.XferRateSml.Peak), totPeak) totPeak = math.Max(math.Max(lcurrTgt, scurrTgt), totPeak) tcount := 0 if v.XferRateLrg.Peak > 0 { tcount++ } if v.XferRateSml.Peak > 0 { tcount++ } qs.TgtXferStats[arn][Large] = XferStats{ Avg: v.XferRateLrg.Avg, Curr: lcurrTgt, Peak: math.Max(v.XferRateLrg.Peak, lcurrTgt), }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
src/archive/tar/reader.go
// io.Seeker, but calling Seek always returns an error and performs // no action. Thus, we try an innocent seek to the current position // to see if Seek is really supported. pos1, err := sr.Seek(0, io.SeekCurrent) if pos1 >= 0 && err == nil { // Seek seems supported, so perform the real Seek. pos2, err := sr.Seek(n-1, io.SeekCurrent) if pos2 < 0 || err != nil { return err
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
// ConnectionPool. taskRunner.newQueue().execute(name = connectionName, block = readerRunnable) } /** Merges [settings] into this peer's settings and sends them to the remote peer. */ @Throws(IOException::class) fun setSettings(settings: Settings) { writer.withLock { this.withLock { if (isShutdown) { throw ConnectionShutdownException()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
cmd/endpoint.go
} // FindGridHostsFromPeerStr will return a matching peer from provided peer (as string) func (l EndpointServerPools) FindGridHostsFromPeerStr(peer string) (peerGrid string) { if peer == "" { return "" } for _, ep := range l { for _, endpoint := range ep.Endpoints { if endpoint.IsLocal { continue } if endpoint.Host == peer { return endpoint.GridHost() } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
fun writeTimeout(): Timeout = writeTimeout /** Returns a source that reads data from the peer. */ fun getSource(): Source = source /** * Returns a sink that can be used to write data to the peer. * * @throws IllegalStateException if this stream was initiated by the peer and a [writeHeaders] has * not yet been sent. */ fun getSink(): Sink { this.withLock {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
cmd/perf-tests.go
// RXSample holds the RX bytes for the duration between // the last peer to connect and the first peer to disconnect. // This is to improve the RX throughput accuracy. type netPerfRX struct { RX uint64 // RX bytes lastToConnect time.Time // time at which last peer to connect to us firstToDisconnect time.Time // time at which the first peer disconnects from us
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0)