Searched refs:encodedMsg (Results 1 - 25 of 33) sorted by relevance

12

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
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 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 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...]
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 DModifyDNMsg.java221 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 DModifyMsg.java210 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 DDeleteMsg.java183 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 DECLUpdateMsg.java112 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 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 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 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...]
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 DModifyDNMsg.java221 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 DModifyMsg.java210 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 DDeleteMsg.java183 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 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 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 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...]
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 DModifyDNMsg.java221 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 DModifyMsg.java210 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 DDeleteMsg.java183 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 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-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]);

Completed in 136 milliseconds

12