/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | StartMsg.java | 71 * @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 D | DoneMsg.java | 59 final byte msgType = scanner.nextByte(); 60 if (msgType != MSG_TYPE_DONE)
|
H A D | WindowMsg.java | 66 final byte msgType = scanner.nextByte(); 67 if (msgType != MSG_TYPE_WINDOW)
|
H A D | LDAPUpdateMsg.java | 212 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 D | MonitorRequestMsg.java | 73 final byte msgType = scanner.nextByte(); 74 if (msgType != MSG_TYPE_REPL_SERVER_MONITOR_REQUEST)
|
H A D | ChangeTimeHeartbeatMsg.java | 86 final byte msgType = scanner.nextByte(); 87 if (msgType != MSG_TYPE_CT_HEARTBEAT) 90 + getClass().getSimpleName() + " message: " + msgType);
|
H A D | ReplicaOfflineMsg.java | 65 final byte msgType = scanner.nextByte(); 66 if (msgType != MSG_TYPE_REPLICA_OFFLINE) 69 + getClass().getSimpleName() + " message: " + msgType);
|
H A D | UpdateMsg.java | 215 * @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 D | EntryMsg.java | 86 final byte msgType = scanner.nextByte(); 87 if (msgType != MSG_TYPE_ENTRY)
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | StartMsg.java | 71 * @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 D | DoneMsg.java | 59 final byte msgType = scanner.nextByte(); 60 if (msgType != MSG_TYPE_DONE)
|
H A D | WindowMsg.java | 66 final byte msgType = scanner.nextByte(); 67 if (msgType != MSG_TYPE_WINDOW)
|
H A D | LDAPUpdateMsg.java | 212 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 D | MonitorRequestMsg.java | 73 final byte msgType = scanner.nextByte(); 74 if (msgType != MSG_TYPE_REPL_SERVER_MONITOR_REQUEST)
|
H A D | ChangeTimeHeartbeatMsg.java | 86 final byte msgType = scanner.nextByte(); 87 if (msgType != MSG_TYPE_CT_HEARTBEAT) 90 + getClass().getSimpleName() + " message: " + msgType);
|
H A D | ReplicaOfflineMsg.java | 65 final byte msgType = scanner.nextByte(); 66 if (msgType != MSG_TYPE_REPLICA_OFFLINE) 69 + getClass().getSimpleName() + " message: " + msgType);
|
H A D | UpdateMsg.java | 215 * @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 D | StartMsg.java | 71 * @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 D | DoneMsg.java | 59 final byte msgType = scanner.nextByte(); 60 if (msgType != MSG_TYPE_DONE)
|
H A D | WindowMsg.java | 66 final byte msgType = scanner.nextByte(); 67 if (msgType != MSG_TYPE_WINDOW)
|
H A D | LDAPUpdateMsg.java | 216 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 D | MonitorRequestMsg.java | 75 final byte msgType = scanner.nextByte(); 76 if (msgType != MSG_TYPE_REPL_SERVER_MONITOR_REQUEST)
|
H A D | ChangeTimeHeartbeatMsg.java | 86 final byte msgType = scanner.nextByte(); 87 if (msgType != MSG_TYPE_CT_HEARTBEAT) 90 + getClass().getSimpleName() + " message: " + msgType);
|
H A D | ReplicaOfflineMsg.java | 65 final byte msgType = scanner.nextByte(); 66 if (msgType != MSG_TYPE_REPLICA_OFFLINE) 69 + getClass().getSimpleName() + " message: " + msgType);
|
H A D | UpdateMsg.java | 216 * @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);
|