Search Options

Results per page
Sort
Preferred Languages
Advance

Results 801 - 810 of 1,555 for readn (0.03 sec)

  1. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        clientListener.assertFailure(
          SocketTimeoutException::class.java,
          "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.
       */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  2. .github/workflows/replication.yaml

    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      replication-test:
        name: Advanced Tests with Go ${{ matrix.go-version }}
        runs-on: ubuntu-latest
    
        strategy:
          matrix:
            go-version: [1.22.x]
    
        steps:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  3. tests/test_tutorial/test_response_model/test_tutorial004_py310.py

                                        }
                                    }
                                },
                            },
                        },
                        "summary": "Read Item",
                        "operationId": "read_item_items__item_id__get",
                        "parameters": [
                            {
                                "required": True,
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Aug 04 20:47:07 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  4. okhttp-logging-interceptor/src/test/java/okhttp3/logging/LoggingEventListenerTest.kt

            ),
          )
          .assertLogMatch(
            Regex(
              """callFailed: \S+(?:SSLProtocolException|SSLHandshakeException|TlsFatalAlert): (?:Unexpected handshake message: client_hello|Handshake message sequence violation, 1|Read error|Handshake failed|unexpected_message\(10\)).*""",
            ),
          )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Jan 14 10:20:09 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/CompactHashing.java

       */
      static int tableGet(Object table, int index) {
        if (table instanceof byte[]) {
          return ((byte[]) table)[index] & BYTE_MASK; // unsigned read
        } else if (table instanceof short[]) {
          return ((short[]) table)[index] & SHORT_MASK; // unsigned read
        } else {
          return ((int[]) table)[index];
        }
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 15:34:52 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/base/Utf8.java

       * isWellFormed(bytes)} is true.
       *
       * @param bytes the input buffer
       * @param off the offset in the buffer of the first byte to read
       * @param len the number of bytes to read from the buffer
       */
      public static boolean isWellFormed(byte[] bytes, int off, int len) {
        int end = off + len;
        checkPositionIndexes(off, end, bytes.length);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 7K bytes
    - Viewed (0)
  7. cmd/erasure-metadata-utils_test.go

    	for x := 1; x < 17; x++ {
    		t.Run(fmt.Sprintf("%d", x), func(t *testing.T) {
    			var first [17]int
    			rng := rand.New(rand.NewSource(0))
    			var tmp [16]byte
    			rng.Read(tmp[:])
    			prefix := hex.EncodeToString(tmp[:])
    			for i := 0; i < 10000; i++ {
    				rng.Read(tmp[:])
    
    				y := hashOrder(fmt.Sprintf("%s/%x", prefix, hex.EncodeToString(tmp[:3])), x)
    				first[y[0]]++
    			}
    			t.Log("first:", first[:x])
    		})
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  8. .teamcity/src/test/kotlin/PromotionProjectTests.kt

            assertEquals(10, model.buildTypes.size)
            assertEquals(
                listOf("SanityCheck", "Nightly Snapshot", "Nightly Snapshot (from QuickFeedback)", "Nightly Snapshot (from QuickFeedback) - Check Ready", "Nightly Snapshot (from QuickFeedback) - Upload", "Nightly Snapshot (from QuickFeedback) - Promote", "Publish Branch Snapshot (from Quick Feedback)", "Release - Milestone", "Start Release Cycle", "Start Release Cycle Test"),
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Feb 13 14:18:23 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  9. docs/en/docs/advanced/response-change-status-code.md

    # Response - Change Status Code
    
    You probably read before that you can set a default [Response Status Code](../tutorial/response-status-code.md){.internal-link target=_blank}.
    
    But in some cases you need to return a different status code than the default.
    
    ## Use case
    
    For example, imagine that you want to return an HTTP status code of "OK" `200` by default.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java

                } catch (final ClientAbortException e) {
                    logger.debug("Client aborts this request.", e);
                } catch (final IOException e) {
                    logger.error("Failed to read {} from {}", path, filePath);
                    throw new WebApiException(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, e);
                }
            } else {
                try {
                    writeHeaders(response);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Aug 15 08:29:24 UTC 2024
    - 11.3K bytes
    - Viewed (0)
Back to top