dlopen - Code Search

src/test/java/jcifs/smb/SmbPipeHandleInternalTest.java

        assertSame(pipe, handle.getPipe());
    }

    @Test
    @DisplayName("isOpen/isStale reflect handle validity and lifecycle")
    void isOpen_isStale_transitions() throws Exception {
        SmbPipeHandleImpl handle = newHandleWithBasicStubs(0, "\\\\pipe\\\\w");
        assertFalse(handle.isOpen(), "Initially not open");
        assertFalse(handle.isStale(), "Initially not stale");

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Thu Aug 14 07:14:38 UTC 2025

- 16.7K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/SmbCircuitBreakerTest.java

    }

    @Test
    public void testCircuitResetsAfterTimeout() throws Exception {
        // Open the circuit
        circuitBreaker.trip();
        assertEquals(State.OPEN, circuitBreaker.getState(), "Circuit should be OPEN");

        // Wait for reset timeout
        Thread.sleep(1100);

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 30 05:58:03 UTC 2025

- 23.2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt

   * events.
   */
  open fun onOpen(
    eventSource: EventSource,
    response: Response,
  ) {
  }

  open fun onEvent(
    eventSource: EventSource,
    id: String?,
    type: String?,
    data: String,
  ) {
  }

  /**
   * No further calls to this listener will be made.
   */
  open fun onClosed(eventSource: EventSource) {
  }

  /**

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Fri Oct 03 07:51:20 UTC 2025

- 1.4K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocketListener.kt

   * messages.
   */
  open fun onOpen(
    webSocket: WebSocket,
    response: Response,
  ) {
  }

  /** Invoked when a text (type `0x1`) message has been received. */
  open fun onMessage(
    webSocket: WebSocket,
    text: String,
  ) {
  }

  /** Invoked when a binary (type `0x2`) message has been received. */
  open fun onMessage(
    webSocket: WebSocket,

Registered: Fri Dec 26 11:42:13 UTC 2025

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

- 2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/taglib/FessFunctions.java

    /**
     * Generates an HTML opening or closing tag with appropriate language attribute.
     *
     * @param isOpen true to generate opening HTML tag, false for closing tag
     * @return HTML opening tag with language attribute or closing tag
     */
    public static String html(final boolean isOpen) {
        if (isOpen) {
            return "<html lang=\"" + LaRequestUtil.getOptionalRequest().map(req -> {

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Fri Nov 28 16:29:12 UTC 2025

- 25.4K bytes

- Viewed (1)

github.com/codelibs/jcifs

src/main/java/jcifs/SmbPipeHandle.java

    void close() throws CIFSException;

    /**
     * Tests whether this file descriptor is open and valid.
     *
     * @return whether the FD is open and valid
     */
    boolean isOpen();

    /**
     * Tests whether this file descriptor was previously open but has become invalid.
     *
     * @return whether the FD was previously open but became invalid
     */
    boolean isStale();

    /**

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 2.4K bytes

- Viewed (0)

github.com/square/okhttp

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

        .pingInterval(Duration.ofMillis(500))
        .build()

    // Stall in onOpen to prevent pongs from being sent.
    val latch = CountDownLatch(1)
    webServer.enqueue(
      MockResponse
        .Builder()
        .webSocketUpgrade(
          object : WebSocketListener() {
            override fun onOpen(
              webSocket: WebSocket,
              response: Response,
            ) {

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Tue Nov 04 19:13:52 UTC 2025

- 35.5K bytes

- Viewed (0)

github.com/minio/minio

cmd/os-instrumented.go

// os.Lstat()
func Access(name string) (err error) {
	defer updateOSMetrics(osMetricAccess, name)(err)
	return access(name)
}

// Open captures time taken to call os.Open
func Open(name string) (f *os.File, err error) {
	defer updateOSMetrics(osMetricOpen, name)(err)
	return os.Open(name)
}

// OpenFileDirectIO captures time taken to call disk.OpenFileDirectIO

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 6.2K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

                  override fun peek() = exchange.peekTrailers()

                  override fun get(): Headers {
                    val source = responseBody.source()
                    if (source.isOpen) {
                      source.skipAll()
                    }
                    return peek() ?: error("null trailers after exhausting response body?!")
                  }
                },

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Thu Oct 30 13:46:58 UTC 2025

- 7.6K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/util/SimpleCircuitBreakerTest.java

            // Expected
        }

        assertEquals(SimpleCircuitBreaker.State.OPEN, circuitBreaker.getState());
    }

    @Test
    @DisplayName("Test reset functionality")
    void testReset() {
        // Open the circuit
        circuitBreaker.tripBreaker();
        assertEquals(SimpleCircuitBreaker.State.OPEN, circuitBreaker.getState());

        // Reset
        circuitBreaker.reset();

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 30 05:58:03 UTC 2025

- 10.6K bytes

- Viewed (0)

Search Options