| | |
| | | @Override |
| | | public ByteString normalizeValue(ByteSequence value) |
| | | { |
| | | |
| | | String[] token = value.toString().split(":", 3); |
| | | |
| | | /* Change the format of the value to index and start |
| | |
| | | String serverId = token[1].substring(16,20); |
| | | String seqNumber = token[1].substring(20, 28); |
| | | |
| | | return ByteString.valueOf(serverId + timestamp + seqNumber); |
| | | if (MultimasterReplication.isLocalServerId(Short.parseShort(serverId, 16))) |
| | | return ByteString.valueOf(serverId + timestamp + seqNumber); |
| | | else |
| | | return (ByteString.valueOf("0")); |
| | | } |
| | | |
| | | /** |