Common part of the hello header: magic + version.
(final byte[] buf, final byte[] hrpc)
| 2099 | |
| 2100 | /** Common part of the hello header: magic + version. */ |
| 2101 | private ChannelBuffer commonHeader(final byte[] buf, final byte[] hrpc) { |
| 2102 | final ChannelBuffer header = ChannelBuffers.wrappedBuffer(buf); |
| 2103 | header.clear(); // Set the writerIndex to 0. |
| 2104 | |
| 2105 | // Magic header. See HBaseClient#writeHeader |
| 2106 | // "hrpc" followed by the version. |
| 2107 | // See HBaseServer#HEADER and HBaseServer#CURRENT_VERSION. |
| 2108 | header.writeBytes(hrpc); // for 0.94 and earlier: 4 + 1. For 0.95+: 4 + 2 |
| 2109 | return header; |
| 2110 | } |
| 2111 | |
| 2112 | /** Hello header for HBase 0.95 and later. */ |
| 2113 | private ChannelBuffer header095() { |
no test coverage detected