responder - Code Search

CLAUDE.md

**Thread Safety**: `AtomicLong` for counters, `volatile` for status flags, synchronized blocks, thread-local storage via `CrawlingParameterUtil`

**Resource Management**: `AutoCloseable` throughout, `DeferredFileOutputStream` for large responses, connection pooling, background temp file deletion via `FileUtil.deleteInBackground()`

**Fault Tolerance**: `FaultTolerantClient` wrapper (retry, circuit breaker), `SwitchableHttpClient` for HTTP client fallback

---

Created: Sun Apr 12 03:50:13 GMT 2026

- Last Modified: Thu Mar 12 03:39:20 GMT 2026

- 8.1K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/SmbConstants.java

     */
    int DEFAULT_PORT = 445;

    /**
     * Default maximum number of outstanding SMB requests.
     */
    int DEFAULT_MAX_MPX_COUNT = 10;
    /**
     * Default timeout in milliseconds for SMB responses.
     */
    int DEFAULT_RESPONSE_TIMEOUT = 30000;
    /**
     * Default socket timeout in milliseconds.
     */
    int DEFAULT_SO_TIMEOUT = 35000;
    /**
     * Default receive buffer size for SMB transport.

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sun Aug 24 00:49:49 GMT 2025

- 12.8K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_body_nested_models/test_tutorial004.py

        },
    }


def test_put_only_required(client: TestClient):
    response = client.put(
        "/items/5",
        json={"name": "Foo", "price": 35.4},
    )
    assert response.status_code == 200, response.text
    assert response.json() == {
        "item_id": 5,
        "item": {
            "name": "Foo",
            "description": None,

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Thu Feb 12 13:19:43 GMT 2026

- 9.5K bytes

- Click Count (0)

github.com/square/okhttp

mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt

   * can return other values to test HTTP edge cases, such as unhappy socket policies or throttled
   * request bodies.
   */
  public open fun peek(): MockResponse = MockResponse()

  /**
   * Release any resources held by this dispatcher. Any requests that are currently being dispatched
   * should return immediately. Responses returned after shutdown will not be transmitted: their

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Fri Jun 20 11:46:46 GMT 2025

- 1.6K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_security_http_basic_realm.py


def test_security_http_basic():
    response = client.get("/users/me", auth=("john", "secret"))
    assert response.status_code == 200, response.text
    assert response.json() == {"username": "john", "password": "secret"}


def test_security_http_basic_no_credentials():
    response = client.get("/users/me")
    assert response.json() == {"detail": "Not authenticated"}
    assert response.status_code == 401, response.text

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Sun Feb 08 10:18:38 GMT 2026

- 2.7K bytes

- Click Count (0)

github.com/square/okhttp

okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt

    hostname: String,
    response: Response,
  ): List<InetAddress> {
    if (response.cacheResponse == null && response.protocol !== Protocol.HTTP_2 && response.protocol !== Protocol.QUIC) {
      Platform.get().log("Incorrect protocol: ${response.protocol}", Platform.WARN)
    }

    response.use {
      if (!response.isSuccessful) {
        throw IOException("response: " + response.code + " " + response.message)

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Sat May 10 11:15:14 GMT 2025

- 8.6K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_body/test_tutorial004.py

                "msg": "Field required",
                "input": {},
            },
        ]
    }


def test_openapi_schema(client: TestClient):
    response = client.get("/openapi.json")
    assert response.status_code == 200, response.text
    assert response.json() == snapshot(
        {
            "openapi": "3.1.0",
            "info": {"title": "FastAPI", "version": "0.1.0"},
            "paths": {

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Thu Feb 12 13:19:43 GMT 2026

- 6.6K bytes

- Click Count (0)

github.com/square/okhttp

okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackRoundTripTest.kt

 *
 * TODO: update hpack-test-case with the output of our encoder.
 * This test will hide complementary bugs in the encoder and decoder,
 * We should test that the encoder is producing responses that are
 */
class HpackRoundTripTest : HpackDecodeTestBase() {
  internal class StoriesTestProvider : SimpleProvider() {
    override fun arguments(): List<Any> = createStories(RAW_DATA)
  }

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 2K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/websockets_/tutorial003_py310.py

from fastapi import FastAPI, WebSocket, WebSocketDisconnect
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <h2>Your ID: <span id="ws-id"></span></h2>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Feb 27 12:34:37 GMT 2026

- 2.5K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_additional_responses/test_tutorial001.py

client = TestClient(app)


def test_path_operation():
    response = client.get("/items/foo")
    assert response.status_code == 200, response.text
    assert response.json() == {"id": "foo", "value": "there goes my hero"}


def test_path_operation_not_found():
    response = client.get("/items/bar")
    assert response.status_code == 404, response.text
    assert response.json() == {"message": "Item not found"}

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Thu Feb 12 13:19:43 GMT 2026

- 5.1K bytes

- Click Count (0)

Search Options