Home
last modified time | relevance | path

Searched refs:retryPolicy (Results 1 – 25 of 675) sorted by relevance

12345678910>>...27

/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 DRMProxy.java91 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 DServerProxy.java66 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 Dtypes.go3 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 Dshard.cpp116 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 DRetriableCommand.java41 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 DRetriableCommand.java43 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 Dclient_test.go289 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 Dclient_test.go291 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 DRetryProxy.java40 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 DHttpRouteAction.php97 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 DSubscription.php147 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 Droutes.go121 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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 Dservice_config.go61 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{

12345678910>>...27