MCPcopy Create free account
hub / github.com/OpenTSDB/asynchbase / serialize

Method serialize

src/RegionClient.java:586–600  ·  view source on GitHub ↗
(final byte server_version)

Source from the content-addressed store, hash-verified

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) {

Callers

nothing calls this directly

Calls 3

newBufferMethod · 0.80
writeHBaseStringMethod · 0.80
writeHBaseLongMethod · 0.80

Tested by

no test coverage detected