(final byte server_version)
| 584 | } |
| 585 | |
| 586 | ChannelBuffer serialize(final byte server_version) { |
| 587 | /** Pre-serialized form for this RPC, which is always the same. */ |
| 588 | // num param + type 1 + string length + string + type 2 + long |
| 589 | final ChannelBuffer buf = newBuffer(server_version, |
| 590 | 4 + 1 + 1 + 44 + 1 + 8); |
| 591 | buf.writeInt(2); // Number of parameters. |
| 592 | // 1st param. |
| 593 | writeHBaseString(buf, "org.apache.hadoop.hbase.ipc.HRegionInterface"); |
| 594 | // 2nd param: what protocol version to speak. If we don't know what the |
| 595 | // server expects, try an old version first (0.90 and before). |
| 596 | // Otherwise tell the server we speak the same version as it does. |
| 597 | writeHBaseLong(buf, server_version == SERVER_VERSION_UNKNWON |
| 598 | ? SERVER_VERSION_090_AND_BEFORE : server_version); |
| 599 | return buf; |
| 600 | } |
| 601 | |
| 602 | @Override |
| 603 | Object deserialize(final ChannelBuffer buf, final int cell_size) { |
nothing calls this directly
no test coverage detected