/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | StartMsg.java | 104 byte[] encodedMsg = new byte[length]; 107 encodedMsg[0] = type; 110 encodedMsg[1] = (byte)sessionProtocolVersion; 114 pos = addByteArray(byteGenerationID, encodedMsg, pos); 117 encodedMsg[pos] = groupId; 122 return encodedMsg; 151 byte[] encodedMsg = new byte[length]; 154 encodedMsg[0] = type; 157 encodedMsg[1] = (byte)ProtocolVersion.REPLICATION_PROTOCOL_V1_REAL; 158 encodedMsg[ 176 decodeHeader(byte[] types, byte [] encodedMsg) argument 233 decodeHeader_V1(byte type, byte [] encodedMsg) argument [all...] |
H A D | ChangeStatusMsg.java | 60 * @param encodedMsg The byte array containing the encoded form of the 65 public ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException argument 73 if (encodedMsg[0] != ReplicationMsg.MSG_TYPE_CHANGE_STATUS) 81 requestedStatus = ServerStatus.valueOf(encodedMsg[1]); 84 newStatus = ServerStatus.valueOf(encodedMsg[2]); 101 byte[] encodedMsg = new byte[3]; 104 encodedMsg[0] = ReplicationMsg.MSG_TYPE_CHANGE_STATUS; 107 encodedMsg[1] = requestedStatus.getValue(); 110 encodedMsg[2] = newStatus.getValue(); 112 return encodedMsg; [all...] |
H A D | LDAPUpdateMsg.java | 265 byte[] encodedMsg = new byte[length]; 268 encodedMsg[0] = type; 271 encodedMsg[1] = (byte) version; 275 pos = addByteArray(changeNumberByte, encodedMsg, pos); 278 pos = addByteArray(byteDn, encodedMsg, pos); 281 pos = addByteArray(byteEntryuuid, encodedMsg, pos); 284 encodedMsg[pos++] = (assuredFlag ? (byte) 1 : 0); 287 encodedMsg[pos++] = assuredMode.getValue(); 290 encodedMsg[pos++] = safeDataLevel; 292 return encodedMsg; 446 decodeHeader(byte[] types, byte[] encodedMsg) argument 526 decodeHeader_V1(byte[] encodedMsg) argument [all...] |
H A D | UpdateMsg.java | 272 byte[] encodedMsg = new byte[length]; 275 encodedMsg[0] = type; 278 encodedMsg[1] = (byte)ProtocolVersion.getCurrentVersion(); 282 pos = addByteArray(changeNumberByte, encodedMsg, pos); 285 encodedMsg[pos++] = (assuredFlag ? (byte) 1 : 0); 288 encodedMsg[pos++] = assuredMode.getValue(); 291 encodedMsg[pos++] = safeDataLevel; 293 return encodedMsg; 300 * @param encodedMsg the encoded form of the UpdateMsg. 302 * @throws DataFormatException if the encodedMsg doe 305 decodeHeader(byte type, byte[] encodedMsg) argument [all...] |
H A D | ModifyDNMsg.java | 221 byte[] encodedMsg = encodeHeader_V1(MSG_TYPE_MODIFYDN_V1, bodyLength); 222 int pos = encodedMsg.length - bodyLength; 225 pos = addByteArray(byteNewRdn, encodedMsg, pos); 230 pos = addByteArray(byteNewSuperior, encodedMsg, pos); 233 encodedMsg[pos++] = 0; 238 pos = addByteArray(byteNewSuperiorId, encodedMsg, pos); 241 encodedMsg[pos++] = 0; 245 encodedMsg[pos++] = 1; 247 encodedMsg[pos++] = 0; 249 return encodedMsg; [all...] |
H A D | ModifyMsg.java | 210 byte[] encodedMsg = encodeHeader_V1(MSG_TYPE_MODIFY_V1, encodedMods.length + 214 int pos = encodedMsg.length - (encodedMods.length + 1); 215 addByteArray(encodedMods, encodedMsg, pos); 217 return encodedMsg; 229 byte[] encodedMsg = encodeHeader(MSG_TYPE_MODIFY, encodedMods.length + 1, 233 int pos = encodedMsg.length - (encodedMods.length + 1); 234 addByteArray(encodedMods, encodedMsg, pos); 236 return encodedMsg; 258 byte [] encodedMsg = encodeHeader(MSG_TYPE_MODIFY, bodyLength, 261 int pos = encodedMsg [all...] |
H A D | DeleteMsg.java | 183 byte [] encodedMsg = encodeHeader(MSG_TYPE_DELETE, bodyLength, 185 int pos = encodedMsg.length - bodyLength; 187 pos = addByteArray(byteInitiatorsName, encodedMsg, pos); 189 encodedMsg[pos++] = 0; 190 pos = addByteArray(byteEntryAttrLen, encodedMsg, pos); 191 pos = addByteArray(encodedEclIncludes, encodedMsg, pos); 193 encodedMsg[pos++] = (isSubtreeDelete ? (byte) 1 : (byte) 0); 195 return encodedMsg;
|
H A D | ECLUpdateMsg.java | 112 byte[] encodedMsg = new byte[length]; 113 System.arraycopy(in, pos, encodedMsg, 0, length); 116 encodedMsg, ProtocolVersion.getCurrentVersion());
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | StartMsg.java | 104 byte[] encodedMsg = new byte[length]; 107 encodedMsg[0] = type; 110 encodedMsg[1] = (byte)sessionProtocolVersion; 114 pos = addByteArray(byteGenerationID, encodedMsg, pos); 117 encodedMsg[pos] = groupId; 122 return encodedMsg; 151 byte[] encodedMsg = new byte[length]; 154 encodedMsg[0] = type; 157 encodedMsg[1] = (byte)ProtocolVersion.REPLICATION_PROTOCOL_V1_REAL; 158 encodedMsg[ 176 decodeHeader(byte[] types, byte [] encodedMsg) argument 233 decodeHeader_V1(byte type, byte [] encodedMsg) argument [all...] |
H A D | ChangeStatusMsg.java | 60 * @param encodedMsg The byte array containing the encoded form of the 65 public ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException argument 73 if (encodedMsg[0] != ReplicationMsg.MSG_TYPE_CHANGE_STATUS) 81 requestedStatus = ServerStatus.valueOf(encodedMsg[1]); 84 newStatus = ServerStatus.valueOf(encodedMsg[2]); 101 byte[] encodedMsg = new byte[3]; 104 encodedMsg[0] = ReplicationMsg.MSG_TYPE_CHANGE_STATUS; 107 encodedMsg[1] = requestedStatus.getValue(); 110 encodedMsg[2] = newStatus.getValue(); 112 return encodedMsg; [all...] |
H A D | LDAPUpdateMsg.java | 265 byte[] encodedMsg = new byte[length]; 268 encodedMsg[0] = type; 271 encodedMsg[1] = (byte) version; 275 pos = addByteArray(changeNumberByte, encodedMsg, pos); 278 pos = addByteArray(byteDn, encodedMsg, pos); 281 pos = addByteArray(byteEntryuuid, encodedMsg, pos); 284 encodedMsg[pos++] = (assuredFlag ? (byte) 1 : 0); 287 encodedMsg[pos++] = assuredMode.getValue(); 290 encodedMsg[pos++] = safeDataLevel; 292 return encodedMsg; 446 decodeHeader(byte[] types, byte[] encodedMsg) argument 526 decodeHeader_V1(byte[] encodedMsg) argument [all...] |
H A D | UpdateMsg.java | 272 byte[] encodedMsg = new byte[length]; 275 encodedMsg[0] = type; 278 encodedMsg[1] = (byte)ProtocolVersion.getCurrentVersion(); 282 pos = addByteArray(changeNumberByte, encodedMsg, pos); 285 encodedMsg[pos++] = (assuredFlag ? (byte) 1 : 0); 288 encodedMsg[pos++] = assuredMode.getValue(); 291 encodedMsg[pos++] = safeDataLevel; 293 return encodedMsg; 300 * @param encodedMsg the encoded form of the UpdateMsg. 302 * @throws DataFormatException if the encodedMsg doe 305 decodeHeader(byte type, byte[] encodedMsg) argument [all...] |
H A D | ModifyDNMsg.java | 221 byte[] encodedMsg = encodeHeader_V1(MSG_TYPE_MODIFYDN_V1, bodyLength); 222 int pos = encodedMsg.length - bodyLength; 225 pos = addByteArray(byteNewRdn, encodedMsg, pos); 230 pos = addByteArray(byteNewSuperior, encodedMsg, pos); 233 encodedMsg[pos++] = 0; 238 pos = addByteArray(byteNewSuperiorId, encodedMsg, pos); 241 encodedMsg[pos++] = 0; 245 encodedMsg[pos++] = 1; 247 encodedMsg[pos++] = 0; 249 return encodedMsg; [all...] |
H A D | ModifyMsg.java | 210 byte[] encodedMsg = encodeHeader_V1(MSG_TYPE_MODIFY_V1, encodedMods.length + 214 int pos = encodedMsg.length - (encodedMods.length + 1); 215 addByteArray(encodedMods, encodedMsg, pos); 217 return encodedMsg; 229 byte[] encodedMsg = encodeHeader(MSG_TYPE_MODIFY, encodedMods.length + 1, 233 int pos = encodedMsg.length - (encodedMods.length + 1); 234 addByteArray(encodedMods, encodedMsg, pos); 236 return encodedMsg; 258 byte [] encodedMsg = encodeHeader(MSG_TYPE_MODIFY, bodyLength, 261 int pos = encodedMsg [all...] |
H A D | DeleteMsg.java | 183 byte [] encodedMsg = encodeHeader(MSG_TYPE_DELETE, bodyLength, 185 int pos = encodedMsg.length - bodyLength; 187 pos = addByteArray(byteInitiatorsName, encodedMsg, pos); 189 encodedMsg[pos++] = 0; 190 pos = addByteArray(byteEntryAttrLen, encodedMsg, pos); 191 pos = addByteArray(encodedEclIncludes, encodedMsg, pos); 193 encodedMsg[pos++] = (isSubtreeDelete ? (byte) 1 : (byte) 0); 195 return encodedMsg;
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | StartMsg.java | 104 byte[] encodedMsg = new byte[length]; 107 encodedMsg[0] = type; 110 encodedMsg[1] = (byte)sessionProtocolVersion; 114 pos = addByteArray(byteGenerationID, encodedMsg, pos); 117 encodedMsg[pos] = groupId; 122 return encodedMsg; 151 byte[] encodedMsg = new byte[length]; 154 encodedMsg[0] = type; 157 encodedMsg[1] = (byte)ProtocolVersion.REPLICATION_PROTOCOL_V1_REAL; 158 encodedMsg[ 176 decodeHeader(byte[] types, byte [] encodedMsg) argument 233 decodeHeader_V1(byte type, byte [] encodedMsg) argument [all...] |
H A D | ChangeStatusMsg.java | 60 * @param encodedMsg The byte array containing the encoded form of the 65 public ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException argument 73 if (encodedMsg[0] != ReplicationMsg.MSG_TYPE_CHANGE_STATUS) 81 requestedStatus = ServerStatus.valueOf(encodedMsg[1]); 84 newStatus = ServerStatus.valueOf(encodedMsg[2]); 101 byte[] encodedMsg = new byte[3]; 104 encodedMsg[0] = ReplicationMsg.MSG_TYPE_CHANGE_STATUS; 107 encodedMsg[1] = requestedStatus.getValue(); 110 encodedMsg[2] = newStatus.getValue(); 112 return encodedMsg; [all...] |
H A D | LDAPUpdateMsg.java | 265 byte[] encodedMsg = new byte[length]; 268 encodedMsg[0] = type; 271 encodedMsg[1] = (byte) version; 275 pos = addByteArray(changeNumberByte, encodedMsg, pos); 278 pos = addByteArray(byteDn, encodedMsg, pos); 281 pos = addByteArray(byteEntryuuid, encodedMsg, pos); 284 encodedMsg[pos++] = (assuredFlag ? (byte) 1 : 0); 287 encodedMsg[pos++] = assuredMode.getValue(); 290 encodedMsg[pos++] = safeDataLevel; 292 return encodedMsg; 446 decodeHeader(byte[] types, byte[] encodedMsg) argument 526 decodeHeader_V1(byte[] encodedMsg) argument [all...] |
H A D | UpdateMsg.java | 272 byte[] encodedMsg = new byte[length]; 275 encodedMsg[0] = type; 278 encodedMsg[1] = (byte)ProtocolVersion.getCurrentVersion(); 282 pos = addByteArray(changeNumberByte, encodedMsg, pos); 285 encodedMsg[pos++] = (assuredFlag ? (byte) 1 : 0); 288 encodedMsg[pos++] = assuredMode.getValue(); 291 encodedMsg[pos++] = safeDataLevel; 293 return encodedMsg; 300 * @param encodedMsg the encoded form of the UpdateMsg. 302 * @throws DataFormatException if the encodedMsg doe 305 decodeHeader(byte type, byte[] encodedMsg) argument [all...] |
H A D | ModifyDNMsg.java | 221 byte[] encodedMsg = encodeHeader_V1(MSG_TYPE_MODIFYDN_V1, bodyLength); 222 int pos = encodedMsg.length - bodyLength; 225 pos = addByteArray(byteNewRdn, encodedMsg, pos); 230 pos = addByteArray(byteNewSuperior, encodedMsg, pos); 233 encodedMsg[pos++] = 0; 238 pos = addByteArray(byteNewSuperiorId, encodedMsg, pos); 241 encodedMsg[pos++] = 0; 245 encodedMsg[pos++] = 1; 247 encodedMsg[pos++] = 0; 249 return encodedMsg; [all...] |
H A D | ModifyMsg.java | 210 byte[] encodedMsg = encodeHeader_V1(MSG_TYPE_MODIFY_V1, encodedMods.length + 214 int pos = encodedMsg.length - (encodedMods.length + 1); 215 addByteArray(encodedMods, encodedMsg, pos); 217 return encodedMsg; 229 byte[] encodedMsg = encodeHeader(MSG_TYPE_MODIFY, encodedMods.length + 1, 233 int pos = encodedMsg.length - (encodedMods.length + 1); 234 addByteArray(encodedMods, encodedMsg, pos); 236 return encodedMsg; 258 byte [] encodedMsg = encodeHeader(MSG_TYPE_MODIFY, bodyLength, 261 int pos = encodedMsg [all...] |
H A D | DeleteMsg.java | 183 byte [] encodedMsg = encodeHeader(MSG_TYPE_DELETE, bodyLength, 185 int pos = encodedMsg.length - bodyLength; 187 pos = addByteArray(byteInitiatorsName, encodedMsg, pos); 189 encodedMsg[pos++] = 0; 190 pos = addByteArray(byteEntryAttrLen, encodedMsg, pos); 191 pos = addByteArray(encodedEclIncludes, encodedMsg, pos); 193 encodedMsg[pos++] = (isSubtreeDelete ? (byte) 1 : (byte) 0); 195 return encodedMsg;
|
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | ChangeStatusMsg.java | 60 * @param encodedMsg The byte array containing the encoded form of the 65 ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException argument 73 if (encodedMsg[0] != ReplicationMsg.MSG_TYPE_CHANGE_STATUS) 77 requestedStatus = ServerStatus.valueOf(encodedMsg[1]); 78 newStatus = ServerStatus.valueOf(encodedMsg[2]);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ChangeStatusMsg.java | 60 * @param encodedMsg The byte array containing the encoded form of the 65 ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException argument 73 if (encodedMsg[0] != ReplicationMsg.MSG_TYPE_CHANGE_STATUS) 77 requestedStatus = ServerStatus.valueOf(encodedMsg[1]); 78 newStatus = ServerStatus.valueOf(encodedMsg[2]);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | ChangeStatusMsg.java | 60 * @param encodedMsg The byte array containing the encoded form of the 65 ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException argument 73 if (encodedMsg[0] != ReplicationMsg.MSG_TYPE_CHANGE_STATUS) 77 requestedStatus = ServerStatus.valueOf(encodedMsg[1]); 78 newStatus = ServerStatus.valueOf(encodedMsg[2]);
|