(self)
| 182 | self.curprio = priority |
| 183 | |
| 184 | def pop(self) -> Request | None: |
| 185 | while self.curprio is not None: |
| 186 | try: |
| 187 | q = self.queues[self.curprio] |
| 188 | except KeyError: |
| 189 | pass |
| 190 | else: |
| 191 | m = q.pop() |
| 192 | if not q: |
| 193 | del self.queues[self.curprio] |
| 194 | q.close() |
| 195 | if not self._start_queues: |
| 196 | self._update_curprio() |
| 197 | return m |
| 198 | if self._start_queues: |
| 199 | try: |
| 200 | q = self._start_queues[self.curprio] |
| 201 | except KeyError: |
| 202 | self._update_curprio() |
| 203 | else: |
| 204 | m = q.pop() |
| 205 | if not q: |
| 206 | del self._start_queues[self.curprio] |
| 207 | q.close() |
| 208 | self._update_curprio() |
| 209 | return m |
| 210 | else: |
| 211 | self._update_curprio() |
| 212 | return None |
| 213 | |
| 214 | def _update_curprio(self) -> None: |
| 215 | prios = { |
nothing calls this directly
no test coverage detected