- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 100 for Setrtable (0.39 sec)
-
src/net/tcpsockopt_openbsd.go
func setKeepAliveIdle(_ *netFD, d time.Duration) error { if d < 0 { return nil } // OpenBSD has no user-settable per-socket TCP keepalive // options. return syscall.ENOPROTOOPT } func setKeepAliveInterval(_ *netFD, d time.Duration) error { if d < 0 { return nil } // OpenBSD has no user-settable per-socket TCP keepalive // options. return syscall.ENOPROTOOPT }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 759 bytes - Viewed (0) -
pilot/pkg/networking/core/route/retry/retry.go
out.RetryOn, out.RetriableStatusCodes = parseRetryOn(in.RetryOn) // If user has just specified HTTP status codes in retryOn but have not specified "retriable-status-codes", let us add it. if len(out.RetriableStatusCodes) > 0 && !strings.Contains(out.RetryOn, "retriable-status-codes") { out.RetryOn += ",retriable-status-codes" } } if in.PerTryTimeout != nil { out.PerTryTimeout = in.PerTryTimeout }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 5K bytes - Viewed (0) -
src/runtime/pprof/vminfo_darwin_test.go
} } func useVMMapWithRetry(t *testing.T) (hi, lo uint64, err error) { var retryable bool for { hi, lo, retryable, err = useVMMap(t) if err == nil { return hi, lo, nil } if !retryable { return 0, 0, err } t.Logf("retrying vmmap after error: %v", err) } } func useVMMap(t *testing.T) (hi, lo uint64, retryable bool, err error) { pid := strconv.Itoa(os.Getpid())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 16 19:59:50 UTC 2024 - 5.5K bytes - Viewed (0) -
src/internal/types/testdata/check/funcinference.go
p := PT(&result[i]) // PT has a Set method. p.Set(v) } return result } type Settable int func (p *Settable) Set(s string) { i, _ := strconv.Atoi(s) // real code should not ignore the error *p = Settable(i) } var _ = FromStrings[Settable]([]string{"1", "2"}) // Suitable error message when the type parameter is provided (rather than inferred).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 01 21:01:45 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/util/iptables/testing/fake.go
f.hasRandomFully = can return f } // EnsureChain is part of iptables.Interface func (f *FakeIPTables) EnsureChain(table iptables.Table, chain iptables.Chain) (bool, error) { t, err := f.Dump.GetTable(table) if err != nil { return false, err } if c, _ := f.Dump.GetChain(table, chain); c != nil { return true, nil } t.Chains = append(t.Chains, Chain{Name: chain}) return false, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 8.5K bytes - Viewed (0) -
pkg/kubelet/config/file_linux.go
if backOff.IsInBackOffSinceUpdate(backOffID, time.Now()) { return } if err := s.doWatch(); err != nil { klog.ErrorS(err, "Unable to read config path", "path", s.path) if _, retryable := err.(*retryableError); !retryable { backOff.Next(backOffID, time.Now()) } } }, retryPeriod) } func (s *sourceFile) doWatch() error { _, err := os.Stat(s.path) if err != nil { if !os.IsNotExist(err) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 17:27:26 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
p2 := corev1helpers.PodPriority(pod2) if p1 != p2 { return p1 > p2 } return GetPodStartTime(pod1).Before(GetPodStartTime(pod2)) } // Retriable defines the retriable errors during a scheduling cycle. func Retriable(err error) bool { return apierrors.IsInternalError(err) || apierrors.IsServiceUnavailable(err) || net.IsConnectionRefused(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
pilot/pkg/networking/core/route/retry/retry_test.go
}, }, { name: "TestRetryOnWithRetriableStatusCodes", // Create a route with a retry policy with retriable status code. route: &networking.HTTPRoute{ Retries: &networking.HTTPRetry{ // Explicitly not retrying. Attempts: 2, RetryOn: "gateway-error,retriable-status-codes,503", }, }, assertFunc: func(g *WithT, policy *envoyroute.RetryPolicy) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 7.7K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/testdata/routes/k8s-gateway-http-route-path-prefix/configdump.json
"cluster": "outbound|8000||httpbin.default.svc.cluster.local", "timeout": "0s", "retry_policy": { "retry_on": "connect-failure,refused-stream,unavailable,cancelled,retriable-status-codes", "num_retries": 2, "retry_host_predicate": [ { "name": "envoy.retry_host_predicates.previous_hosts", "typed_config": {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 29 12:37:14 UTC 2023 - 3.1K bytes - Viewed (0) -
cmd/os-reliable.go
func reliableRemoveAll(dirPath string) (err error) { i := 0 for { // Removes all the directories and files. if err = RemoveAll(dirPath); err != nil { // Retry only for the first retryable error. if isSysErrNotEmpty(err) && i == 0 { i++ continue } } break } return err } // Wrapper functions to os.MkdirAll, which calls reliableMkdirAll
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Apr 22 17:49:30 UTC 2024 - 5.8K bytes - Viewed (0)