/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | UpdateMsg.java | 72 * @param bytes A Byte Array with the encoded form of the message. 74 * @throws DataFormatException If bytes is not valid. 76 UpdateMsg(byte[] bytes) throws DataFormatException argument 78 final ByteArrayScanner scanner = new ByteArrayScanner(bytes); 80 // Read the payload : all the remaining bytes but the terminating 0 202 * Return the number of bytes used by this message. 204 * @return The number of bytes used by this message. 222 new ByteArrayBuilder(bytes(6) + csnsUTF8(1));
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | NotAssuredUpdateMsg.java | 90 byte[] bytes = getRealUpdateMsgBytes(ProtocolVersion.REPLICATION_PROTOCOL_V1); 101 int pos = findNthZeroByte(bytes, 1, 2); 103 bytes[pos] = 0; 106 realUpdateMsgNotAssuredBytesV1 = bytes; 113 bytes = getRealUpdateMsgBytes(ProtocolVersion.getCurrentVersion()); 125 pos = findNthZeroByte(bytes, 2, 3); 127 bytes[pos] = 0; 130 realUpdateMsgNotAssuredBytesVLatest = bytes; 140 byte[] bytes = getRealUpdateMsgBytes(ProtocolVersion.getCurrentVersion()); 153 int pos = findNthZeroByte(bytes, 175 findNthZeroByte(byte[] bytes, int startPos, int nbToFind) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/admin/ |
H A D | SizeUnit.java | 46 BYTES(1L, "b", "bytes"), 102 * Gets the best-fit unit for the specified number of bytes. The 103 * returned unit will be able to represent the number of bytes using 107 * the number of bytes is zero then the {@link #BYTES} unit is 120 * @param bytes 121 * The number of bytes. 124 * If <code>bytes</code> is negative. 127 public static SizeUnit getBestFitUnit(long bytes) argument 129 if (bytes < 0) { 130 throw new IllegalArgumentException("negative number of bytes 181 getBestFitUnitExact(long bytes) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/ |
H A D | EntryIDSet.java | 83 * @param bytes The database value, or null if there are no entry IDs. 85 public EntryIDSet(byte[] keyBytes, byte[] bytes) argument 89 if (bytes == null) 95 if (bytes.length == 0) 101 else if ((bytes[0] & 0x80) == 0x80) 105 undefinedSize = JebFormat.entryIDUndefinedSizeFromDatabase(bytes); 109 // Seems like entry limit has not been exceeded and the bytes is a 111 values = JebFormat.entryIDListFromDatabase(bytes);
|
H A D | ID2Entry.java | 142 private Entry decode(ByteString bytes, CompressedSchema compressedSchema) argument 147 byte formatVersion = bytes.byteAt(0); 156 ASN1Reader reader = ASN1.getReader(bytes.subSequence(1, bytes.length())); 291 * the data bytes. 305 * @param bytes A byte array containing the encoded database value. 317 public static Entry entryFromDatabase(ByteString bytes, argument 324 return codec.decode(bytes, compressedSchema);
|
H A D | JebFormat.java | 68 * this method will throw an ArrayIndexOutOfBoundsException if the bytes 71 * @param bytes The database value of the entry ID. 74 public static long entryIDFromDatabase(byte[] bytes) argument 80 v |= (bytes[i] & 0xFF); 88 * @param bytes The database value of the entry ID count. 91 public static long entryIDUndefinedSizeFromDatabase(byte[] bytes) argument 93 if(bytes == null) 98 if(bytes.length == 8) 101 v |= (bytes[0] & 0x7F); 105 v |= (bytes[ 125 entryIDListFromDatabase(byte[] bytes) argument 154 intArrayFromDatabaseBytes(byte[] bytes) argument [all...] |
H A D | SortValuesSet.java | 67 * @param dataBytes The bytes to decode and construct this set. 344 * @return The encoded bytes representing this set or null if 374 * @param bytes The encoded bytes of a SortValuesSet to decode the size from. 378 public static int getEncodedSize(byte[] bytes, int offset) argument 384 v |= (bytes[i] & 0xFF); 392 * @param bytes The encoded bytes of a SortValuesSet to decode the IDs from. 396 public static long[] getEncodedIDs(byte[] bytes, int offset) argument 398 int length = getEncodedSize(bytes, offse [all...] |
H A D | SubstringIndexer.java | 224 * @param bytes The byte array containing the value 229 private byte[] makeSubstringKey(byte[] bytes, int pos, int len) argument 232 System.arraycopy(bytes, pos, keyBytes, 0, len);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | UpdateMsg.java | 83 * @param bytes A Byte Array with the encoded form of the message. 85 * @throws DataFormatException If bytes is not valid. 87 UpdateMsg(byte[] bytes) throws DataFormatException argument 90 int pos = decodeHeader(MSG_TYPE_GENERIC_UPDATE, bytes); 92 /* Read the payload : all the remaining bytes but the terminating 0 */ 93 int length = bytes.length - pos; 97 System.arraycopy(bytes, pos, payload, 0, length); 234 * Return the number of bytes used by this message. 236 * @return The number of bytes used by this message. 252 * encode the remaining bytes o [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | UpdateMsg.java | 83 * @param bytes A Byte Array with the encoded form of the message. 85 * @throws DataFormatException If bytes is not valid. 87 UpdateMsg(byte[] bytes) throws DataFormatException argument 90 int pos = decodeHeader(MSG_TYPE_GENERIC_UPDATE, bytes); 92 /* Read the payload : all the remaining bytes but the terminating 0 */ 93 int length = bytes.length - pos; 97 System.arraycopy(bytes, pos, payload, 0, length); 234 * Return the number of bytes used by this message. 236 * @return The number of bytes used by this message. 252 * encode the remaining bytes o [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/admin/ |
H A D | SizeUnit.java | 45 BYTES(1L, "b", "bytes"), 101 * Gets the best-fit unit for the specified number of bytes. The 102 * returned unit will be able to represent the number of bytes using 106 * the number of bytes is zero then the {@link #BYTES} unit is 119 * @param bytes 120 * The number of bytes. 123 * If <code>bytes</code> is negative. 126 public static SizeUnit getBestFitUnit(long bytes) argument 128 if (bytes < 0) { 129 throw new IllegalArgumentException("negative number of bytes 180 getBestFitUnitExact(long bytes) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/ |
H A D | EntryIDSet.java | 82 * @param bytes The database value, or null if there are no entry IDs. 84 public EntryIDSet(byte[] keyBytes, byte[] bytes) argument 88 if (bytes == null) 94 if (bytes.length == 0) 100 else if ((bytes[0] & 0x80) == 0x80) 104 undefinedSize = JebFormat.entryIDUndefinedSizeFromDatabase(bytes); 108 // Seems like entry limit has not been exceeded and the bytes is a 110 values = JebFormat.entryIDListFromDatabase(bytes);
|
H A D | ID2Entry.java | 141 private Entry decode(ByteString bytes, CompressedSchema compressedSchema) argument 146 byte formatVersion = bytes.byteAt(0); 155 ASN1Reader reader = ASN1.getReader(bytes.subSequence(1, bytes.length())); 290 * the data bytes. 304 * @param bytes A byte array containing the encoded database value. 316 public static Entry entryFromDatabase(ByteString bytes, argument 323 return codec.decode(bytes, compressedSchema);
|
H A D | JebFormat.java | 67 * this method will throw an ArrayIndexOutOfBoundsException if the bytes 70 * @param bytes The database value of the entry ID. 73 public static long entryIDFromDatabase(byte[] bytes) argument 79 v |= (bytes[i] & 0xFF); 87 * @param bytes The database value of the entry ID count. 90 public static long entryIDUndefinedSizeFromDatabase(byte[] bytes) argument 92 if(bytes == null) 97 if(bytes.length == 8) 100 v |= (bytes[0] & 0x7F); 104 v |= (bytes[ 124 entryIDListFromDatabase(byte[] bytes) argument 153 intArrayFromDatabaseBytes(byte[] bytes) argument [all...] |
H A D | SortValuesSet.java | 66 * @param dataBytes The bytes to decode and construct this set. 343 * @return The encoded bytes representing this set or null if 373 * @param bytes The encoded bytes of a SortValuesSet to decode the size from. 377 public static int getEncodedSize(byte[] bytes, int offset) argument 383 v |= (bytes[i] & 0xFF); 391 * @param bytes The encoded bytes of a SortValuesSet to decode the IDs from. 395 public static long[] getEncodedIDs(byte[] bytes, int offset) argument 397 int length = getEncodedSize(bytes, offse [all...] |
H A D | SubstringIndexer.java | 223 * @param bytes The byte array containing the value 228 private byte[] makeSubstringKey(byte[] bytes, int pos, int len) argument 231 System.arraycopy(bytes, pos, keyBytes, 0, len);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ByteArrayScanner.java | 51 private final ByteSequenceReader bytes; field in class:ByteArrayScanner 58 * @param bytes 61 public ByteArrayScanner(byte[] bytes) argument 63 this.bytes = ByteString.wrap(bytes).asReader(); 64 this.byteArray = bytes; 90 return bytes.get(); 109 return bytes.getShort(); 128 return bytes.getInt(); 147 return bytes [all...] |
H A D | UpdateMsg.java | 72 * @param bytes A Byte Array with the encoded form of the message. 74 * @throws DataFormatException If bytes is not valid. 76 UpdateMsg(byte[] bytes) throws DataFormatException argument 78 final ByteArrayScanner scanner = new ByteArrayScanner(bytes); 80 // Read the payload : all the remaining bytes but the terminating 0 202 * Return the number of bytes used by this message. 204 * @return The number of bytes used by this message. 222 new ByteArrayBuilder(bytes(6) + csnsUTF8(1));
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | NotAssuredUpdateMsg.java | 90 byte[] bytes = getRealUpdateMsgBytes(ProtocolVersion.REPLICATION_PROTOCOL_V1); 101 int pos = findNthZeroByte(bytes, 1, 2); 103 bytes[pos] = 0; 106 realUpdateMsgNotAssuredBytesV1 = bytes; 113 bytes = getRealUpdateMsgBytes(ProtocolVersion.getCurrentVersion()); 125 pos = findNthZeroByte(bytes, 2, 3); 127 bytes[pos] = 0; 130 realUpdateMsgNotAssuredBytesVLatest = bytes; 140 byte[] bytes = getRealUpdateMsgBytes(ProtocolVersion.getCurrentVersion()); 153 int pos = findNthZeroByte(bytes, 175 findNthZeroByte(byte[] bytes, int startPos, int nbToFind) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/admin/ |
H A D | SizeUnit.java | 46 BYTES(1L, "b", "bytes"), 102 * Gets the best-fit unit for the specified number of bytes. The 103 * returned unit will be able to represent the number of bytes using 107 * the number of bytes is zero then the {@link #BYTES} unit is 120 * @param bytes 121 * The number of bytes. 124 * If <code>bytes</code> is negative. 127 public static SizeUnit getBestFitUnit(long bytes) argument 129 if (bytes < 0) { 130 throw new IllegalArgumentException("negative number of bytes 181 getBestFitUnitExact(long bytes) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/ |
H A D | EntryIDSet.java | 83 * @param bytes The database value, or null if there are no entry IDs. 85 public EntryIDSet(byte[] keyBytes, byte[] bytes) argument 89 if (bytes == null) 95 if (bytes.length == 0) 101 else if ((bytes[0] & 0x80) == 0x80) 105 undefinedSize = JebFormat.entryIDUndefinedSizeFromDatabase(bytes); 109 // Seems like entry limit has not been exceeded and the bytes is a 111 values = JebFormat.entryIDListFromDatabase(bytes);
|
H A D | ID2Entry.java | 142 private Entry decode(ByteString bytes, CompressedSchema compressedSchema) argument 147 byte formatVersion = bytes.byteAt(0); 156 ASN1Reader reader = ASN1.getReader(bytes.subSequence(1, bytes.length())); 291 * the data bytes. 305 * @param bytes A byte array containing the encoded database value. 317 public static Entry entryFromDatabase(ByteString bytes, argument 324 return codec.decode(bytes, compressedSchema);
|
H A D | JebFormat.java | 68 * this method will throw an ArrayIndexOutOfBoundsException if the bytes 71 * @param bytes The database value of the entry ID. 74 public static long entryIDFromDatabase(byte[] bytes) argument 80 v |= (bytes[i] & 0xFF); 88 * @param bytes The database value of the entry ID count. 91 public static long entryIDUndefinedSizeFromDatabase(byte[] bytes) argument 93 if(bytes == null) 98 if(bytes.length == 8) 101 v |= (bytes[0] & 0x7F); 105 v |= (bytes[ 125 entryIDListFromDatabase(byte[] bytes) argument 154 intArrayFromDatabaseBytes(byte[] bytes) argument [all...] |
H A D | SortValuesSet.java | 67 * @param dataBytes The bytes to decode and construct this set. 344 * @return The encoded bytes representing this set or null if 374 * @param bytes The encoded bytes of a SortValuesSet to decode the size from. 378 public static int getEncodedSize(byte[] bytes, int offset) argument 384 v |= (bytes[i] & 0xFF); 392 * @param bytes The encoded bytes of a SortValuesSet to decode the IDs from. 396 public static long[] getEncodedIDs(byte[] bytes, int offset) argument 398 int length = getEncodedSize(bytes, offse [all...] |
H A D | SubstringIndexer.java | 224 * @param bytes The byte array containing the value 229 private byte[] makeSubstringKey(byte[] bytes, int pos, int len) argument 232 System.arraycopy(bytes, pos, keyBytes, 0, len);
|