| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
| H A D | ReplInputStream.java | 49 private byte[] bytes; field in class:ReplInputStream 79 * @param len The maximum number of bytes that may be read into the 82 * @return The number of bytes read from the input stream into the provided 97 if (bytes == null) 101 bytes = domain.receiveEntryBytes(); 103 if (bytes==null) 109 receivedLength = bytes.length; 116 receivedLength = bytes.length - index; 128 System.arraycopy(bytes, index, b, off, copiedLength); 131 if (index == bytes [all...] |
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
| H A D | ReplInputStream.java | 49 private byte[] bytes; field in class:ReplInputStream 79 * @param len The maximum number of bytes that may be read into the 82 * @return The number of bytes read from the input stream into the provided 97 if (bytes == null) 101 bytes = domain.receiveEntryBytes(); 103 if (bytes==null) 109 receivedLength = bytes.length; 116 receivedLength = bytes.length - index; 128 System.arraycopy(bytes, index, b, off, copiedLength); 131 if (index == bytes [all...] |
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
| H A D | ReplInputStream.java | 49 private byte[] bytes; field in class:ReplInputStream 79 * @param len The maximum number of bytes that may be read into the 82 * @return The number of bytes read from the input stream into the provided 97 if (bytes == null) 101 bytes = domain.receiveEntryBytes(); 103 if (bytes==null) 109 receivedLength = bytes.length; 116 receivedLength = bytes.length - index; 128 System.arraycopy(bytes, index, b, off, copiedLength); 131 if (index == bytes [all...] |
| /forgerock/openam-v13/openam-radius/openam-radius-common/src/test/java/org/forgerock/openam/radius/common/packet/ |
| H A D | TestChapPasswordAttribute.java | 35 byte[] bytes = a.getOctets(); 36 Assert.assertEquals(bytes[0], AttributeType.CHAP_PASSWORD.getTypeCode()); 37 Assert.assertEquals(bytes[1], 19); 38 Assert.assertEquals(bytes[2], 27); 39 Assert.assertNotEquals(new String(bytes, 3, 16, Charset.forName("utf-8")), "challenge"); 40 Assert.assertTrue(new String(bytes, 3, 16, Charset.forName("utf-8")).startsWith("challenge")); 46 byte[] bytes = a.getOctets(); 47 System.out.println("hAp3=" + Utils.toHexAndPrintableChars(bytes)); 48 Assert.assertEquals(bytes[0], AttributeType.CHAP_PASSWORD.getTypeCode()); 49 Assert.assertEquals(bytes[ [all...] |
| H A D | TestFramedCompressionAttribute.java | 33 final byte[] bytes = a.getOctets(); 34 Assert.assertEquals(bytes[0], AttributeType.FRAMED_COMPRESSION.getTypeCode()); 35 Assert.assertEquals(bytes[1], 6); 36 Assert.assertEquals(bytes[2], 0); 37 Assert.assertEquals(bytes[3], 0); 38 Assert.assertEquals(bytes[4], 0); 39 Assert.assertEquals(bytes[5], 0); 46 final byte[] bytes = a.getOctets(); 47 Assert.assertEquals(bytes[0], AttributeType.FRAMED_COMPRESSION.getTypeCode()); 48 Assert.assertEquals(bytes[ [all...] |
| H A D | TestFramedProtocolAttribute.java | 33 final byte[] bytes = a.getOctets(); 34 Assert.assertEquals(bytes[0], AttributeType.FRAMED_PROTOCOL.getTypeCode()); 35 Assert.assertEquals(bytes[1], 6); 36 Assert.assertEquals(bytes[2], 0); 37 Assert.assertEquals(bytes[3], 0); 38 Assert.assertEquals(bytes[4], 0); 39 Assert.assertEquals(bytes[5], 0); 46 final byte[] bytes = a.getOctets(); 47 Assert.assertEquals(bytes[0], AttributeType.FRAMED_PROTOCOL.getTypeCode()); 48 Assert.assertEquals(bytes[ [all...] |
| H A D | TestFilterIdAttribute.java | 34 byte[] bytes = a.getOctets(); 35 Assert.assertEquals(bytes[0], AttributeType.FILTER_ID.getTypeCode()); 36 Assert.assertEquals(bytes[1], "filter".length() + 2); 37 Assert.assertEquals(new String(bytes, 2, bytes.length - 2, Charset.forName("utf-8")), "filter"); 43 * characters which have two bytes. But since all are from the ascii set the upper byte has a value of zero. 70 byte[] bytes = a.getOctets(); 71 Assert.assertEquals(bytes[0], AttributeType.FILTER_ID.getTypeCode()); 72 Assert.assertEquals(bytes[1], ((byte) 255)); // bytes ar [all...] |
| H A D | TestFramedAppleTalkZoneAttribute.java | 34 final byte[] bytes = a.getOctets(); 35 Assert.assertEquals(bytes[0], AttributeType.FRAMED_APPLETALK_ZONE.getTypeCode()); 36 Assert.assertEquals(bytes[1], "filter".length() + 2); 37 Assert.assertEquals(new String(bytes, 2, bytes.length - 2, Charset.forName("utf-8")), "filter"); 52 final byte[] bytes = a.getOctets(); 53 Assert.assertEquals(bytes[0], AttributeType.FRAMED_APPLETALK_ZONE.getTypeCode()); 54 Assert.assertEquals(bytes[1], ((byte) 255)); // bytes are signed. therefore to get unsigned byte with 56 Assert.assertEquals(new String(bytes, [all...] |
| H A D | TestFramedRouteAttribute.java | 35 byte[] bytes = a.getOctets(); 36 Assert.assertEquals(bytes[0], AttributeType.FRAMED_ROUTE.getTypeCode()); 37 Assert.assertEquals(bytes[1], route.length() + 2); 38 Assert.assertEquals(new String(bytes, 2, bytes.length - 2, Charset.forName("utf-8")), route); 53 byte[] bytes = a.getOctets(); 54 Assert.assertEquals(bytes[0], AttributeType.FRAMED_APPLETALK_ZONE.getTypeCode()); 55 Assert.assertEquals(bytes[1], ((byte) 255)); // bytes are signed. therefore to get unsigned byte with 57 Assert.assertEquals(new String(bytes, [all...] |
| /forgerock/openam/openam-radius/openam-radius-common/src/test/java/org/forgerock/openam/radius/common/packet/ |
| H A D | TestChapPasswordAttribute.java | 35 byte[] bytes = a.getOctets(); 36 Assert.assertEquals(bytes[0], AttributeType.CHAP_PASSWORD.getTypeCode()); 37 Assert.assertEquals(bytes[1], 19); 38 Assert.assertEquals(bytes[2], 27); 39 Assert.assertNotEquals(new String(bytes, 3, 16, Charset.forName("utf-8")), "challenge"); 40 Assert.assertTrue(new String(bytes, 3, 16, Charset.forName("utf-8")).startsWith("challenge")); 46 byte[] bytes = a.getOctets(); 47 System.out.println("hAp3=" + Utils.toHexAndPrintableChars(bytes)); 48 Assert.assertEquals(bytes[0], AttributeType.CHAP_PASSWORD.getTypeCode()); 49 Assert.assertEquals(bytes[ [all...] |
| H A D | TestFramedCompressionAttribute.java | 33 final byte[] bytes = a.getOctets(); 34 Assert.assertEquals(bytes[0], AttributeType.FRAMED_COMPRESSION.getTypeCode()); 35 Assert.assertEquals(bytes[1], 6); 36 Assert.assertEquals(bytes[2], 0); 37 Assert.assertEquals(bytes[3], 0); 38 Assert.assertEquals(bytes[4], 0); 39 Assert.assertEquals(bytes[5], 0); 46 final byte[] bytes = a.getOctets(); 47 Assert.assertEquals(bytes[0], AttributeType.FRAMED_COMPRESSION.getTypeCode()); 48 Assert.assertEquals(bytes[ [all...] |
| H A D | TestFramedProtocolAttribute.java | 33 final byte[] bytes = a.getOctets(); 34 Assert.assertEquals(bytes[0], AttributeType.FRAMED_PROTOCOL.getTypeCode()); 35 Assert.assertEquals(bytes[1], 6); 36 Assert.assertEquals(bytes[2], 0); 37 Assert.assertEquals(bytes[3], 0); 38 Assert.assertEquals(bytes[4], 0); 39 Assert.assertEquals(bytes[5], 0); 46 final byte[] bytes = a.getOctets(); 47 Assert.assertEquals(bytes[0], AttributeType.FRAMED_PROTOCOL.getTypeCode()); 48 Assert.assertEquals(bytes[ [all...] |
| H A D | TestFilterIdAttribute.java | 34 byte[] bytes = a.getOctets(); 35 Assert.assertEquals(bytes[0], AttributeType.FILTER_ID.getTypeCode()); 36 Assert.assertEquals(bytes[1], "filter".length() + 2); 37 Assert.assertEquals(new String(bytes, 2, bytes.length - 2, Charset.forName("utf-8")), "filter"); 43 * characters which have two bytes. But since all are from the ascii set the upper byte has a value of zero. 70 byte[] bytes = a.getOctets(); 71 Assert.assertEquals(bytes[0], AttributeType.FILTER_ID.getTypeCode()); 72 Assert.assertEquals(bytes[1], ((byte) 255)); // bytes ar [all...] |
| H A D | TestFramedAppleTalkZoneAttribute.java | 34 final byte[] bytes = a.getOctets(); 35 Assert.assertEquals(bytes[0], AttributeType.FRAMED_APPLETALK_ZONE.getTypeCode()); 36 Assert.assertEquals(bytes[1], "filter".length() + 2); 37 Assert.assertEquals(new String(bytes, 2, bytes.length - 2, Charset.forName("utf-8")), "filter"); 52 final byte[] bytes = a.getOctets(); 53 Assert.assertEquals(bytes[0], AttributeType.FRAMED_APPLETALK_ZONE.getTypeCode()); 54 Assert.assertEquals(bytes[1], ((byte) 255)); // bytes are signed. therefore to get unsigned byte with 56 Assert.assertEquals(new String(bytes, [all...] |
| H A D | TestFramedRouteAttribute.java | 35 byte[] bytes = a.getOctets(); 36 Assert.assertEquals(bytes[0], AttributeType.FRAMED_ROUTE.getTypeCode()); 37 Assert.assertEquals(bytes[1], route.length() + 2); 38 Assert.assertEquals(new String(bytes, 2, bytes.length - 2, Charset.forName("utf-8")), route); 53 byte[] bytes = a.getOctets(); 54 Assert.assertEquals(bytes[0], AttributeType.FRAMED_APPLETALK_ZONE.getTypeCode()); 55 Assert.assertEquals(bytes[1], ((byte) 255)); // bytes are signed. therefore to get unsigned byte with 57 Assert.assertEquals(new String(bytes, [all...] |
| /forgerock/opendj2/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...] |
| /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...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/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.readByte(); 109 return bytes.readShort(); 128 return bytes.readInt(); 147 return bytes [all...] |
| /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-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/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
| H A D | NotAssuredUpdateMsg.java | 89 byte[] bytes = getRealUpdateMsgBytes(ProtocolVersion.REPLICATION_PROTOCOL_V1); 100 int pos = findNthZeroByte(bytes, 1, 2); 102 bytes[pos] = 0; 105 realUpdateMsgNotAssuredBytesV1 = bytes; 112 bytes = getRealUpdateMsgBytes(ProtocolVersion.getCurrentVersion()); 124 pos = findNthZeroByte(bytes, 2, 3); 126 bytes[pos] = 0; 129 realUpdateMsgNotAssuredBytesVLatest = bytes; 139 byte[] bytes = getRealUpdateMsgBytes(ProtocolVersion.getCurrentVersion()); 152 int pos = findNthZeroByte(bytes, 174 findNthZeroByte(byte[] bytes, int startPos, int nbToFind) argument [all...] |
| /forgerock/opendj2/src/server/org/opends/server/replication/service/ |
| H A D | ReplInputStream.java | 44 private byte[] bytes; field in class:ReplInputStream 74 * @param len The maximum number of bytes that may be read into the 77 * @return The number of bytes read from the input stream into the provided 94 if (bytes == null) 98 bytes = domain.receiveEntryBytes(); 100 if (bytes==null) 106 receivedLength = bytes.length; 113 receivedLength = bytes.length - index; 125 System.arraycopy(bytes, index, b, off, copiedLength); 128 if (index == bytes [all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
| H A D | ReplInputStream.java | 44 private byte[] bytes; field in class:ReplInputStream 74 * @param len The maximum number of bytes that may be read into the 77 * @return The number of bytes read from the input stream into the provided 94 if (bytes == null) 98 bytes = domain.receiveEntryBytes(); 100 if (bytes==null) 106 receivedLength = bytes.length; 113 receivedLength = bytes.length - index; 125 System.arraycopy(bytes, index, b, off, copiedLength); 128 if (index == bytes [all...] |
| /forgerock/openam-v13/openam-radius/openam-radius-common/src/main/java/org/forgerock/openam/radius/common/packet/ |
| H A D | UnknownAttribute.java | 29 * Constructs a new instance from the on-the-wire bytes for this attribute including the prefixing attribute-type 32 * @param octets the on-the-wire bytes from which to construct this instance 48 byte[] bytes = new byte[orig.length]; 49 System.arraycopy(orig, 0, bytes, 0, orig.length); 50 bytes[0] = (byte) AttributeType.UNKNOWN.getTypeCode(); 51 return bytes;
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
| H A D | ReplInputStream.java | 44 private byte[] bytes; field in class:ReplInputStream 74 * @param len The maximum number of bytes that may be read into the 77 * @return The number of bytes read from the input stream into the provided 94 if (bytes == null) 98 bytes = domain.receiveEntryBytes(); 100 if (bytes==null) 106 receivedLength = bytes.length; 113 receivedLength = bytes.length - index; 125 System.arraycopy(bytes, index, b, off, copiedLength); 128 if (index == bytes [all...] |