- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 358 for Complete (0.22 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
throw ProtocolException("unexpected end of stream") } try { super.close() complete(null) } catch (e: IOException) { throw complete(e) } } private fun <E : IOException?> complete(e: E): E { if (completed) return e completed = true return bodyComplete(bytesReceived, responseDone = false, requestDone = true, e = e) } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2) -
internal/bucket/replication/datatypes.go
// Type - replication type enum type Type int const ( // Pending - replication is pending. Pending StatusType = "PENDING" // Completed - replication completed ok. Completed StatusType = "COMPLETED" // CompletedLegacy was called "COMPLETE" incorrectly. CompletedLegacy StatusType = "COMPLETE" // Failed - replication failed. Failed StatusType = "FAILED" // Replica - this is a replica. Replica StatusType = "REPLICA"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 1.5K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
type poolInfo struct { position int completed bool decomStarted bool // started but not finished yet } rememberedPools := make(map[string]poolInfo) for idx, pool := range p.Pools { complete := false decomStarted := false if pool.Decommission != nil { if pool.Decommission.Complete { complete = true } decomStarted = true }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
writeHeader(PREFIX_CLEAN, upstreamSize, metadata.size.toLong()) file!!.channel.force(false) // This file is complete. synchronized(this@Relay) { complete = true } upstream?.closeQuietly() upstream = null } fun metadata(): ByteString = metadata /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* Clears fields that are no longer needed after this future has completed -- or at least all its * inputs have completed (more precisely, after {@link #handleAllCompleted()} has been called). * Often called multiple times (that is, both when the inputs complete and when the output * completes). * * <p>This is similar to our proposed {@code afterCommit} method but not quite the same. See the * description of CL 265462958. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
if len(ri.Targets) == 0 { return VersionPurgeStatusType("") } completed := 0 for _, v := range ri.Targets { switch v.VersionPurgeStatus { case Failed: return Failed case Complete: completed++ } } if completed == len(ri.Targets) { return Complete } return Pending } func (ri replicatedInfos) VersionPurgeStatusInternal() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone() * complete} or, if the computation is already complete, immediately. * * <p>There is no guaranteed ordering of execution of listeners, but any listener added through * this method is guaranteed to be called once the computation is complete. * * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
docs/de/docs/deployment/server-workers.md
[19511] [INFO] Waiting for application startup. [19511] [INFO] Application startup complete. [19513] [INFO] Started server process [19513] [19513] [INFO] Waiting for application startup. [19513] [INFO] Application startup complete. [19514] [INFO] Started server process [19514] [19514] [INFO] Waiting for application startup. [19514] [INFO] Application startup complete. [19515] [INFO] Started server process [19515]
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Sat Mar 30 18:19:25 GMT 2024 - 10.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* The listener will run when the {@code Future}'s computation is {@linkplain Future#isDone() * complete} or, if the computation is already complete, immediately. * * <p>There is no guaranteed ordering of execution of listeners, but any listener added through * this method is guaranteed to be called once the computation is complete. * * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
docs/ko/docs/deployment/server-workers.md
[19511] [INFO] Waiting for application startup. [19511] [INFO] Application startup complete. [19513] [INFO] Started server process [19513] [19513] [INFO] Waiting for application startup. [19513] [INFO] Application startup complete. [19514] [INFO] Started server process [19514] [19514] [INFO] Waiting for application startup. [19514] [INFO] Application startup complete. [19515] [INFO] Started server process [19515]
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 10.2K bytes - Viewed (0)