private LoadBalancerProtos.LoadBalancerState parseFrom(byte [] pbBytes) throws DeserializationException { ProtobufUtil.expectPBMagicPrefix(pbBytes); LoadBalancerProtos.LoadBalancerState.Builder builder = LoadBalancerProtos.LoadBalancerState.newBuilder(); try { int magicLen = ProtobufUtil.lengthOfPBMagic(); ProtobufUtil.mergeFrom(builder, pbBytes, magicLen, pbBytes.length - magicLen); } catch (IOException e) { throw new DeserializationException(e); } return builder.build(); }
private LoadBalancerProtos.LoadBalancerState parseFrom(byte [] pbBytes) throws DeserializationException { ProtobufUtil.expectPBMagicPrefix(pbBytes); LoadBalancerProtos.LoadBalancerState.Builder builder = LoadBalancerProtos.LoadBalancerState.newBuilder(); try { int magicLen = ProtobufUtil.lengthOfPBMagic(); builder.mergeFrom(pbBytes, magicLen, pbBytes.length - magicLen); } catch (InvalidProtocolBufferException e) { throw new DeserializationException(e); } return builder.build(); }
private byte [] toByteArray(boolean isBalancerOn) { LoadBalancerProtos.LoadBalancerState.Builder builder = LoadBalancerProtos.LoadBalancerState.newBuilder(); builder.setBalancerOn(isBalancerOn); return ProtobufUtil.prependPBMagic(builder.build().toByteArray()); }