- Sort Score
- Result 10 results
- Languages All
Results 261 - 270 of 528 for sockets (0.05 sec)
-
cmd/metrics-v3-api.go
// This includes bucket level S3 HTTP metrics and S3 network in/out metrics. func loadBucketAPIHTTPMetrics(ctx context.Context, m MetricValues, _ *metricsCache, buckets []string) error { if len(buckets) == 0 { return nil } for bucket, inOut := range globalBucketConnStats.getBucketS3InOutBytes(buckets) { recvBytes := inOut.In if recvBytes > 0 { m.Set(apiTrafficSentBytes, float64(recvBytes), "bucket", bucket, "type", "s3") }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 9.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/StandardAndroidSocketAdapter.kt
} catch (e: Exception) { AndroidLog.androidLog( loggerName = OkHttpClient::class.java.name, logLevel = Platform.WARN, message = "unable to load android socket classes", t = e, ) null } } }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt
val request = Request(server.url("/")) val response = client.newCall(request).execute() response.body.close() // This client shares a connection pool but has a different SSL socket factory. val handshakeCertificates2 = HandshakeCertificates.Builder().build() val anotherClient = client.newBuilder() .sslSocketFactory( handshakeCertificates2.sslSocketFactory(),
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 12.3K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
*/ fun cancel() fun interface Factory { /** * Creates a new event source and immediately returns it. Creating an event source initiates an * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must cancel the returned event source when it is no longer in use. */ fun newEventSource( request: Request,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.4K bytes - Viewed (0) -
mockwebserver-deprecated/api/mockwebserver.api
public fun <init> (Ljava/lang/String;Lokhttp3/Headers;Ljava/util/List;JLokio/Buffer;ILjava/net/Socket;)V public fun <init> (Ljava/lang/String;Lokhttp3/Headers;Ljava/util/List;JLokio/Buffer;ILjava/net/Socket;Ljava/io/IOException;)V public synthetic fun <init> (Ljava/lang/String;Lokhttp3/Headers;Ljava/util/List;JLokio/Buffer;ILjava/net/Socket;Ljava/io/IOException;ILkotlin/jvm/internal/DefaultConstructorMarker;)V public final fun getBody ()Lokio/Buffer;
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 10.2K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.8.md
* - Don't generate empty record for externalName service. * - Add validation for upstreamNameserver port. * - Update go version to 1.9.3. * Fix mounting of UNIX sockets(and other special files) in subpaths ([#61480](https://github.com/kubernetes/kubernetes/pull/61480), [@gnufied](https://github.com/gnufied))
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 312.2K bytes - Viewed (0) -
docs/sts/README.md
2018/12/26 17:49:36 listening on http://localhost:8888/ ``` This will open the login page of keycloak, upon successful login, STS credentials along with any buckets discovered using the credentials will be printed on the screen, for example: ``` { "buckets": [ "bucket-x" ], "credentials": { "AccessKeyID": "6N2BALX7ELO827DXS3GK", "SecretAccessKey": "23JKqAD+um8ObHqzfIh+bfqwG9V8qs9tFY6MqeFR+xxx",
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 7.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.play() val longString = repeat('a', Http2.INITIAL_MAX_FRAME_SIZE + 1) val socket = peer.openSocket() val connection = Http2Connection.Builder(true, TaskRunner.INSTANCE) .socket(socket) .pushObserver(IGNORE) .build() connection.start(sendConnectionPreface = false) socket.shutdownOutput() assertFailsWith<IOException> {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
.teamcity/src/test/kotlin/CIConfigIntegrationTests.kt
assertCorrectParameters(it.key, it.value) } } fun assertProjectAreSplitByGradleVersionCorrectly(buckets: List<List<String>>, testType: TestType, functionalTests: List<BaseGradleBuildType>) { buckets.forEachIndexed { index: Int, startEndVersion: List<String> ->
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Thu Jul 18 07:02:47 UTC 2024 - 13.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/TlsVersion.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 /** * Versions of TLS that can be offered when negotiating a secure socket. See * [javax.net.ssl.SSLSocket.setEnabledProtocols]. */ enum class TlsVersion( @get:JvmName("javaName") val javaName: String, ) { TLS_1_3("TLSv1.3"), // 2016. TLS_1_2("TLSv1.2"), // 2008.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.5K bytes - Viewed (0)