| 640 | } |
| 641 | |
| 642 | #getDelayThreshold() { |
| 643 | if (!process.env.RETRY_DELAY_THRESHOLD_IN_MS) { |
| 644 | return DEFAULT_RETRY_DELAY_THRESHOLD_IN_MS; |
| 645 | } |
| 646 | |
| 647 | const threshold = parseInt(process.env.RETRY_DELAY_THRESHOLD_IN_MS); |
| 648 | |
| 649 | if (isNaN(threshold)) { |
| 650 | logger.log( |
| 651 | "RETRY_DELAY_THRESHOLD_IN_MS parses as NaN, must supply integer. Will use default instead.", |
| 652 | { |
| 653 | RETRY_DELAY_THRESHOLD_IN_MS: process.env.RETRY_DELAY_THRESHOLD_IN_MS, |
| 654 | DEFAULT_DELAY_THRESHOLD_IN_MS: DEFAULT_RETRY_DELAY_THRESHOLD_IN_MS, |
| 655 | } |
| 656 | ); |
| 657 | return DEFAULT_RETRY_DELAY_THRESHOLD_IN_MS; |
| 658 | } |
| 659 | |
| 660 | return threshold; |
| 661 | } |
| 662 | |
| 663 | #createPlatformSocket() { |
| 664 | if (!PLATFORM_ENABLED) { |