|
7 | 7 | "context" |
8 | 8 | "fmt" |
9 | 9 | "log" |
10 | | - "strconv" |
11 | 10 | "strings" |
12 | 11 | "time" |
13 | 12 |
|
@@ -451,7 +450,7 @@ func (s *DatabaseDbHomeResourceCrud) Create() error { |
451 | 450 |
|
452 | 451 | // Special override to ensure that CreateDbHome retries for the duration of the Terraform configured Create timeout |
453 | 452 | // The underlying db system or vm cluster may be in an updating state. So keep retrying the CreateDbHome. |
454 | | - createDbHomeRetryDurationFn := getDbHomeRetryDurationFunction(s.D.Timeout(schema.TimeoutCreate)) |
| 453 | + createDbHomeRetryDurationFn := tfresource.GetDbHomeRetryDurationFunction(s.D.Timeout(schema.TimeoutCreate)) |
455 | 454 |
|
456 | 455 | request.RequestMetadata.RetryPolicy = tfresource.GetRetryPolicy(s.DisableNotFoundRetries, "database", createDbHomeRetryDurationFn) |
457 | 456 |
|
@@ -616,7 +615,7 @@ func (s *DatabaseDbHomeResourceCrud) Delete() error { |
616 | 615 |
|
617 | 616 | // Special override to ensure that DeleteDbHome retries for the duration of the Terraform configured Create timeout |
618 | 617 | // The underlying db system or vm cluster may be in an updating state. So keep retrying it. |
619 | | - deleteDbHomeRetryDurationFn := getDbHomeRetryDurationFunction(s.D.Timeout(schema.TimeoutDelete)) |
| 618 | + deleteDbHomeRetryDurationFn := tfresource.GetDbHomeRetryDurationFunction(s.D.Timeout(schema.TimeoutDelete)) |
620 | 619 | request.RequestMetadata.RetryPolicy = tfresource.GetRetryPolicy(s.DisableNotFoundRetries, "database", deleteDbHomeRetryDurationFn) |
621 | 620 |
|
622 | 621 | dbErr := s.deleteNestedDB() |
@@ -1404,30 +1403,3 @@ func (s *DatabaseDbHomeResourceCrud) mapToUpdateDbBackupConfig(fieldKeyFormat st |
1404 | 1403 |
|
1405 | 1404 | return result, nil |
1406 | 1405 | } |
1407 | | - |
1408 | | -func getDbHomeRetryDurationFunction(retryTimeout time.Duration) expectedRetryDurationFn { |
1409 | | - return func(response oci_common.OCIOperationResponse, disableNotFoundRetries bool, service string, optionals ...interface{}) time.Duration { |
1410 | | - defaultRetryTime := tfresource.GetDefaultExpectedRetryDuration(response, disableNotFoundRetries) |
1411 | | - if response.Response == nil || response.Response.HTTPResponse() == nil { |
1412 | | - return defaultRetryTime |
1413 | | - } |
1414 | | - e := response.Error |
1415 | | - switch statusCode := response.Response.HTTPResponse().StatusCode; statusCode { |
1416 | | - case 409: |
1417 | | - if isDisable409Retry, _ := strconv.ParseBool(utils.GetEnvSettingWithDefault("disable_409_retry", "false")); isDisable409Retry { |
1418 | | - log.Printf("[ERROR] Resource is in conflict state due to multiple update request: %v", e.Error()) |
1419 | | - return 0 |
1420 | | - } |
1421 | | - if e := response.Error; e != nil { |
1422 | | - if strings.Contains(e.Error(), "IncorrectState") { |
1423 | | - defaultRetryTime = retryTimeout |
1424 | | - } else if strings.Contains(e.Error(), "InvalidatedRetryToken") { |
1425 | | - defaultRetryTime = 0 |
1426 | | - } else { |
1427 | | - defaultRetryTime = tfresource.LongRetryTime |
1428 | | - } |
1429 | | - } |
1430 | | - } |
1431 | | - return defaultRetryTime |
1432 | | - } |
1433 | | -} |
0 commit comments