Check peering. When this exists, we are definitely active
(self, timeout=None)
| 3047 | self.log("recovered!") |
| 3048 | |
| 3049 | def wait_for_active(self, timeout=None): |
| 3050 | """ |
| 3051 | Check peering. When this exists, we are definitely active |
| 3052 | """ |
| 3053 | self.log("waiting for peering to complete") |
| 3054 | start = time.time() |
| 3055 | num_active = self.get_num_active() |
| 3056 | while not self.is_active(): |
| 3057 | if timeout is not None: |
| 3058 | if time.time() - start >= timeout: |
| 3059 | self.log('dumping pgs not active') |
| 3060 | self.dump_pgs_not_active() |
| 3061 | assert time.time() - start < timeout, \ |
| 3062 | 'wait_for_active: failed before timeout expired' |
| 3063 | cur_active = self.get_num_active() |
| 3064 | if cur_active != num_active: |
| 3065 | start = time.time() |
| 3066 | num_active = cur_active |
| 3067 | time.sleep(3) |
| 3068 | self.log("active!") |
| 3069 | |
| 3070 | def wait_for_active_or_down(self, timeout=None): |
| 3071 | """ |