Searched refs:msgType (Results 1 - 25 of 77) sorted by relevance

1234

/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 DDoneMsg.java59 final byte msgType = scanner.nextByte();
60 if (msgType != MSG_TYPE_DONE)
H A DWindowMsg.java66 final byte msgType = scanner.nextByte();
67 if (msgType != MSG_TYPE_WINDOW)
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 DMonitorRequestMsg.java73 final byte msgType = scanner.nextByte();
74 if (msgType != MSG_TYPE_REPL_SERVER_MONITOR_REQUEST)
H A DChangeTimeHeartbeatMsg.java86 final byte msgType = scanner.nextByte();
87 if (msgType != MSG_TYPE_CT_HEARTBEAT)
90 + getClass().getSimpleName() + " message: " + msgType);
H A DReplicaOfflineMsg.java65 final byte msgType = scanner.nextByte();
66 if (msgType != MSG_TYPE_REPLICA_OFFLINE)
69 + getClass().getSimpleName() + " message: " + msgType);
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 DEntryMsg.java86 final byte msgType = scanner.nextByte();
87 if (msgType != MSG_TYPE_ENTRY)
/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 DDoneMsg.java59 final byte msgType = scanner.nextByte();
60 if (msgType != MSG_TYPE_DONE)
H A DWindowMsg.java66 final byte msgType = scanner.nextByte();
67 if (msgType != MSG_TYPE_WINDOW)
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 DMonitorRequestMsg.java73 final byte msgType = scanner.nextByte();
74 if (msgType != MSG_TYPE_REPL_SERVER_MONITOR_REQUEST)
H A DChangeTimeHeartbeatMsg.java86 final byte msgType = scanner.nextByte();
87 if (msgType != MSG_TYPE_CT_HEARTBEAT)
90 + getClass().getSimpleName() + " message: " + msgType);
H A DReplicaOfflineMsg.java65 final byte msgType = scanner.nextByte();
66 if (msgType != MSG_TYPE_REPLICA_OFFLINE)
69 + getClass().getSimpleName() + " message: " + msgType);
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);
/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 DDoneMsg.java59 final byte msgType = scanner.nextByte();
60 if (msgType != MSG_TYPE_DONE)
H A DWindowMsg.java66 final byte msgType = scanner.nextByte();
67 if (msgType != MSG_TYPE_WINDOW)
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 DMonitorRequestMsg.java75 final byte msgType = scanner.nextByte();
76 if (msgType != MSG_TYPE_REPL_SERVER_MONITOR_REQUEST)
H A DChangeTimeHeartbeatMsg.java86 final byte msgType = scanner.nextByte();
87 if (msgType != MSG_TYPE_CT_HEARTBEAT)
90 + getClass().getSimpleName() + " message: " + msgType);
H A DReplicaOfflineMsg.java65 final byte msgType = scanner.nextByte();
66 if (msgType != MSG_TYPE_REPLICA_OFFLINE)
69 + getClass().getSimpleName() + " message: " + msgType);
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);

Completed in 44 milliseconds

1234