/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/ |
H A D | RMProxy.java | 91 RetryPolicy retryPolicy = createRetryPolicy(conf); in createRMProxy() local 95 return (T) RetryProxy.create(protocol, provider, retryPolicy); in createRMProxy() 100 return (T) RetryProxy.create(protocol, proxy, retryPolicy); in createRMProxy() 122 RetryPolicy retryPolicy = createRetryPolicy(conf); in createRMProxy() local 125 return (T) RetryProxy.create(protocol, proxy, retryPolicy); in createRMProxy() 233 RetryPolicy retryPolicy = null; 235 retryPolicy = RetryPolicies.RETRY_FOREVER; 237 retryPolicy = 245 exceptionToPolicyMap.put(EOFException.class, retryPolicy); 246 exceptionToPolicyMap.put(ConnectException.class, retryPolicy); [all …]
|
H A D | ServerProxy.java | 66 RetryPolicy retryPolicy = in createRetryPolicy() local 72 exceptionToPolicyMap.put(EOFException.class, retryPolicy); in createRetryPolicy() 73 exceptionToPolicyMap.put(ConnectException.class, retryPolicy); in createRetryPolicy() 74 exceptionToPolicyMap.put(NoRouteToHostException.class, retryPolicy); in createRetryPolicy() 75 exceptionToPolicyMap.put(UnknownHostException.class, retryPolicy); in createRetryPolicy() 76 exceptionToPolicyMap.put(RetriableException.class, retryPolicy); in createRetryPolicy() 77 exceptionToPolicyMap.put(SocketException.class, retryPolicy); in createRetryPolicy() 78 exceptionToPolicyMap.put(NMNotYetReadyException.class, retryPolicy); in createRetryPolicy() 88 RetryPolicy retryPolicy) { in createRetriableProxy() argument 95 return (T) RetryProxy.create(protocol, proxy, retryPolicy); in createRetriableProxy()
|
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/github.com/quobyte/api/ |
H A D | types.go | 3 type retryPolicy struct { struct 17 retryPolicy anonMember 28 retryPolicy anonMember 45 retryPolicy anonMember 77 retryPolicy anonMember 82 retryPolicy anonMember 104 retryPolicy anonMember
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/client/ |
H A D | shard.cpp | 116 RetryPolicy retryPolicy) { in runCommand() argument 117 return runCommand(opCtx, readPref, dbName, cmdObj, Milliseconds::max(), retryPolicy); in runCommand() 125 RetryPolicy retryPolicy) { in runCommand() argument 134 if (isRetriableError(status.code(), retryPolicy)) { in runCommand() 151 RetryPolicy retryPolicy) { in runCommandWithFixedRetryAttempts() argument 153 opCtx, readPref, dbName, cmdObj, Milliseconds::max(), retryPolicy); in runCommandWithFixedRetryAttempts() 162 RetryPolicy retryPolicy) { in runCommandWithFixedRetryAttempts() argument 171 if (retry < kOnErrorNumRetries && isRetriableError(status.code(), retryPolicy)) { in runCommandWithFixedRetryAttempts() 186 RetryPolicy retryPolicy) { in runBatchWriteCommand() argument 198 if (retry < kOnErrorNumRetries && isRetriableError(writeStatus.code(), retryPolicy)) { in runBatchWriteCommand()
|
/dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/distcp2/util/ |
H A D | RetriableCommand.java | 41 private RetryPolicy retryPolicy = RetryPolicies. field in RetriableCommand 58 public RetriableCommand(String description, RetryPolicy retryPolicy) { in RetriableCommand() argument 60 setRetryPolicy(retryPolicy); in RetriableCommand() 91 } while (retryPolicy.shouldRetry(latestException, counter)); in execute() 103 this.retryPolicy = retryHandler; in setRetryPolicy()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/util/ |
H A D | RetriableCommand.java | 43 private RetryPolicy retryPolicy = RetryPolicies. field in RetriableCommand 60 public RetriableCommand(String description, RetryPolicy retryPolicy) { in RetriableCommand() argument 62 setRetryPolicy(retryPolicy); in RetriableCommand() 93 RetryAction action = retryPolicy.shouldRetry(latestException, counter, 0, true); in execute() 111 this.retryPolicy = retryHandler; in setRetryPolicy()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/oracle/oci-go-sdk/common/ |
H A D | client_test.go | 289 retryPolicy *RetryPolicy member 300 return request.retryPolicy 326 retryPolicy := NewRetryPolicy(totalNumberAttempts, shouldRetryOperation, getNextDuration) 328 retryPolicy: &retryPolicy, 359 retryPolicy := NewRetryPolicy(totalNumberAttempts, shouldRetryOperation, getNextDuration) 361 retryPolicy: &retryPolicy, 393 retryPolicy := NewRetryPolicy(totalNumberAttempts, shouldRetryOperation, getNextDuration) 395 retryPolicy: &retryPolicy, 404 response, err := Retry(ctx, retryableRequest, fakeOperation, retryPolicy) 437 retryPolicy: &retryPolicy, [all …]
|
/dports/security/lego/lego-4.5.3/vendor/github.com/oracle/oci-go-sdk/common/ |
H A D | client_test.go | 291 retryPolicy *RetryPolicy member 302 return request.retryPolicy 329 retryPolicy := NewRetryPolicy(totalNumberAttempts, shouldRetryOperation, getNextDuration) 331 retryPolicy: &retryPolicy, 363 retryPolicy := NewRetryPolicy(totalNumberAttempts, shouldRetryOperation, getNextDuration) 365 retryPolicy: &retryPolicy, 397 retryPolicy := NewRetryPolicy(totalNumberAttempts, shouldRetryOperation, getNextDuration) 399 retryPolicy: &retryPolicy, 408 response, err := Retry(ctx, retryableRequest, fakeOperation, retryPolicy) 441 retryPolicy: &retryPolicy, [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/ |
H A D | RetryProxy.java | 40 RetryPolicy retryPolicy) { in create() argument 43 retryPolicy); in create() 57 FailoverProxyProvider<T> proxyProvider, RetryPolicy retryPolicy) { in create() argument 61 new RetryInvocationHandler<T>(proxyProvider, retryPolicy) in create()
|
/dports/www/owncloud/owncloud/apps/files_external/3rdparty/google/apiclient-services/src/Google/Service/Compute/ |
H A D | HttpRouteAction.php | 97 public function setRetryPolicy(Google_Service_Compute_HttpRetryPolicy $retryPolicy) argument 99 $this->retryPolicy = $retryPolicy; 106 return $this->retryPolicy;
|
/dports/www/owncloud/owncloud/apps/files_external/3rdparty/google/apiclient-services/src/Google/Service/Pubsub/ |
H A D | Subscription.php | 147 public function setRetryPolicy(Google_Service_Pubsub_RetryPolicy $retryPolicy) argument 149 $this->retryPolicy = $retryPolicy; 156 return $this->retryPolicy;
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/agent/xds/ |
H A D | routes.go | 121 retryPolicy := &envoyroute.RetryPolicy{} 123 retryPolicy.NumRetries = makeUint32Value(int(destination.NumRetries)) 128 retryPolicy.RetryOn = "connect-failure" 131 if retryPolicy.RetryOn != "" { 132 retryPolicy.RetryOn = ",retriable-status-codes" 134 retryPolicy.RetryOn = "retriable-status-codes" 136 retryPolicy.RetriableStatusCodes = destination.RetryOnStatusCodes 139 routeAction.Route.RetryPolicy = retryPolicy
|
/dports/databases/prometheus-postgresql-adapter/prometheus-postgresql-adapter-0.6.0/vendor/github.com/prometheus/prometheus/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 113 type retryPolicy struct { struct 275 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 311 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 333 rp := &retryPolicy{
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 116 type retryPolicy struct { struct 276 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 312 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 334 rp := &retryPolicy{
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 113 type retryPolicy struct { struct 275 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 311 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 333 rp := &retryPolicy{
|
/dports/sysutils/go-wtf/wtf-0.21.0/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 116 type retryPolicy struct { struct 276 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 312 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 334 rp := &retryPolicy{
|
/dports/sysutils/go-wtf/wtf-0.21.0/vendor/google.golang.org/grpc/grpc-go-1.21.1/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 116 type retryPolicy struct { struct 276 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 312 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 334 rp := &retryPolicy{
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/hashicorp/consul/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 104 type retryPolicy struct { struct 261 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 297 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 319 rp := &retryPolicy{
|
/dports/misc/perkeep/perkeep-0.11/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 116 type retryPolicy struct { struct 276 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 312 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 334 rp := &retryPolicy{
|
/dports/www/fabio/fabio-1.5.14/vendor/google.golang.org/grpc/grpc-go-1.16.0/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 104 type retryPolicy struct { struct 264 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 300 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 322 rp := &retryPolicy{
|
/dports/www/fabio/fabio-1.5.14/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 104 type retryPolicy struct { struct 264 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 300 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 322 rp := &retryPolicy{
|
/dports/www/fabio/fabio-1.5.14/vendor/github.com/hashicorp/consul/consul-1.4.2/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 104 type retryPolicy struct { struct 261 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 297 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 319 rp := &retryPolicy{
|
/dports/net/bosh-cli/bosh-cli-5.5.0/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 116 type retryPolicy struct { struct 276 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 312 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 334 rp := &retryPolicy{
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/go-gcp-common/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 113 type retryPolicy struct { struct 275 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 311 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 333 rp := &retryPolicy{
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/vendor/google.golang.org/grpc/ |
H A D | service_config.go | 61 retryPolicy *retryPolicy member 104 type retryPolicy struct { struct 261 if mc.retryPolicy, err = convertRetryPolicy(m.RetryPolicy); err != nil { 297 func convertRetryPolicy(jrp *jsonRetryPolicy) (p *retryPolicy, err error) { 319 rp := &retryPolicy{
|