Searched defs:encodedMsg (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DChangeStatusMsg.java60 * @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 DStartMsg.java104 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 DUpdateMsg.java272 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 DLDAPUpdateMsg.java265 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 DChangeStatusMsg.java60 * @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 DChangeStatusMsg.java60 * @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 DStartMsg.java104 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 DUpdateMsg.java272 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 DLDAPUpdateMsg.java265 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 DChangeStatusMsg.java60 * @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 DStartMsg.java104 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 DUpdateMsg.java272 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 DLDAPUpdateMsg.java265 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 DChangeStatusMsg.java60 * @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 DChangeStatusMsg.java60 * @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 DNotAssuredUpdateMsg.java392 public int decodeHeader(byte type, byte[] encodedMsg) argument
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DNotAssuredUpdateMsg.java392 public int decodeHeader(byte type, byte[] encodedMsg) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DNotAssuredUpdateMsg.java392 public int decodeHeader(byte type, byte[] encodedMsg) argument

Completed in 115 milliseconds