rocket - Code Search

okhttp/src/jvmTest/kotlin/okhttp3/InterceptorOverridesTest.kt

  }

  class DelayingSocketFactory(
    val onConnect: Socket.(timeout: Int) -> Unit = {},
    val onRead: Socket.() -> Unit = {},
    val onWrite: Socket.() -> Unit = {},
  ) : DelegatingSocketFactory(getDefault()) {
    override fun createSocket(): Socket {
      return object : Socket() {
        override fun connect(
          endpoint: SocketAddress?,
          timeout: Int,

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

- Last Modified: Wed Mar 11 02:37:00 GMT 2026

- 28.8K bytes

- Click Count (0)

github.com/square/okhttp

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

 * limitations under the License.
 */
package okhttp3

import okio.ByteString

abstract class WebSocketListener {
  /**
   * Invoked when a web socket has been accepted by the remote peer and may begin transmitting
   * messages.
   */
  open fun onOpen(
    webSocket: WebSocket,
    response: Response,
  ) {
  }

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

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

- 2K bytes

- Click Count (0)

github.com/minio/minio

cmd/server-main.go

	globalLifecycleSys = NewLifecycleSys()

	// Create new bucket encryption subsystem
	globalBucketSSEConfigSys = NewBucketSSEConfigSys()

	// Create new bucket object lock subsystem
	globalBucketObjectLockSys = NewBucketObjectLockSys()

	// Create new bucket quota subsystem
	globalBucketQuotaSys = NewBucketQuotaSys()

	// Create new bucket versioning subsystem
	if globalBucketVersioningSys == nil {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue May 27 15:18:36 GMT 2025

- 35.9K bytes

- Click Count (4)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.31.md

onformance:v1.31.14](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance) | [amd64](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance-amd64), [arm64](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance-arm64), [ppc64le](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance-ppc64le),...

Created: Fri Apr 03 09:05:14 GMT 2026

- Last Modified: Wed Nov 12 11:33:21 GMT 2025

- 451.9K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

    } else {
      Protocol.HTTP_2
    }

  @Volatile
  private var canceled = false

  override val isResponseComplete: Boolean
    get() = stream?.isSourceComplete == true

  override val socket: Socket
    get() = stream!!

  override fun createRequestBody(
    request: Request,
    contentLength: Long,
  ): Sink = stream!!.sink

  override fun writeRequestHeaders(request: Request) {

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

- Last Modified: Tue Jul 29 21:11:09 GMT 2025

- 7K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/platform/Platform.kt

      // https://github.com/bcgit/bc-java/issues/1773
      listOf()
    }
  }

  @Throws(IOException::class)
  open fun connectSocket(
    socket: Socket,
    address: InetSocketAddress,
    connectTimeout: Int,
  ) {
    socket.connect(address, connectTimeout)
  }

  open fun log(
    message: String,
    level: Int = INFO,
    t: Throwable? = null,
  ) {

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

- Last Modified: Tue Feb 03 22:17:59 GMT 2026

- 8.1K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/ConscryptSocketAdapter.kt

      matchesSocket(sslSocket) -> Conscrypt.getApplicationProtocol(sslSocket)
      else -> null // No TLS extensions if the socket class is custom.
    }

  override fun configureTlsExtensions(
    sslSocket: SSLSocket,
    hostname: String?,
    protocols: List<Protocol>,
  ) {
    // No TLS extensions if the socket class is custom.
    if (matchesSocket(sslSocket)) {
      // Enable session tickets.

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

- Last Modified: Tue Jan 27 09:00:39 GMT 2026

- 3K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/witness/WitnessRpcClient.java

     * @throws IOException if connection fails
     */
    private void testConnection() throws IOException {
        // For now, just test basic connectivity to RPC endpoint
        try (java.net.Socket socket = new java.net.Socket()) {
            socket.connect(new java.net.InetSocketAddress(serverAddress, WITNESS_RPC_PORT), WITNESS_RPC_TIMEOUT_MS);
        } catch (IOException e) {

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

- Last Modified: Sun Aug 24 00:12:28 GMT 2025

- 12.1K bytes

- Click Count (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.29.md

onformance:v1.29.15](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance) | [amd64](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance-amd64), [arm64](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance-arm64), [ppc64le](https://console.cloud.google.com/artifacts/docker/k8s-artifacts-prod/southamerica-east1/images/conformance-ppc64le),...

Created: Fri Apr 03 09:05:14 GMT 2026

- Last Modified: Wed Mar 12 00:36:01 GMT 2025

- 429.6K bytes

- Click Count (1)

github.com/minio/minio

docs/bucket/replication/setup_3site_replication.sh

./s3-check-md5 -versions -access-key minio -secret-key minio123 -endpoint http://127.0.0.1:9002/ -bucket bucket
./s3-check-md5 -versions -access-key minio -secret-key minio123 -endpoint http://127.0.0.1:9003/ -bucket bucket
./s3-check-md5 -versions -access-key minio -secret-key minio123 -endpoint http://127.0.0.1:9004/ -bucket bucket

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Tue Sep 24 08:03:58 GMT 2024

- 10.3K bytes

- Click Count (0)

Search Options