tracker mode to handle handler ready.
(self, handler)
| 417 | self.loop.call_later(self.update_tracker_period, _callback) |
| 418 | |
| 419 | def _handler_ready_tracker_mode(self, handler): |
| 420 | """tracker mode to handle handler ready.""" |
| 421 | if handler.rpc_key.startswith("server:"): |
| 422 | key = base.random_key(handler.match_key, cmap=self._server_pool) |
| 423 | handler.match_key = key |
| 424 | self._server_pool[key] = handler |
| 425 | self._tracker_pending_puts.append(key) |
| 426 | self._update_tracker() |
| 427 | else: |
| 428 | if handler.match_key in self._server_pool: |
| 429 | self._pair_up(self._server_pool.pop(handler.match_key), handler) |
| 430 | else: |
| 431 | handler.send_data(struct.pack("<i", base.RPC_CODE_MISMATCH)) |
| 432 | handler.signal_close() |
| 433 | |
| 434 | def _handler_ready_proxy_mode(self, handler): |
| 435 | """Normal proxy mode when handler is ready.""" |
no test coverage detected