Search Options

Results per page
Sort
Preferred Languages
Advance

Results 461 - 470 of 812 for segons (0.07 sec)

  1. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

      private lateinit var client: OkHttpClient
    
      val listener = RecordingEventListener()
    
      fun setUp(mode: Pair<CancelMode, ConnectionType>) {
        this.cancelMode = mode.first
        this.connectionType = mode.second
    
        if (connectionType == H2) {
          platform.assumeHttp2Support()
        }
    
        // Sockets on some platforms can have large buffers that mean writes do not block when
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

                if (exitValue != 0) {
                    final StringBuilder out = new StringBuilder();
                    if (processTimeout) {
                        out.append("Process is terminated due to ").append(timeout).append(" second exceeded.\n");
                    }
                    out.append("Exit Code: ").append(exitValue).append("\nOutput:\n").append(it.getOutput());
                    throw new JobProcessingException(out.toString());
                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/job/SuggestJob.java

                if (exitValue != 0) {
                    final StringBuilder out = new StringBuilder();
                    if (processTimeout) {
                        out.append("Process is terminated due to ").append(timeout).append(" second exceeded.\n");
                    }
                    out.append("Exit Code: ").append(exitValue).append("\nOutput:\n").append(it.getOutput());
                    throw new JobProcessingException(out.toString());
                }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sun Jun 23 04:13:47 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/collect/PeekingIteratorTest.java

        /* Should recover to be able to remove() after next(). */
        assertEquals("B", peekingIterator.next());
        peekingIterator.remove();
        assertEquals("Should have removed an element", 2, list.size());
        assertFalse("Second element should be gone", list.contains("B"));
      }
    
      static class ThrowsAtEndException extends RuntimeException {
        /* nothing */
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/primitives/SignedBytes.java

       * that of {@code ((Byte) a).compareTo(b)}.
       *
       * <p><b>Note:</b> this method behaves identically to {@link Byte#compare}.
       *
       * @param a the first {@code byte} to compare
       * @param b the second {@code byte} to compare
       * @return a negative value if {@code a} is less than {@code b}; a positive value if {@code a} is
       *     greater than {@code b}; or zero if they are equal
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. tests/embedded_struct_test.go

    		t.Errorf("Should find correct value for embedded pointer type")
    	}
    
    	if hnPost.Author != nil {
    		t.Errorf("Expected to get back a nil Author but got: %v", hnPost.Author)
    	}
    
    	now := time.Now().Round(time.Second)
    	NewPost := HNPost{
    		BasePost: &BasePost{Title: "embedded_pointer_type2"},
    		Author: &Author{
    			Name:        "test",
    			Content:     Content{"test"},
    			ContentPtr:  nil,
    			Birthday:    now,
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/LegacyLocalRepositoryManager.java

             * into a repository. In the first case, the result needs to be a proper local repository that one can use for
             * local artifact resolution. In the second case, the result needs to precisely obey the path information of the
             * repository's layout to allow pointing at artifacts within the repository. Unfortunately,
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  8. internal/event/target/redis.go

    			return nil, fmt.Errorf("unable to initialize the queue store of Redis `%s`: %w", id, err)
    		}
    	}
    
    	pool := &redis.Pool{
    		MaxIdle:     3,
    		IdleTimeout: 2 * 60 * time.Second,
    		Dial: func() (redis.Conn, error) {
    			conn, err := redis.Dial("tcp", args.Addr.String())
    			if err != nil {
    				return nil, err
    			}
    
    			if args.Password != "" {
    				if args.User != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  9. 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)
  10. okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt

          "ConnectionAcquired",
          "ConnectionReleased",
        )
      }
    
      @Test
      fun failedCallEventSequence() {
        server!!.enqueue(
          MockResponse.Builder()
            .headersDelay(2, TimeUnit.SECONDS)
            .build(),
        )
        client =
          client.newBuilder()
            .readTimeout(Duration.ofMillis(250))
            .build()
        val call =
          client.newCall(
            Request.Builder()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.6K bytes
    - Viewed (0)
Back to top