- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 95 for Finish (0.16 sec)
-
okhttp/src/test/java/okhttp3/DispatcherTest.kt
a2.cancel() a3.cancel() assertThat(dispatcher.runningCalls()) .containsExactlyInAnyOrder(a1, a2) assertThat(dispatcher.queuedCalls()).isEmpty() // Let the calls finish. waiting.countDown() t1.join() t2.join() // Now we should have 0 running calls and 0 queued calls. assertThat(dispatcher.runningCallsCount()).isEqualTo(0)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Apr 05 03:30:42 GMT 2024 - 12.7K bytes - Viewed (0) -
cmd/erasure-multipart.go
g.Go(func() error { if disks[index] == nil { return errDiskNotFound } return disks[index].RenameFile(ctx, srcBucket, srcEntry, dstBucket, dstEntry) }, index) } // Wait for all renames to finish. errs := g.Wait() // Do not need to undo partial successful operation since those will be cleaned up // in 24hrs via multipart cleaner, never rename() back to `.minio.sys/tmp` as there // is no way to clean them.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/project/DefaultProjectBuilder.java
// We need an executor that will not block. // We can't use work stealing, as we are building a graph // and this could lead to cycles where a thread waits for // a task to finish, then execute another one which waits // for the initial task... // In order to work around that problem, we override the // invokeAll method, so that whenever the method is called,
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 56.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} throw IllegalStateException("too early; can't read the trailers yet") } } /** * Sends a reply to an incoming stream. * * @param outFinished true to eagerly finish the output stream to send data to the remote peer. * Corresponds to `FLAG_FIN`. * @param flushHeaders true to force flush the response headers. This should be true unless the
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
* * This test yields threads to force the decision of plan1 to be deliberate and not lucky. In * particular, we set up this sequence of events: * * 1. take plan 0 * 3. plan 0 connects * 4. finish taking plan 1 * * https://github.com/square/okhttp/issues/7152 */ @Test fun reusePlanAndNewConnectRace() { val plan0 = routePlanner.addPlan() plan0.tcpConnectDelayNanos = 250.ms
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
internal/logger/target/http/http.go
atomic.StoreInt32(&h.status, statusClosed) h.storeCtxCancel() // Wait for messages to be sent... h.wg.Wait() // Set logch to nil and close it. // This will block all Send operations, // and finish the existing ones. // All future ones will be discarded. h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
src/main/webapp/js/admin/jquery-3.6.3.min.js
t].anim.stop(o),e=!1,n.splice(t,1));!e&&o||E.dequeue(this,i)})},finish:function(a){return!1!==a&&(a=a||"fx"),this.each(function(){var e,t=Y.get(this),n=t[a+"queue"],r=t[a+"queueHooks"],i=E.timers,o=n?n.length:0;for(t.finish=!0,E.queue(this,a,[]),r&&r.stop&&r.stop.call(this,!0),e=i.length;e--;)i[e].elem===this&&i[e].queue===a&&(i[e].anim.stop(!0),i.splice(e,1));for(e=0;e<o;e++)n[e]&&n[e].finish&&n[e].finish.call(this);delete t.finish})}}),E.each(["toggle","show","hide"],function(e,r){var i=E.fn[r...
JavaScript - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Fri Feb 17 12:13:41 GMT 2023 - 87.8K bytes - Viewed (3) -
src/main/webapp/js/jquery-3.6.3.min.js
t].anim.stop(o),e=!1,n.splice(t,1));!e&&o||E.dequeue(this,i)})},finish:function(a){return!1!==a&&(a=a||"fx"),this.each(function(){var e,t=Y.get(this),n=t[a+"queue"],r=t[a+"queueHooks"],i=E.timers,o=n?n.length:0;for(t.finish=!0,E.queue(this,a,[]),r&&r.stop&&r.stop.call(this,!0),e=i.length;e--;)i[e].elem===this&&i[e].queue===a&&(i[e].anim.stop(!0),i.splice(e,1));for(e=0;e<o;e++)n[e]&&n[e].finish&&n[e].finish.call(this);delete t.finish})}}),E.each(["toggle","show","hide"],function(e,r){var i=E.fn[r...
JavaScript - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Fri Feb 17 12:13:41 GMT 2023 - 87.8K bytes - Viewed (5) -
cmd/format-erasure.go
g.Go(func() error { if formats[index] == nil { return errDiskNotFound } return saveFormatErasure(storageDisks[index], formats[index], "") }, index) } // Wait for the routines to finish. return reduceWriteQuorumErrs(ctx, g.Wait(), nil, len(storageDisks)) } // relinquishes the underlying connection for all storage disks. func closeStorageDisks(storageDisks ...StorageAPI) { var wg sync.WaitGroup
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
do { try { send(request, response, config.getNetbiosRetryTimeout()); } catch ( InterruptedIOException ioe ) { // second query thread to finish gets interrupted so this is expected if ( log.isTraceEnabled() ) { log.trace("Failed to send nameservice request for " + name.name, ioe); }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Aug 14 14:26:22 GMT 2022 - 38.2K bytes - Viewed (0)