Search Options

Results per page
Sort
Preferred Languages
Advance

Results 331 - 340 of 417 for timeouts (0.07 sec)

  1. .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)
  2. 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)
  3. 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)
  4. 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)
  5. istioctl/pkg/authz/testdata/configdump.yaml

    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 21 14:20:23 UTC 2023
    - 206.7K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top