Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 449 for reading_ (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top