- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 1,346 for connections (0.11 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/en/docs/advanced/websockets.md
``` Client #1596980209979 left the chat ``` /// tip The app above is a minimal and simple example to demonstrate how to handle and broadcast messages to several WebSocket connections. But keep in mind that, as everything is handled in memory, in a single list, it will only work while the process is running, and will only work with a single process.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sat Mar 07 09:29:03 GMT 2026 - 5.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocksProxy.kt
val socket = serverSocket!!.accept() connectionCount.incrementAndGet() service(socket) } } catch (e: SocketException) { logger.info("$threadName done accepting connections: ${e.message}") } catch (e: IOException) { logger.log(Level.WARNING, "$threadName failed unexpectedly", e) } finally { for (socket in openSockets) { socket.closeQuietly() }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 7.7K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java
import jcifs.internal.smb2.info.Smb2SetInfoRequest; import jcifs.internal.smb2.io.Smb2ReadRequest; import jcifs.internal.smb2.io.Smb2WriteRequest; /** * Load balancer for SMB3 Multi-Channel connections */ public class ChannelLoadBalancer { private final ChannelManager manager; private LoadBalancingStrategy strategy; private final AtomicInteger roundRobinCounter; /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 8.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
return null } HTTP_MISDIRECTED_REQUEST -> { // OkHttp can coalesce HTTP/2 connections even if the domain names are different. See // RealConnection.isEligible(). If we attempted this and the server returned HTTP 421, then // we can retry on a different connection. val requestBody = userResponse.request.body if (requestBody != null && requestBody.isOneShot()) {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 12.5K bytes - Click Count (0) -
helm-releases/minio-3.6.4.tgz
service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" ; MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS...
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Apr 12 01:30:28 GMT 2022 - 17.9K bytes - Click Count (0) -
src/main/java/jcifs/dcerpc/msrpc/srvsvc.java
/** * The share permissions. */ public int permissions; /** * The maximum number of concurrent connections. */ public int max_uses; /** * The current number of connections. */ public int current_uses; /** * The local path of the share. */ public String path;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 27K bytes - Click Count (0) -
docs/lambda/README.md
The field of `getObjectContext` means the input and output details for connections to MinIO. It has the following fields:
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 7.7K bytes - Click Count (0) -
helm-releases/minio-5.0.6.tgz
service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" ; MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS...
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Feb 13 06:53:06 GMT 2023 - 20.3K bytes - Click Count (0) -
SECURITY.md
internal communication only. It is not built for use in untrusted environments or networks. For performance reasons, the default TensorFlow server does not include any authorization protocol and sends messages unencrypted. It accepts connections from anywhere, and executes the graphs it is sent without performing any checks. Therefore, if you run a `tf.train.Server` in your network, anybody with access
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Wed Oct 16 16:10:43 GMT 2024 - 9.6K bytes - Click Count (0) -
helm-releases/minio-4.0.5.tgz
service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ; # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" ; MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS...
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sat Jul 16 06:42:56 GMT 2022 - 18.3K bytes - Click Count (0)