- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 24 for sockets (0.07 seconds)
-
docs/changelogs/changelog_3x.md
* New: charset support for `Credentials.basic()`. ## Version 3.5.0 _2016-11-30_ * **Web Sockets are now a stable feature of OkHttp.** Since being introduced as a beta feature in OkHttp 2.3 our web socket client has matured. Connect to a server's web socket with `OkHttpClient.newWebSocket()`, send messages with `send()`, and receive messages with the `WebSocketListener`.
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
} /** * Sets the socket factory used to create connections. OkHttp only uses the parameterless * [SocketFactory.createSocket] method to create unconnected sockets. Overriding this method, * e. g., allows the socket to be bound to a specific local address. * * If unset, the [system-wide default][SocketFactory.getDefault] socket factory will be used. */Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 51.4K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
do { this.socket = new Socket(); if (this.localAddr != null) { this.socket.bind(new InetSocketAddress(this.localAddr, this.localPort)); } this.socket.connect(new InetSocketAddress(this.address.getHostAddress(), 139), tc.getConfig().getConnTimeout()); this.socket.setSoTimeout(tc.getConfig().getSoTimeout());Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 69.8K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/HcHttpClient.java
import org.apache.http.conn.HttpClientConnectionManager; import org.apache.http.conn.routing.HttpRoutePlanner; import org.apache.http.conn.socket.ConnectionSocketFactory; import org.apache.http.conn.socket.LayeredConnectionSocketFactory; import org.apache.http.conn.socket.PlainConnectionSocketFactory; import org.apache.http.conn.ssl.NoopHostnameVerifier; import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sun Nov 23 12:19:14 GMT 2025 - 53.7K bytes - Click Count (0) -
kotlin-js-store/yarn.lock
integrity sha512-V4GrkLy+HeF1F/en3SpUaM+7XxYXpuMUWLGde1kSSh5nQMN4hLrbPIkD+otwh6q9R6NOQBN4AMaOZ2zVjui82g== dependencies: "@socket.io/component-emitter" "~3.1.0" debug "~4.3.1" socket.io@^4.4.1: version "4.5.4" resolved "https://registry.yarnpkg.com/socket.io/-/socket.io-4.5.4.tgz#a4513f06e87451c17013b8d13fdfaf8da5a86a90"Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 87.4K bytes - Click Count (0) -
cmd/bucket-handlers.go
// // -- If IP of the entry doesn't match, this means entry is // // for another instance. Log an error to console. func initFederatorBackend(buckets []string, objLayer ObjectLayer) { if len(buckets) == 0 { return } // Get buckets in the DNS dnsBuckets, err := globalDNSConfig.List() if err != nil && !IsErrIgnored(err, dns.ErrNoEntriesFound, dns.ErrNotImplemented, dns.ErrDomainMissing) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 63.9K bytes - Click Count (0) -
cmd/erasure-server-pool.go
defer cancel() buckets, err = z.s3Peer.ListBuckets(ctx, opts) if err != nil { return nil, err } if !opts.NoMetadata { for i := range buckets { createdAt, err := globalBucketMetadataSys.CreatedAt(buckets[i].Name) if err == nil { buckets[i].Created = createdAt } } } return buckets, nil }, )
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 89.2K bytes - Click Count (0) -
cmd/admin-handlers-users_test.go
}() } restrictedClient := s.getUserClient(c, "restricted", "restricted123", "") buckets, err := restrictedClient.ListBuckets(ctx) if err != nil { c.Fatalf("err fetching buckets %s", err) } if len(buckets) != 2 || buckets[0].Name != "bucket1" || buckets[1].Name != "bucket2" { c.Fatalf("restricted service account should only have access to bucket1 and bucket2") }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 50.6K bytes - Click Count (0) -
okhttp/api/jvm/okhttp.api
public abstract interface class okhttp3/Connection { public abstract fun handshake ()Lokhttp3/Handshake; public abstract fun protocol ()Lokhttp3/Protocol; public abstract fun route ()Lokhttp3/Route; public abstract fun socket ()Ljava/net/Socket; } public final class okhttp3/ConnectionPool { public fun <init> ()V public fun <init> (IJLjava/util/concurrent/TimeUnit;)V public final fun connectionCount ()I public final fun evictAll ()VCreated: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Nov 05 18:28:35 GMT 2025 - 70.2K bytes - Click Count (0) -
cmd/peer-rest-server.go
return false } return true } // GetBandwidth gets the bandwidth for the buckets requested. func (s *peerRESTServer) GetBandwidth(params *grid.URLValues) (*bandwidth.BucketBandwidthReport, *grid.RemoteErr) { buckets := params.Values().Get("buckets") selectBuckets := bandwidth.SelectBuckets(buckets) return globalBucketMonitor.GetReport(selectBuckets), nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0)