Searched defs:msgType (Results 1 - 25 of 35) sorted by relevance

12

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DStartMsg.java71 * @param msgType The type of the message to create.
76 void encodeHeader(byte msgType, ByteArrayBuilder builder, short protocolVersion) argument
81 builder.appendByte(msgType);
91 * @param msgType The type of the message to create.
95 void encodeHeader_V1(byte msgType, ByteArrayBuilder builder) argument
100 builder.appendByte(msgType);
117 final byte msgType = scanner.nextByte();
118 if (!isTypeAllowed(allowedTypes, msgType))
121 + msgType);
127 if (msgType
160 isTypeAllowed(byte[] allowedTypes, final byte msgType) argument
[all...]
H A DUpdateMsg.java215 * @param msgType The type of UpdateMsg to encode.
219 protected ByteArrayBuilder encodeHeader(byte msgType, short protocolVersion) argument
223 builder.appendByte(msgType);
247 final byte msgType = scanner.nextByte();
248 if (allowedType != msgType)
251 + msgType);
H A DLDAPUpdateMsg.java212 public ByteArrayBuilder encodeHeader(byte msgType, short protocolVersion) argument
219 builder.appendByte(msgType);
234 * @param msgType the type of UpdateMessage to encode.
237 ByteArrayBuilder encodeHeader_V1(byte msgType) argument
243 builder.appendByte(msgType);
340 final byte msgType = scanner.nextByte();
341 if (!isTypeAllowed(msgType, allowedTypes))
344 + msgType);
347 if (msgType == MSG_TYPE_ADD_V1
348 || msgType
375 isTypeAllowed(final byte msgType, byte... allowedTypes) argument
[all...]
H A DModifyDNMsg.java225 private void decodeBody_V123(ByteArrayScanner scanner, byte msgType) argument
235 if (msgType == MSG_TYPE_MODIFYDN)
/forgerock/opendj2/src/server/org/opends/server/tools/upgrade/
H A DUpgradeContext.java302 * @param msgType
307 void notify(final Message message, final int msgType) throws ClientException argument
312 message, msgType) });
/forgerock/opendj2.6.2/src/server/org/opends/server/tools/upgrade/
H A DUpgradeContext.java303 * @param msgType
308 void notify(final Message message, final int msgType) throws ClientException argument
313 message, msgType) });
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DStartMsg.java71 * @param msgType The type of the message to create.
76 void encodeHeader(byte msgType, ByteArrayBuilder builder, short protocolVersion) argument
81 builder.appendByte(msgType);
91 * @param msgType The type of the message to create.
95 void encodeHeader_V1(byte msgType, ByteArrayBuilder builder) argument
100 builder.appendByte(msgType);
117 final byte msgType = scanner.nextByte();
118 if (!isTypeAllowed(allowedTypes, msgType))
121 + msgType);
127 if (msgType
160 isTypeAllowed(byte[] allowedTypes, final byte msgType) argument
[all...]
H A DUpdateMsg.java215 * @param msgType The type of UpdateMsg to encode.
219 protected ByteArrayBuilder encodeHeader(byte msgType, short protocolVersion) argument
223 builder.appendByte(msgType);
247 final byte msgType = scanner.nextByte();
248 if (allowedType != msgType)
251 + msgType);
H A DLDAPUpdateMsg.java212 public ByteArrayBuilder encodeHeader(byte msgType, short protocolVersion) argument
219 builder.appendByte(msgType);
234 * @param msgType the type of UpdateMessage to encode.
237 ByteArrayBuilder encodeHeader_V1(byte msgType) argument
243 builder.appendByte(msgType);
340 final byte msgType = scanner.nextByte();
341 if (!isTypeAllowed(msgType, allowedTypes))
344 + msgType);
347 if (msgType == MSG_TYPE_ADD_V1
348 || msgType
375 isTypeAllowed(final byte msgType, byte... allowedTypes) argument
[all...]
H A DModifyDNMsg.java225 private void decodeBody_V123(ByteArrayScanner scanner, byte msgType) argument
235 if (msgType == MSG_TYPE_MODIFYDN)
/forgerock/opendj2-hg/src/server/org/opends/server/tools/upgrade/
H A DUpgradeContext.java302 * @param msgType
307 void notify(final Message message, final int msgType) throws ClientException argument
312 message, msgType) });
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DStartMsg.java71 * @param msgType The type of the message to create.
76 void encodeHeader(byte msgType, ByteArrayBuilder builder, short protocolVersion) argument
81 builder.appendByte(msgType);
91 * @param msgType The type of the message to create.
95 void encodeHeader_V1(byte msgType, ByteArrayBuilder builder) argument
100 builder.appendByte(msgType);
117 final byte msgType = scanner.nextByte();
118 if (!isTypeAllowed(allowedTypes, msgType))
121 + msgType);
127 if (msgType
160 isTypeAllowed(byte[] allowedTypes, final byte msgType) argument
[all...]
H A DUpdateMsg.java216 * @param msgType The type of UpdateMsg to encode.
220 protected ByteArrayBuilder encodeHeader(byte msgType, short protocolVersion) argument
223 builder.appendByte(msgType);
247 final byte msgType = scanner.nextByte();
248 if (allowedType != msgType)
251 + msgType);
H A DLDAPUpdateMsg.java216 public ByteArrayBuilder encodeHeader(byte msgType, short protocolVersion) argument
223 builder.appendByte(msgType);
238 * @param msgType the type of UpdateMessage to encode.
241 ByteArrayBuilder encodeHeader_V1(byte msgType) argument
247 builder.appendByte(msgType);
344 final byte msgType = scanner.nextByte();
345 if (!isTypeAllowed(msgType, allowedTypes))
348 + msgType);
351 if (msgType == MSG_TYPE_ADD_V1
352 || msgType
379 isTypeAllowed(final byte msgType, byte... allowedTypes) argument
[all...]
H A DModifyDNMsg.java226 private void decodeBody_V123(ByteArrayScanner scanner, byte msgType) argument
236 if (msgType == MSG_TYPE_MODIFYDN)
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/tools/upgrade/
H A DUpgradeContext.java249 * @param msgType
254 void notify(final LocalizableMessage message, final int msgType) throws ClientException argument
259 message, msgType) });
/forgerock/opendj-b2.6/src/server/org/opends/server/tools/upgrade/
H A DUpgradeContext.java264 * @param msgType
269 public void notify(final Message message, final int msgType) argument
275 message, msgType) });
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DNotAssuredUpdateMsg.java317 protected void decodeHeader(byte msgType, ByteArrayScanner scanner) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/tools/upgrade/
H A DUpgradeContext.java264 * @param msgType
269 public void notify(final Message message, final int msgType) argument
275 message, msgType) });
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DNotAssuredUpdateMsg.java317 protected void decodeHeader(byte msgType, ByteArrayScanner scanner) argument
/forgerock/openam-v13/openam-authentication/openam-auth-ldap/src/main/java/com/sun/identity/authentication/modules/ldap/
H A DLDAPCallbacks.java186 private void messageCallback(int msgType, String msg) argument
193 callbacks[0] = new TextOutputCallback (msgType,msg);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DNotAssuredUpdateMsg.java312 protected void decodeHeader(byte msgType, ByteArrayScanner scanner) argument
/forgerock/openam/openam-authentication/openam-auth-ldap/src/main/java/com/sun/identity/authentication/modules/ldap/
H A DLDAPCallbacks.java186 private void messageCallback(int msgType, String msg) argument
193 callbacks[0] = new TextOutputCallback (msgType,msg);
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java1089 * @param msgType Class of the message we are waiting for.
1092 protected static ReplicationMsg waitForSpecificMsg(Session session, String msgType) { argument
1107 fail("Exception waiting for " + msgType + " message : " +
1112 if (rcvMsgType.equals(msgType))
1122 fail("Failed to receive an expected " + msgType +
1132 * @param msgType Class of the message we are waiting for.
1135 protected static ReplicationMsg waitForSpecificMsg(ReplicationBroker broker, String msgType) { argument
1150 fail("Exception waiting for " + msgType + " message : " +
1155 if (rcvMsgType.equals(msgType))
1165 fail("Failed to receive an expected " + msgType
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java1089 * @param msgType Class of the message we are waiting for.
1092 protected static ReplicationMsg waitForSpecificMsg(Session session, String msgType) { argument
1107 fail("Exception waiting for " + msgType + " message : " +
1112 if (rcvMsgType.equals(msgType))
1122 fail("Failed to receive an expected " + msgType +
1132 * @param msgType Class of the message we are waiting for.
1135 protected static ReplicationMsg waitForSpecificMsg(ReplicationBroker broker, String msgType) { argument
1150 fail("Exception waiting for " + msgType + " message : " +
1155 if (rcvMsgType.equals(msgType))
1165 fail("Failed to receive an expected " + msgType
[all...]

Completed in 92 milliseconds

12