| /dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/src/ |
| H A D | retry_policy.cpp | 123 RetryPolicy::RetryDecision
173 RetryPolicy::RetryDecision
224 RetryDecision decision = in on_read_timeout()
228 case RetryDecision::IGNORE: in on_read_timeout()
235 case RetryDecision::RETRY: in on_read_timeout()
254 RetryDecision decision = in on_write_timeout()
258 case RetryDecision::IGNORE: in on_write_timeout()
265 case RetryDecision::RETRY: in on_write_timeout()
285 case RetryDecision::IGNORE: in on_unavailable()
291 case RetryDecision::RETRY: in on_unavailable()
[all …]
|
| H A D | retry_policy.hpp | 42 class RetryDecision { class in datastax::internal::core::RetryPolicy
46 RetryDecision(Type type, CassConsistency retry_cl, bool retry_current_host) in RetryDecision() function in datastax::internal::core::RetryPolicy::RetryDecision
55 static RetryDecision return_error() { in return_error()
56 return RetryDecision(RETURN_ERROR, CASS_CONSISTENCY_UNKNOWN, false); in return_error()
59 static RetryDecision retry(CassConsistency cl) { return RetryDecision(RETRY, cl, true); } in retry()
61 static RetryDecision retry_next_host(CassConsistency cl) { in retry_next_host()
62 return RetryDecision(RETRY, cl, false); in retry_next_host()
65 static RetryDecision ignore() { return RetryDecision(IGNORE, CASS_CONSISTENCY_UNKNOWN, false); } in ignore()
88 virtual RetryDecision on_request_error(const Request* request, CassConsistency cl,
107 virtual RetryDecision on_request_error(const Request* request, CassConsistency cl,
[all …]
|
| H A D | request_handler.cpp | 582 RetryPolicy::RetryDecision decision = RetryPolicy::RetryDecision::return_error(); in on_error_response()
641 case RetryPolicy::RetryDecision::RETURN_ERROR: in on_error_response()
648 case RetryPolicy::RetryDecision::RETRY: in on_error_response()
658 case RetryPolicy::RetryDecision::IGNORE: in on_error_response()
|
| /dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/tests/src/unit/tests/ |
| H A D | test_retry_policies.cpp | 24 typedef RetryPolicy::RetryDecision RetryDecision; typedef
26 void check_decision(RetryDecision decision, RetryDecision::Type type, CassConsistency cl, in check_decision()
38 RetryDecision::RETRY, CASS_CONSISTENCY_QUORUM, true); in check_default()
54 RetryDecision::RETRY, CASS_CONSISTENCY_QUORUM, true); in check_default()
59 RetryDecision::RETURN_ERROR, CASS_CONSISTENCY_UNKNOWN, false); in check_default()
94 RetryDecision::RETRY, CASS_CONSISTENCY_TWO, true); in TEST()
98 RetryDecision::RETRY, CASS_CONSISTENCY_ONE, true); in TEST()
114 RetryDecision::IGNORE, CASS_CONSISTENCY_UNKNOWN, false); in TEST()
119 RetryDecision::IGNORE, CASS_CONSISTENCY_UNKNOWN, false); in TEST()
134 RetryDecision::RETRY, CASS_CONSISTENCY_QUORUM, true); in TEST()
[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 | RetryPolicy.java | 39 new RetryAction(RetryDecision.FAIL);
41 new RetryAction(RetryDecision.RETRY);
43 new RetryAction(RetryDecision.FAILOVER_AND_RETRY);
45 public final RetryDecision action;
49 public RetryAction(RetryDecision action) { in RetryAction()
53 public RetryAction(RetryDecision action, long delayTime) { in RetryAction()
57 public RetryAction(RetryDecision action, long delayTime, String reason) { in RetryAction()
69 public enum RetryDecision { enum in RetryPolicy.RetryAction
|
| H A D | RetryPolicies.java | 211 return new RetryAction(RetryAction.RetryDecision.RETRY, in shouldRetry()
326 return new RetryAction(RetryAction.RetryDecision.RETRY, sleepTime); in shouldRetry()
562 return new RetryAction(RetryAction.RetryDecision.FAIL, 0, in shouldRetry()
567 return new RetryAction(RetryAction.RetryDecision.FAIL, 0, "retries (" in shouldRetry()
577 return new RetryAction(RetryAction.RetryDecision.FAILOVER_AND_RETRY, in shouldRetry()
582 return new RetryAction(RetryAction.RetryDecision.RETRY, in shouldRetry()
589 return new RetryAction(RetryAction.RetryDecision.FAIL, 0, in shouldRetry()
|
| H A D | RetryInvocationHandler.java | 120 if (action.action == RetryAction.RetryDecision.FAIL) { in invoke()
134 if (action.action == RetryAction.RetryDecision.FAILOVER_AND_RETRY && in invoke()
158 if (action.action == RetryAction.RetryDecision.FAILOVER_AND_RETRY) { in invoke()
|
| /dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/tests/src/integration/policies/ |
| H A D | next_host_retry_policy.hpp | 45 RetryDecision on_read_timeout(const datastax::internal::core::Request* request, in on_read_timeout()
48 return RetryDecision::retry_next_host(cl); in on_read_timeout()
50 RetryDecision on_write_timeout(const datastax::internal::core::Request* request, in on_write_timeout()
53 return RetryDecision::retry_next_host(cl); in on_write_timeout()
55 virtual RetryDecision on_unavailable(const datastax::internal::core::Request* request, in on_unavailable()
58 return RetryDecision::retry_next_host(cl); in on_unavailable()
60 virtual RetryDecision on_request_error(const datastax::internal::core::Request* request, in on_request_error()
64 return RetryDecision::retry_next_host(cl); in on_request_error()
|
| H A D | ignore_retry_policy.hpp | 45 RetryDecision on_read_timeout(const datastax::internal::core::Request* request, in on_read_timeout()
48 return RetryDecision::ignore(); in on_read_timeout()
50 RetryDecision on_write_timeout(const datastax::internal::core::Request* request, in on_write_timeout()
53 return RetryDecision::ignore(); in on_write_timeout()
55 virtual RetryDecision on_unavailable(const datastax::internal::core::Request* request, in on_unavailable()
58 return RetryDecision::ignore(); in on_unavailable()
60 virtual RetryDecision on_request_error(const datastax::internal::core::Request* request, in on_request_error()
64 return RetryDecision::ignore(); in on_request_error()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/retry/ |
| H A D | TestDefaultRetryPolicy.java | 57 is(RetryPolicy.RetryAction.RetryDecision.RETRY)); in testWithRetriable()
79 is(RetryPolicy.RetryAction.RetryDecision.RETRY)); in testWithWrappedRetriable()
99 is(RetryPolicy.RetryAction.RetryDecision.FAIL)); in testWithRetriableAndRetryDisabled()
|
| /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 | 94 if (action.action == RetryPolicy.RetryAction.RetryDecision.RETRY) { in execute()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/web/ |
| H A D | WebHdfsFileSystem.java | 640 boolean isRetry = a.action == RetryPolicy.RetryAction.RetryDecision.RETRY; in shouldRetry()
642 a.action == RetryPolicy.RetryAction.RetryDecision.FAILOVER_AND_RETRY; in shouldRetry()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ |
| H A D | Client.java | 851 if (action.action == RetryAction.RetryDecision.FAIL) { in handleConnectionFailure()
|