- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 449 for reading_ (0.17 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
timeout().clearDeadline() } else { timeout().deadlineNanoTime(nowNs + originalDurationNs) } } } /** * Attempts to exhaust this, returning true if successful. This is useful when reading a complete * source is helpful, such as when doing so completes a cache body or frees a socket connection for * reuse. */ internal fun Source.discard( timeout: Int, timeUnit: TimeUnit, ): Boolean =
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon May 13 13:42:37 UTC 2024 - 10.7K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/DefaultModelProcessor.java
* * This is because the ModelProcessor interface extends ModelLocator and ModelReader. If we * made this component available under all its interfaces then it could end up being injected * into itself leading to a stack overflow. * * A side effect of using @Typed is that it translates to explicit bindings in the container. * So instead of binding the component under a 'wildcard' key it is now bound with an explicit
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
"timeout", "Read timed out", ) assertThat(webSocket.close(1000, null)).isFalse() } /** * There's no read timeout when reading the first byte of a new frame. But as soon as we start * reading a frame we enable the read timeout. In this test we have the server returning the first * byte of a frame but no more frames. */ @Test fun readTimeoutAppliesWithinFrames() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0) -
src/main/resources/fess_message_ru.properties
errors.failed_to_upload_mapping_file=Failed to upload the Mapping file. errors.invalid_kuromoji_token={0} is invalid. errors.invalid_kuromoji_segmentation=The number of segmentations {0} does not the match number of readings {1}. errors.invalid_str_is_included="{1}" in "{0}" is invalid. errors.blank_password=Password is required. errors.invalid_confirm_password=Confirm Password does not match.
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri May 20 12:12:28 UTC 2022 - 10.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
frame.writeInt(expectedStreamId and 0x7fffffff) frame.writeAll(headerBlock) // Check writer sends the same bytes. assertThat(sendHeaderFrames(false, sentHeaders)).isEqualTo(frame) // Reading the above frames should result in a concatenated headerBlock. reader.nextFrame( requireSettings = false, object : BaseTestHandler() { override fun headers( inFinished: Boolean,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 28.1K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// The s3ChunkedReader returns io.EOF when the final 0-length chunk is read. // // NewChunkedReader is not needed by normal applications. The http package // automatically decodes chunking when reading response bodies. func newSignV4ChunkedReader(req *http.Request, trailer bool) (io.ReadCloser, APIErrorCode) { cred, seedSignature, region, seedDate, errCode := calculateSeedSignature(req, trailer) if errCode != ErrNone {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 18.2K bytes - Viewed (0) -
cmd/batch-expire_gen.go
if err != nil { err = msgp.WrapError(err, "Purge") return } switch msgp.UnsafeString(field) { case "RetainVersions": z.Purge.RetainVersions, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Purge", "RetainVersions") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err, "Purge")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 01 12:53:30 UTC 2024 - 19.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
return null // Another edit is in progress. } if (entry != null && entry.lockingSourceCount != 0) { return null // We can't write this file because a reader is still reading it. } if (mostRecentTrimFailed || mostRecentRebuildFailed) { // The OS has become our enemy! If the trim job failed, it means we are storing more data than
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 34.7K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
} // Target - Kafka target. type Target struct { status int32 totalMessages int64 failedMessages int64 wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/erasure-coding.go
lastShardSize := ceilFrac(lastBlockSize, int64(e.dataBlocks)) return numShards*e.ShardSize() + lastShardSize } // ShardFileOffset - returns the effective offset where erasure reading begins. func (e *Erasure) ShardFileOffset(startOffset, length, totalLength int64) int64 { shardSize := e.ShardSize() shardFileSize := e.ShardFileSize(totalLength) endShard := (startOffset + length) / e.blockSize
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 8.6K bytes - Viewed (0)