- Sort Score
- Num 10 results
- Language All
Results 201 - 210 of 443 for sockets (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
.github/workflows/notify-translations.yml
with: limit-access-to-actor: true env: GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }} - name: Notify Translations run: python ./scripts/notify_translations.py env: GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }} NUMBER: ${{ github.event.inputs.number || null }}Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Fri Nov 21 13:03:21 GMT 2025 - 1.7K bytes - Click Count (0) -
docs/debugging/s3-check-md5/main.go
s3Client.TraceOn(os.Stderr) } var buckets []string if bucket != "" { buckets = append(buckets, bucket) } else { bucketsInfo, err := s3Client.ListBuckets(context.Background()) if err != nil { log.Fatalln(err) } for _, b := range bucketsInfo { buckets = append(buckets, b.Name) } } for _, bucket := range buckets { opts := minio.ListObjectsOptions{
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.3K bytes - Click Count (0) -
internal/config/dns/store.go
Bucket string Err error } // ErrInvalidBucketName for buckets with invalid name type ErrInvalidBucketName Error func (e ErrInvalidBucketName) Error() string { return e.Bucket + " invalid bucket name error: " + e.Err.Error() } func (e Error) Error() string { return "dns related error: " + e.Err.Error() } // ErrBucketConflict for buckets that already exist type ErrBucketConflict Error
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.6K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance.go
now := time.Now() for idx := range z.serverPools { r.PoolStats[idx] = &rebalanceStats{ Buckets: make([]string, len(buckets)), RebalancedBuckets: make([]string, 0, len(buckets)), InitFreeSpace: diskStats[idx].AvailableSpace, InitCapacity: diskStats[idx].TotalSpace, } copy(r.PoolStats[idx].Buckets, buckets)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 28.7K bytes - Click Count (0) -
android/guava/src/com/google/common/net/InetAddresses.java
* * <p>"IPv4 mapped" addresses were originally a representation of IPv4 addresses for use on an IPv6 * socket that could receive both IPv4 and IPv6 connections (by disabling the {@code IPV6_V6ONLY} * socket option on an IPv6 socket). Yes, it's confusing. Nevertheless, these "mapped" addresses * were never supposed to be seen on the wire. That assumption was dropped, some say mistakenly, in
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Feb 19 21:24:11 GMT 2025 - 47.4K bytes - Click Count (0) -
okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/DeferredSocketAdapter.kt
* limitations under the License. */ package okhttp3.internal.platform.android import javax.net.ssl.SSLSocket import okhttp3.Protocol /** * Deferred implementation of SocketAdapter that works by observing the socket * and initializing on first use. * * We use this because eager classpath checks cause confusion and excessive logging in Android,
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 2.1K bytes - Click Count (0) -
scripts/topic_repos.py
import logging import secrets import subprocess from pathlib import Path import yaml from github import Github from pydantic import BaseModel, SecretStr from pydantic_settings import BaseSettings class Settings(BaseSettings): github_repository: str github_token: SecretStr class Repo(BaseModel): name: str html_url: str stars: int owner_login: str owner_html_url: str
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Dec 16 12:34:01 GMT 2025 - 2.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/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(
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 12.2K bytes - Click Count (1) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
} @Test fun connection() { val connection = object : Connection { override fun route(): Route = TODO() override fun socket(): Socket = TODO() override fun handshake(): Handshake? = TODO() override fun protocol(): Protocol = TODO() } } @Test fun connectionPool() {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 47K bytes - Click Count (0) -
cmd/site-replication.go
} return info, errSRBackendIssue(err) } buckets = append(buckets, bi) } else { buckets, err = objAPI.ListBuckets(ctx, BucketOptions{Deleted: opts.ShowDeleted}) if err != nil { return info, errSRBackendIssue(err) } } info.Buckets = make(map[string]madmin.SRBucketInfo, len(buckets)) for _, bucketInfo := range buckets { bucket := bucketInfo.Name
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 184.8K bytes - Click Count (1)