- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 417 for timeouts (0.26 sec)
-
.github/actions/notify-translations/app/main.py
"discussion_id": discussion_id, "comment_id": comment_id, "body": body, } response = httpx.post( github_graphql_url, headers=headers, timeout=settings.httpx_timeout, json={"query": query, "variables": variables, "operationName": "Q"}, ) if response.status_code != 200: logging.error(
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Jul 29 23:35:07 UTC 2024 - 12.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
// SequentialExecutor by the time the barrier is satisfied barrier.await(1, SECONDS); executor.execute(barrierTask); // timeout means the second task wasn't even tried barrier.await(1, SECONDS); } finally { service.shutdown(); } } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 11.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/RequestBody.kt
* due to any of: * * * A stale connection. The request was made on a reused connection and that reused connection * has since been closed by the server. * * A client timeout (HTTP 408). * * A authorization challenge (HTTP 401 and 407) that is satisfied by the [Authenticator]. * * A retryable server failure (HTTP 503 with a `Retry-After: 0` response header).
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Jan 25 14:41:37 UTC 2024 - 9.6K bytes - Viewed (0) -
cmd/admin-handlers.go
if logKind == 0 { logKind = madmin.LogMaskAll } // Avoid reusing tcp connection if read timeout is hit // This is needed to make r.Context().Done() work as // expected in case of read timeout w.Header().Set("Connection", "close") setEventStreamHeaders(w) logCh := make(chan log.Info, 1000) peers, _ := newPeerRestClients(globalEndpoints)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
istioctl/pkg/authz/testdata/configdump.yaml
{ "match": { "prefix": "/" }, "route": { "cluster": "InboundPassthroughClusterIpv4", "timeout": "0s", "max_stream_duration": { "max_stream_duration": "0s", "grpc_timeout_header_max": "0s" } },
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jun 21 14:20:23 UTC 2023 - 206.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test import org.junit.jupiter.api.Timeout import org.junit.jupiter.api.extension.RegisterExtension @Flaky // STDOUT logging enabled for test @Timeout(30) @Tag("Slow") class EventListenerTest { @RegisterExtension val platform = PlatformRule() @RegisterExtension
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (2) -
tests/prepared_stmt_test.go
t.Fatalf("no error should happen but got %v", err) } user2 := *GetUser("prepared_stmt2", Config{}) if err := txCtx.Create(&user2).Error; err == nil { t.Fatalf("should failed to create with timeout context") } if err := tx.Create(&user2).Error; err != nil { t.Fatalf("failed to create, got error %v", err) } var result3 User if err := tx.Find(&result3, user2.ID).Error; err != nil {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:02:05 UTC 2024 - 8.5K bytes - Viewed (0) -
cmd/handler-api.go
// will be properly audited and traced. w.WriteHeader(499) default: globalHTTPStats.addRequestsInQueue(-1) if contextCanceled(ctx) { w.WriteHeader(499) return } // Send a http timeout message writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrTooManyRequests), r.URL) } } } func (t *apiConfig) getReplicationOpts() replicationPoolOpts { t.mu.RLock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 17:07:10 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
if err := healFreshDisk(ctx, z, disk); err != nil { globalBackgroundHealState.setDiskHealingStatus(disk, false) timedout := OperationTimedOut{} if !errors.Is(err, context.Canceled) && !errors.As(err, &timedout) && !errors.Is(err, errRetryHealing) { printEndpointError(disk, err, false) } return } // Only upon success pop the healed disk.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0) -
src/cmd/asm/internal/asm/operand_test.go
{"rcv_name+20(FP)", "rcv_name+20(FP)"}, {"retoffset+28(FP)", "retoffset+28(FP)"}, {"runtime·_GetStdHandle(SB)", "runtime._GetStdHandle(SB)"}, {"sync\u2215atomic·AddInt64(SB)", "sync/atomic.AddInt64(SB)"}, {"timeout+20(FP)", "timeout+20(FP)"}, {"ts+16(FP)", "ts+16(FP)"}, {"x+24(FP)", "x+24(FP)"}, {"x·y(SB)", "x.y(SB)"}, {"x·y(SP)", "x.y(SP)"}, {"x·y+8(SB)", "x.y+8(SB)"}, {"x·y+8(SP)", "x.y+8(SP)"}, {"y+56(FP)", "y+56(FP)"},
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Aug 29 18:31:05 UTC 2023 - 23.9K bytes - Viewed (0)