Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 337 for ping (0.02 sec)

  1. .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)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

        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())
          .isCloseTo(1000.0, 250.0)
      }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 35.5K bytes
    - Viewed (0)
  3. 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)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

      private val maskCursor: Buffer.UnsafeCursor? = if (isClient) Buffer.UnsafeCursor() else null
    
      /** Send a ping with the supplied [payload]. */
      @Throws(IOException::class)
      fun writePing(payload: ByteString) {
        writeControlFrame(OPCODE_CONTROL_PING, payload)
      }
    
      /** Send a pong with the supplied [payload]. */
      @Throws(IOException::class)
      fun writePong(payload: ByteString) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 6K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

            sink.writeInt(settings[i])
          }
          sink.flush()
        }
      }
    
      /**
       * Send a connection-level ping to the peer. `ack` indicates this is a reply. The data in
       * `payload1` and `payload2` opaque binary, and there are no rules on the content.
       */
      @Throws(IOException::class)
      fun ping(
        ack: Boolean,
        payload1: Int,
        payload2: Int,
      ) {
        withLock {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt

          settings: Settings,
        )
    
        /** HTTP/2 only. */
        fun ackSettings()
    
        /**
         * Read a connection-level ping from the peer. `ack` indicates this is a reply. The data
         * in `payload1` and `payload2` opaque binary, and there are no rules on the content.
         */
        fun ping(
          ack: Boolean,
          payload1: Int,
          payload2: Int,
        )
    
        /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_3x.md

        Previously if you configured a ping interval that would cause OkHttp to send
        pings, but it did not track whether the reply pongs were received. With this
        update OkHttp requires that every ping receive a response: if it does not
        the connection will be closed and the listener's `onFailure()` method will
        be called.
    
        Web sockets have always been had pings, but pings on HTTP/2 connections is
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  8. src/main/java/jcifs/dcerpc/DcerpcConstants.java

         */
        int DCERPC_OBJECT_UUID = 0x80; /* if true, a non-nil object UUID */
    
        // Packet Types (ptype)
        /**
         * Request packet type
         */
        int RPC_PT_REQUEST = 0x00;
        /**
         * Ping packet type
         */
        int RPC_PT_PING = 0x01;
        /**
         * Response packet type
         */
        int RPC_PT_RESPONSE = 0x02;
        /**
         * Fault packet type - indicates an error
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  9. CONTRIBUTING.md

    for MinIO?
    
    ``MinIO`` is fully conformant with Golang style. Refer: [Effective Go](https://github.com/golang/go/wiki/CodeReviewComments) article from Golang project. If you observe offending code, please feel free to send a pull request or ping us on [Slack](https://slack.min.io)....
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 05 18:35:53 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  10. gorm.go

    		ConnPool: db.ConnPool,
    		Context:  context.Background(),
    		Clauses:  map[string]clause.Clause{},
    	}
    
    	if err == nil && !config.DisableAutomaticPing {
    		if pinger, ok := db.ConnPool.(interface{ Ping() error }); ok {
    			err = pinger.Ping()
    		}
    	}
    
    	if err != nil {
    		config.Logger.Error(context.Background(), "failed to initialize database, got error %v", err)
    	}
    
    	return
    }
    
    // Session create new db session
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Aug 26 06:24:29 UTC 2025
    - 12.8K bytes
    - Viewed (0)
Back to top