thead - Code Search

okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

        .build(),
    )
    val webSocket: WebSocket = newWebSocket()
    clientListener.assertOpen()
    val server = serverListener.assertOpen()

    // Sleep longer than the HTTP client's read timeout.
    Thread.sleep((client.readTimeoutMillis + 500).toLong())
    server.send("abc")
    clientListener.assertTextMessage("abc")
    closeWebSockets(webSocket, server)
  }

  @Test
  @Throws(Exception::class)

Registered: Fri Sep 05 11:42:10 UTC 2025

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

- 35.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/test/resources/plugin/repo3/index.html

<!DOCTYPE html>
<html>

<head>
	<title>Central Repository: org/codelibs/fess</title>
	<meta name="viewport" content="width=device-width, initial-scale=1.0">
	<style>
body {
	background: #fff;
}
	</style>
</head>

<body>
	<header>
		<h1>org/codelibs/fess</h1>
	</header>
	<hr/>
	<main>
		<pre id="contents">
<a href="../">../</a>

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Mon Jun 17 13:30:41 UTC 2024

- 6.2K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/docs/reference/apirouter.md

    options:
        members:
            - websocket
            - include_router
            - get
            - put
            - post
            - delete
            - options
            - head
            - patch
            - trace

Registered: Sun Sep 07 07:19:17 UTC 2025

- Last Modified: Thu Apr 18 19:53:19 UTC 2024

- 524 bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/webconfig/admin_webconfig_edit.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8" %><!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title><la:message key="labels.admin_brand_title"/> | <la:message
            key="labels.web_crawling_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Thu Feb 13 07:47:04 UTC 2020

- 15.9K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

  private var nextTcpConnectAtNanos = Long.MIN_VALUE

  /**
   * Plans currently being connected, and that will later be added to [connectResults]. This is
   * mutated by the call thread only. If is accessed by background connect threads.
   */
  private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>()

  /**
   * Results are posted here as they occur. The find job is done when either one plan completes

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Fri Dec 27 13:39:56 UTC 2024

- 5.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/admin/crawlinginfo/AdminCrawlinginfoAction.java

                    throwValidationError(messages -> messages.addErrorsCrudCouldNotFindCrudTable(GLOBAL, id), this::asListHtml);
                    return null;
                });
    }

    /**
     * Print a thread dump.
     * @param form The edit form.
     * @return The HTML response.
     */
    @Execute
    @Secured({ ROLE })
    public HtmlResponse threaddump(final EditForm form) {

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Thu Aug 07 03:06:29 UTC 2025

- 11.4K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

    public void finalizeReferent() {
      finalizeReferentCalled = true;
    }
  }

  /**
   * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we
   * know that the background thread has stopped and released its strong reference.
   */
  private WeakReference<ReferenceQueue<Object>> queueReference;

  @Test
  public void testThatFinalizerStops() {
    weaklyReferenceQueue();

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Tue May 13 18:46:00 UTC 2025

- 8.7K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

    public void finalizeReferent() {
      finalizeReferentCalled = true;
    }
  }

  /**
   * Keeps a weak reference to the underlying reference queue. When this reference is cleared, we
   * know that the background thread has stopped and released its strong reference.
   */
  private WeakReference<ReferenceQueue<Object>> queueReference;

  @Test
  public void testThatFinalizerStops() {
    weaklyReferenceQueue();

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Tue May 13 18:46:00 UTC 2025

- 8.7K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/base/FinalizableSoftReference.java

import java.lang.ref.ReferenceQueue;
import java.lang.ref.SoftReference;
import org.jspecify.annotations.Nullable;

/**
 * Soft reference with a {@code finalizeReferent()} method which a background thread invokes after
 * the garbage collector reclaims the referent. This is a simpler alternative to using a {@link
 * ReferenceQueue}.
 *
 * @author Bob Lee
 * @since 2.0
 */
@J2ktIncompatible
@GwtIncompatible

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Sun Dec 22 03:38:46 UTC 2024

- 1.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/collect/ForwardingMap.java

 * not consistent with {@code equals}.
 *
 * <p>The {@code standard} methods and the collection views they return are not guaranteed to be
 * thread-safe, even when all of the methods that they depend on are thread-safe.
 *
 * @author Kevin Bourrillion
 * @author Jared Levy
 * @author Louis Wasserman
 * @since 2.0
 */
@GwtCompatible

Registered: Fri Sep 05 12:43:10 UTC 2025

- Last Modified: Wed Aug 06 17:32:30 UTC 2025

- 9.8K bytes

- Viewed (0)

Search Options