(final ChannelBuffer buf, final int cell_size)
| 240 | } |
| 241 | |
| 242 | @Override |
| 243 | Boolean deserialize(final ChannelBuffer buf, final int cell_size) { |
| 244 | HBaseRpc.ensureNoCell(cell_size); |
| 245 | final MutateResponse resp = readProtobuf(buf, MutateResponse.PARSER); |
| 246 | if (!resp.hasProcessed()) { |
| 247 | throw new InvalidResponseException( |
| 248 | "After a CAS on " + put + ", the protobuf in the response didn't " |
| 249 | + "contain the field indicating whether the CAS was successful or not", |
| 250 | resp); |
| 251 | } |
| 252 | return resp.getProcessed(); |
| 253 | } |
| 254 | |
| 255 | } |
nothing calls this directly
no test coverage detected