(final ChannelBuffer buf, final int cell_size)
| 1578 | } |
| 1579 | |
| 1580 | @Override |
| 1581 | Object deserialize(final ChannelBuffer buf, final int cell_size) { |
| 1582 | HBaseRpc.ensureNoCell(cell_size); |
| 1583 | final ScanResponse resp = readProtobuf(buf, ScanResponse.PARSER); |
| 1584 | final long id = resp.getScannerId(); |
| 1585 | if (scanner_id != id) { |
| 1586 | if (LOG.isDebugEnabled()) { |
| 1587 | LOG.debug("Scan RPC response was for scanner ID " + id |
| 1588 | + " but we expected " + scanner_id, resp); |
| 1589 | } |
| 1590 | //throw new InvalidResponseException("Scan RPC response was for scanner" |
| 1591 | // + " ID " + id + " but we expected" |
| 1592 | // + scanner_id, resp); |
| 1593 | } |
| 1594 | return null; |
| 1595 | } |
| 1596 | |
| 1597 | public String toString() { |
| 1598 | return "CloseScannerRequest(scanner_id=" + Bytes.hex(scanner_id) |
nothing calls this directly
no test coverage detected