- Sort Score
- Result 10 results
- Languages All
Results 261 - 270 of 377 for timeouts (0.1 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
.headersDelay(500, TimeUnit.MILLISECONDS) .setHeader("content-type", "text/event-stream") .body("data: hey\n\n") .build(), ) newEventSource() listener.assertFailure("timeout") } @Test fun retainsAccept() { server.enqueue( MockResponse.Builder() .body( """ |data: hey | |
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 6.6K bytes - Viewed (0) -
cmd/globals.go
globalDomainIPs set.StringSet // Root domain IP address(s) for a distributed MinIO deployment globalOperationTimeout = newDynamicTimeout(10*time.Minute, 5*time.Minute) // default timeout for general ops globalDeleteOperationTimeout = newDynamicTimeout(5*time.Minute, 1*time.Minute) // default time for delete ops globalBucketObjectLockSys *BucketObjectLockSys globalBucketQuotaSys *BucketQuotaSys
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (0) -
cmd/admin-heal-ops.go
) const ( // a heal sequence with this many un-consumed heal result // items blocks until heal-status consumption resumes or is // aborted due to timeout. maxUnconsumedHealResultItems = 1000 // if no heal-results are consumed (via the heal-status API) // for this timeout duration, the heal sequence is aborted. healUnconsumedTimeout = 24 * time.Hour // time-duration to keep heal sequence state after it // completes.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
public void testTimeoutOnGetWorksCorrectly() throws InterruptedException, ExecutionException { // The task thread waits for the latch, so we expect a timeout here. try { future.get(20, MILLISECONDS); fail("Should have timed out trying to get the value."); } catch (TimeoutException expected) { } finally { latch.countDown(); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
buildscripts/verify-healing.sh
disown $pid2 "${MINIO[@]}" --address ":$((start_port + 3))" $args >"${WORK_DIR}/dist-minio-server3.log" 2>&1 & pid3=$! disown $pid3 export MC_HOST_myminio="http://minio:minio123@127.0.0.1:$((start_port + 1))" timeout 15m /tmp/mc ready myminio || fail [ ${first_time} -eq 0 ] && upload_objects [ ${first_time} -ne 0 ] && sleep 120 if ! ps -p $pid1 1>&2 >/dev/null; then echo "minio server 1 is not running" && fail fi
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 4K bytes - Viewed (0) -
.github/workflows/codeql.yml
# Consider using larger runners or machines with greater resources for possible analysis time improvements. runs-on: ${{ (matrix.language == 'swift' && 'macos-latest') || 'ubuntu-latest' }} timeout-minutes: ${{ (matrix.language == 'swift' && 120) || 360 }} permissions: # required for all workflows security-events: write # required to fetch internal or private CodeQL packs packages: read
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Wed Aug 14 23:51:19 UTC 2024 - 4.4K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
*/ object StallSocketAtStart : SocketPolicy /** * Read the request but don't respond to it. Just keep the socket open. For testing read response * header timeout issue. */ object NoResponse : SocketPolicy /** * Fail HTTP/2 requests without processing them by sending [http2ErrorCode]. */ @ExperimentalOkHttpApi class ResetStreamAtStart(
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 4.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/PythonJob.java
} if (exitValue != 0) { final StringBuilder out = new StringBuilder(); if (processTimeout) { out.append("Process is terminated due to ").append(timeout).append(" second exceeded.\n"); } out.append("Exit Code: ").append(exitValue).append("\nOutput:\n").append(it.getOutput()); throw new JobProcessingException(out.toString());
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 5.9K bytes - Viewed (0) -
internal/grid/debug.go
// Call (TestGrid).Cleanup() when done. func SetupTestGrid(n int) (*TestGrid, error) { hosts, listeners, err := getHosts(n) if err != nil { return nil, err } dialer := &net.Dialer{ Timeout: 5 * time.Second, } var res TestGrid res.Hosts = hosts ready := make(chan struct{}) ctx, cancel := context.WithCancel(context.Background()) res.cancel = cancel for i, host := range hosts {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 4.4K bytes - Viewed (0) -
src/main/webapp/js/bootstrap.min.js
Element()).hasClass(Me))return void this._leave(null,this);this._enter(null,this)}},t.dispose=function(){clearTimeout(this._timeout),g.removeData(this.element,this.constructor.DATA_KEY),g(this.element).off(this.constructor.EVENT_KEY),g(this.element).closest(".modal").off("hide.bs.modal",this._hideModalHandler),this.tip&&g(this.tip).remove(),this._isEnabled=null,this._timeout=null,this._hoverState=null,this._activeTrigger=null,this._popper&&this._popper.destroy(),this._popper=null,this.element=nu...
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Feb 07 10:28:50 UTC 2020 - 58.6K bytes - Viewed (0)