- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 87 for multiplexed (0.75 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
var idleAtNs = Long.MAX_VALUE /** * Returns true if this is an HTTP/2 connection. Such connections can be used in multiple HTTP * requests simultaneously. */ internal val isMultiplexed: Boolean get() = http2Connection != null /** Prevent further exchanges from being created on this connection. */ override fun noNewExchanges() { this.withLock { noNewExchanges = true }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 15.4K bytes - Viewed (0) -
src/image/jpeg/idct.go
w2mw6 = w2 - w6 w3pw5 = w3 + w5 w3mw5 = w3 - w5 r2 = 181 // 256/sqrt(2) ) // idct performs a 2-D Inverse Discrete Cosine Transformation. // // The input coefficients should already have been multiplied by the // appropriate quantization table. We use fixed-point computation, with the // number of bits for the fractional component varying over the intermediate // stages. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 23:18:37 UTC 2019 - 5K bytes - Viewed (0) -
tensorflow/cc/framework/gradient_checker.cc
// The number of rows is the number of elements in the x tensor multiplied // by the number of Jacobian entries needed to represent each x type. const int64_t x_size = x_shapes[x_idx].num_elements() * JacobianStride<X_T>::value; for (int y_idx = 0; y_idx < y_num; y_idx++) { // The number of columns is the number of elements in the y tensor // multiplied by the number of Jacobian entries needed to represent each
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 05:57:22 UTC 2024 - 18.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComNegotiateResponse.java
* * @return negotiated send buffer size */ public int getNegotiatedSendBufferSize () { return this.snd_buf_size; } /** * * @return negotiated multiplex count */ public int getNegotiatedMpxCount () { return this.maxMpxCount; } /** * * @return negotiated session key */
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Tue Jul 07 10:52:42 UTC 2020 - 15.4K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/http.go
if !strings.HasPrefix(cfg.Proxy, "socks5://") { out.Proxy = cfg.proxyURL } return out } noCloseFn := func() {} // Always create a new HTTP transport for each request, since HTTP can't multiplex over // a single connection. return func() (http.RoundTripper, func(), error) { conn := newConn() return conn, noCloseFn, nil }, noCloseFn } type httpCall struct { *httpProtocol
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 7.9K bytes - Viewed (0) -
api/openapi-spec/v3/apis__networking.k8s.io__v1_openapi.json
}, "tls": { "description": "tls represents the TLS configuration. Currently the Ingress only supports a single TLS port, 443. If multiple members of this list specify different hosts, they will be multiplexed on the same port according to the hostname specified through the SNI TLS extension, if the ingress controller fulfilling the ingress supports SNI.", "items": { "allOf": [ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 324.8K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
// However, here it makes sense, because we are generally streaming a single resource, // so sending an error will not cause a single failure to prevent the entire multiplex stream // of resources, and failures here are generally due to temporary networking issues to the CA // rather than a result of configuration issues, which trigger updates in Istiod when resolved.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
} if _, err := conn.channels[channel].DataFromSocket(data); err != nil { klog.Errorf("Unable to write frame (%d bytes) to %d: %v", len(data), channel, err) continue } } } // write multiplexes the specified channel onto the websocket func (conn *Conn) write(num byte, data []byte) (int, error) { conn.resetTimeout() switch conn.codec { case rawCodec: frame := make([]byte, len(data)+1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0) -
src/crypto/internal/edwards25519/field/fe_generic.go
// // Overall, the reduction works the same as carryPropagate, except with // wider inputs: we take the carry for each coefficient by shifting it right // by 51, and add it to the limb above it. The top carry is multiplied by 19 // according to the reduction identity and added to the lowest limb. // // The largest coefficient (r0) will be at most 111 bits, which guarantees
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 27 01:16:19 UTC 2023 - 8.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
// In the first synchronized block, acquire the connection if it can satisfy this call. val acquired = connection.withLock { when { requireMultiplexed && !connection.isMultiplexed -> false !connection.isEligible(address, routes) -> false else -> { connectionUser.acquireConnectionNoEvents(connection) true } }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 16.2K bytes - Viewed (0)