/forgerock/opendj-b2.6/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 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 | 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 | 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 | 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...] |
/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.6.2/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 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 | 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 | 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 | 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...] |
/forgerock/opendj2-jel-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 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 | 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 | 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 | 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...] |
/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]);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | NotAssuredUpdateMsg.java | 392 public int decodeHeader(byte type, byte[] encodedMsg) argument
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | NotAssuredUpdateMsg.java | 392 public int decodeHeader(byte type, byte[] encodedMsg) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | NotAssuredUpdateMsg.java | 392 public int decodeHeader(byte type, byte[] encodedMsg) argument
|