- Sort Score
- Result 10 results
- Languages All
Results 841 - 850 of 1,031 for readOp (0.12 sec)
-
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java
import static org.apache.maven.api.Lifecycle.AT; import static org.apache.maven.api.Lifecycle.BEFORE; import static org.apache.maven.api.Lifecycle.Phase.PACKAGE; import static org.apache.maven.api.Lifecycle.Phase.READY; import static org.apache.maven.lifecycle.internal.concurrent.BuildStep.CREATED; import static org.apache.maven.lifecycle.internal.concurrent.BuildStep.EXECUTED;
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Oct 16 06:12:36 UTC 2025 - 55.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt
private var handshake: Handshake? = null private var protocol: Protocol? = null private lateinit var socket: BufferedSocket private var connection: RealConnection? = null /** True if this connection is ready for use, including TCP, tunnels, and TLS. */ override val isReady: Boolean get() = protocol != null private fun copy( attempt: Int = this.attempt, tunnelRequest: Request? = this.tunnelRequest,Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Oct 08 03:50:05 UTC 2025 - 19.3K bytes - Viewed (2) -
docs/changelogs/changelog_2x.md
return such malformed responses will now trigger a `ProtocolException` in the client. * **WebSocketListener has incompatible changes.** The `onOpen()` method is now called on the reader thread, so implementations must return before further websocket messages will be delivered. The `onFailure()` method now includes an HTTP response if one was returned. ## Version 2.4.0-RC1 _2015-05-16_Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/LeaseManagerTest.java
assertTrue(fullEntry.hasReadCache()); assertTrue(fullEntry.hasWriteCache()); assertTrue(fullEntry.hasHandleCache()); // Test read-only lease Smb2LeaseKey readKey = leaseManager.requestLease(path + "2", Smb2LeaseState.SMB2_LEASE_READ_CACHING); leaseManager.updateLease(readKey, Smb2LeaseState.SMB2_LEASE_READ_CACHING);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 21 00:16:17 UTC 2025 - 13.2K bytes - Viewed (0) -
docs/pt/docs/advanced/events.md
Um **gerenciador de contexto** em Python é algo que você pode usar em uma declaração `with`, por exemplo, `open()` pode ser usado como um gerenciador de contexto: ```Python with open("file.txt") as file: file.read() ``` Em versões mais recentes do Python, há também um **gerenciador de contexto assíncrono**. Você o usaria com `async with`: ```Python async with lifespan(app): await do_stuff() ```
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 8.8K bytes - Viewed (0) -
src/main/webapp/js/admin/jquery-3.7.1.min.js
ner("DOMContentLoaded",P),ie.removeEventListener("load",P),ce.ready()}ce.fn.ready=function(e){return O.then(e)["catch"](function(e){ce.readyException(e)}),this},ce.extend({isReady:!1,readyWait:1,ready:function(e){(!0===e?--ce.readyWait:ce.isReady)||(ce.isReady=!0)!==e&&0<--ce.readyWait||O.resolveWith(C,[ce])}}),ce.ready.then=O.then,"complete"===C.readyState||"loading"!==C.readyState&&!C.documentElement.doScroll?ie.setTimeout(ce.ready):(C.addEventListener("DOMContentLoaded",P),ie.addEventListener("load",P));var...Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Oct 26 01:07:52 UTC 2024 - 85.5K bytes - Viewed (1) -
docs/metrics/prometheus/grafana/minio-dashboard.json
"fullMetaSearch": false, "hide": false, "includeNullMetadata": true, "instant": false, "legendFormat": "Pool {{pool}} / Set {{set}} - Read Quorum", "range": true, "refId": "B", "useBackend": false }, { "datasource": { "type": "prometheus",
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Aug 04 01:46:49 UTC 2025 - 93.1K bytes - Viewed (0) -
internal/s3select/csv/reader_contrib_test.go
} if !c.header { args.FileHeaderInfo = none } inr := io.Reader(bytes.NewReader(input)) if c.sendErr != nil { inr = io.MultiReader(inr, errReader{c.sendErr}) } r, _ := NewReader(io.NopCloser(inr), &args) fields := 0 for { record, err = r.Read(record) if err != nil { break } opts := sql.WriteCSVOpts{Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 38.4K bytes - Viewed (0) -
api/go1.3.txt
pkg archive/tar, const TypeGNUSparse = 83 pkg archive/tar, const TypeGNUSparse ideal-char pkg archive/tar, type Header struct, Xattrs map[string]string pkg compress/gzip, method (*Reader) Reset(io.Reader) error pkg crypto/tls, const CurveP256 = 23 pkg crypto/tls, const CurveP256 CurveID pkg crypto/tls, const CurveP384 = 24 pkg crypto/tls, const CurveP384 CurveID pkg crypto/tls, const CurveP521 = 25 pkg crypto/tls, const CurveP521 CurveID
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Mon Jun 02 02:45:00 UTC 2014 - 117K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.4.md
* Change eviction policies in NodeController: * add a "partialDisruption" mode, when more than 33% of Nodes in the zone are not Ready * add "fullDisruption" mode, when all Nodes in the zone are not Ready * Eviction behavior depends on the mode in which NodeController is operating:Registered: Fri Dec 26 09:05:12 UTC 2025 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 133.5K bytes - Viewed (0)