Try to create a socket, using an exponential backoff with a max retry time. Thanks to Robert Olson for the original patch (SF #815911) which has been slightly refactored.
(self)
| 596 | return result |
| 597 | |
| 598 | def createSocket(self): |
| 599 | """ |
| 600 | Try to create a socket, using an exponential backoff with |
| 601 | a max retry time. Thanks to Robert Olson for the original patch |
| 602 | (SF #815911) which has been slightly refactored. |
| 603 | """ |
| 604 | now = time.time() |
| 605 | # Either retryTime is None, in which case this |
| 606 | # is the first time back after a disconnect, or |
| 607 | # we've waited long enough. |
| 608 | if self.retryTime is None: |
| 609 | attempt = True |
| 610 | else: |
| 611 | attempt = (now >= self.retryTime) |
| 612 | if attempt: |
| 613 | try: |
| 614 | self.sock = self.makeSocket() |
| 615 | self.retryTime = None # next time, no delay before trying |
| 616 | except OSError: |
| 617 | #Creation failed, so set the retry time and return. |
| 618 | if self.retryTime is None: |
| 619 | self.retryPeriod = self.retryStart |
| 620 | else: |
| 621 | self.retryPeriod = self.retryPeriod * self.retryFactor |
| 622 | if self.retryPeriod > self.retryMax: |
| 623 | self.retryPeriod = self.retryMax |
| 624 | self.retryTime = now + self.retryPeriod |
| 625 | |
| 626 | def send(self, s): |
| 627 | """ |
no test coverage detected