Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 105 for pin2 (0.02 sec)

  1. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

                final PingResponse pingResponse = searchEngineClient.ping();
                writeJsonResponse(pingResponse.getStatus() == 0 ? HttpServletResponse.SC_OK : HttpServletResponse.SC_SERVICE_UNAVAILABLE,
                        "\"data\":" + pingResponse.getMessage());
            } catch (final Exception e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to process a ping request.", e);
                }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 54.6K bytes
    - Viewed (1)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

          awaitingPong = true
        }
    
        if (failedPing != -1) {
          failWebSocket(
            e =
              SocketTimeoutException(
                "sent ping but didn't receive pong within " +
                  "${pingIntervalMillis}ms (after ${failedPing - 1} successful ping/pongs)",
              ),
            isWriter = true,
          )
          return
        }
    
        try {
          writer.writePing(ByteString.EMPTY)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  3. tests/connpool_test.go

    	return c.Tx.QueryRowContext(ctx, query, args...)
    }
    
    type wrapperConnPool struct {
    	db     *sql.DB
    	got    []string
    	expect []string
    }
    
    func (c *wrapperConnPool) Ping() error {
    	return c.db.Ping()
    }
    
    // If you use BeginTx returned *sql.Tx as shown below then you can't record queries in a transaction.
    //
    //	func (c *wrapperConnPool) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun May 25 07:40:40 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  4. .github/workflows/tests.yml

              MYSQL_USER: gorm
              MYSQL_PASSWORD: gorm
              MYSQL_RANDOM_ROOT_PASSWORD: "yes"
            ports:
              - 9910:3306
            options: >-
              --health-cmd "mysqladmin ping -ugorm -pgorm"
              --health-interval 10s
              --health-start-period 10s
              --health-timeout 5s
              --health-retries 10
    
        steps:
        - name: Set up Go 1.x
          uses: actions/setup-go@v4
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Jul 21 02:46:58 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  5. src/main/resources/fess_indices/fess/ro/stopwords.txt

    nimeni
    nişte
    noastră
    noastre
    noi
    noştri
    nostru
    nu
    ori
    oricând
    oricare
    oricât
    orice
    oricînd
    oricine
    oricît
    oricum
    oriunde
    până
    pe
    pentru
    peste
    pînă
    poate
    pot
    prea
    prima
    primul
    prin
    printr
    sa
    să
    săi
    sale
    sau
    său
    se
    şi
    sînt
    sîntem
    sînteţi
    spre
    sub
    sunt
    suntem
    sunteţi
    ta
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 19 06:31:02 UTC 2018
    - 1.4K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(response.protocol).isEqualTo(protocol)
    
        // Confirm a single ping was sent and received, and its reply was sent and received.
        val logs = testLogHandler.takeAll()
        assertThat(countFrames(logs, "FINE: >> 0x00000000     8 PING          "))
          .isEqualTo(1)
        assertThat(countFrames(logs, "FINE: << 0x00000000     8 PING          "))
          .isEqualTo(1)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  7. ci/official/requirements_updater/requirements.in

    auditwheel >= 6.1.0
    # Install tensorboard, and keras
    # Note that here we want the latest version that matches TF major.minor version
    # Note that we must use nightly here as these are used in nightly jobs
    # For release jobs, we will pin these on the release branch
    keras-nightly ~= 3.10.0.dev
    tb-nightly ~= 2.20.0.a
    # For new protobuf, if V.x.y is gencode version, then runtime version U must be
    # V <= U <= V+1
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Wed Sep 03 23:57:17 UTC 2025
    - 1.2K bytes
    - Viewed (0)
  8. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        }
        val urlConnection2 = server.url("/").toUrl().openConnection()
        val in2 = urlConnection2.getInputStream()
        assertThat(in2.read()).isEqualTo('D'.code)
        assertThat(in2.read()).isEqualTo('E'.code)
        assertThat(in2.read()).isEqualTo('F'.code)
        assertThat(in2.read()).isEqualTo(-1)
        assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 03 13:16:34 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

        )
        val openAtNanos = System.nanoTime()
        newWebSocket()
        clientListener.assertOpen()
        clientListener.assertFailure(
          SocketTimeoutException::class.java,
          "sent ping but didn't receive pong within 500ms (after 0 successful ping/pongs)",
        )
        latch.countDown()
        val elapsedUntilFailure = System.nanoTime() - openAtNanos
        assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedUntilFailure).toDouble())
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        val settings1 = Settings()
        settings1[Settings.MAX_CONCURRENT_STREAMS] = maxConcurrentStreams
        peer.sendFrame().settings(settings1)
        peer.acceptFrame() // ACK
        peer.sendFrame().ping(false, 2, 0)
        peer.acceptFrame() // PING
        peer.play()
    
        // Play it back.
        val connection =
          Http2Connection
            .Builder(true, TaskRunner.INSTANCE)
            .socket(peer.openSocket().asBufferedSocket(), "peer")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 12.9K bytes
    - Viewed (0)
Back to top