Home
last modified time | relevance | path

Searched refs:RPC_HEADER (Results 1 – 4 of 4) sorted by relevance

/dports/databases/hbase/hbase-1.2.1/hbase-common/src/main/java/org/apache/hadoop/hbase/
H A DHConstants.java64 public static final byte[] RPC_HEADER = new byte[] { 'H', 'B', 'a', 's' }; field in HConstants
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/
H A DRpcClientImpl.java803 int rpcHeaderLen = HConstants.RPC_HEADER.length; in writeConnectionHeaderPreamble()
805 System.arraycopy(HConstants.RPC_HEADER, 0, preamble, 0, rpcHeaderLen); in writeConnectionHeaderPreamble()
H A DAsyncRpcChannel.java527 byteBuf.writeBytes(HConstants.RPC_HEADER);
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/
H A DRpcServer.java1476 if (!Arrays.equals(HConstants.RPC_HEADER, dataLengthBuffer.array())) { in readPreamble()
1478 Bytes.toStringBinary(HConstants.RPC_HEADER) + in readPreamble()