(self, codec)
| 71 | pass |
| 72 | |
| 73 | def _process_request(self, codec): |
| 74 | info = codec.start_read_message() |
| 75 | if info.type not in [MessageType.kInvocationMessage, MessageType.kOnewayMessage]: |
| 76 | raise RequestError("invalid type of incoming request") |
| 77 | |
| 78 | service = self.get_service_with_id(info.service) |
| 79 | if service is None: |
| 80 | raise RequestError("invalid service ID (%d)" % info.service) |
| 81 | service.handle_invocation(info.request, info.sequence, codec) |
| 82 | |
| 83 | if info.type is MessageType.kOnewayMessage: |
| 84 | codec.reset() |
no test coverage detected