Fix a couple spots where we were missing checks for the new tag_throttled error
This commit is contained in:
parent
decf3e82b0
commit
6ce4ddf1db
|
@ -78,7 +78,7 @@ fdb_bool_t fdb_error_predicate( int predicate_test, fdb_error_t code ) {
|
|||
return code == error_code_not_committed || code == error_code_transaction_too_old ||
|
||||
code == error_code_future_version || code == error_code_database_locked ||
|
||||
code == error_code_proxy_memory_limit_exceeded || code == error_code_batch_transaction_throttled ||
|
||||
code == error_code_process_behind;
|
||||
code == error_code_process_behind || code == error_code_tag_throttled;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
|
|
@ -2899,8 +2899,11 @@ ACTOR static Future<Void> tryCommit( Database cx, Reference<TransactionLogInfo>
|
|||
&& e.code() != error_code_not_committed
|
||||
&& e.code() != error_code_database_locked
|
||||
&& e.code() != error_code_proxy_memory_limit_exceeded
|
||||
&& e.code() != error_code_batch_transaction_throttled)
|
||||
&& e.code() != error_code_batch_transaction_throttled
|
||||
&& e.code() != error_code_tag_throttled)
|
||||
{
|
||||
TraceEvent(SevError, "TryCommitError").error(e);
|
||||
}
|
||||
if (trLogInfo)
|
||||
trLogInfo->addLog(FdbClientLogEvents::EventCommitError(startTime, static_cast<int>(e.code()), req));
|
||||
throw;
|
||||
|
|
Loading…
Reference in New Issue