/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/ |
H A D | DSInfo.java | 62 private final short protocolVersion; field in class:DSInfo 94 * @param protocolVersion 101 Collection<String> eclIncludesForDeletes, short protocolVersion) 117 this.protocolVersion = protocolVersion; 235 return protocolVersion; 251 eclIncludesForDeletes, protocolVersion); 279 && protocolVersion == dsInfo.getProtocolVersion() 306 hash = 73 * hash + this.protocolVersion; 330 sb.append(" ; Protocol version: ").append(protocolVersion); 97 DSInfo(int dsId, String dsUrl, int rsId, long generationId, ServerStatus status, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, byte groupId, Collection<String> refUrls, Collection<String> eclIncludes, Collection<String> eclIncludesForDeletes, short protocolVersion) argument [all...] |
H A D | ServerState.java | 234 * @param protocolVersion 239 public void writeTo(ASN1Writer writer, short protocolVersion) argument 242 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V7)
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | DeleteMsg.java | 92 if (protocolVersion >= 4) 145 public byte[] getBytes_V45(short protocolVersion) argument 148 encodeHeader(MSG_TYPE_DELETE, protocolVersion); 176 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V1) 179 " protocolVersion: " + protocolVersion + 184 (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V2 ? 189 return "!!! Unknown version: " + protocolVersion + "!!!";
|
H A D | MonitorMsg.java | 270 public byte[] getBytes(short protocolVersion) argument 276 append(builder, senderID, protocolVersion); 277 append(builder, destination, protocolVersion); 286 data.replServerDbState.writeTo(writer, protocolVersion); 291 writeServerStates(protocolVersion, writer, false /* DS */); 292 writeServerStates(protocolVersion, writer, true /* RS */); 296 if (protocolVersion == ProtocolVersion.REPLICATION_PROTOCOL_V1) 310 short protocolVersion) 312 if (protocolVersion == ProtocolVersion.REPLICATION_PROTOCOL_V1) 316 else if (protocolVersion < 309 append(final ByteArrayBuilder builder, int data, short protocolVersion) argument 326 writeServerStates(short protocolVersion, ASN1Writer writer, boolean writeRSStates) argument [all...] |
H A D | ReplServerStartDSMsg.java | 176 public byte[] getBytes(short protocolVersion) argument 184 encodeHeader(MSG_TYPE_REPL_SERVER_START_DS, builder, protocolVersion); 242 "\nprotocolVersion: " + protocolVersion +
|
H A D | ServerStartMsg.java | 203 public byte[] getBytes(short protocolVersion) argument 206 encodeHeader(MSG_TYPE_SERVER_START, builder, protocolVersion); 261 "\nprotocolVersion: " + protocolVersion +
|
H A D | StartSessionMsg.java | 116 public byte[] getBytes(short protocolVersion) argument 118 if (protocolVersion <= ProtocolVersion.REPLICATION_PROTOCOL_V3) 124 return getBytes_V45(protocolVersion);
|
H A D | UpdateMsg.java | 44 protected short protocolVersion; field in class:UpdateMsg 95 this.protocolVersion = ProtocolVersion.getCurrentVersion(); 199 return protocolVersion; 217 * @param protocolVersion The ProtocolVersion to use when encoding. 220 protected ByteArrayBuilder encodeHeader(byte msgType, short protocolVersion) argument 254 protocolVersion = scanner.nextByte(); 280 public byte[] getBytes(short protocolVersion) argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | NotAssuredUpdateMsg.java | 166 private byte[] getRealUpdateMsgBytes(final short protocolVersion) argument 168 byte[] origBytes = realUpdateMsg.getBytes(protocolVersion); 248 public byte[] getBytes(short protocolVersion) argument 250 if (protocolVersion == ProtocolVersion.REPLICATION_PROTOCOL_V1) 304 short protocolVersion) 303 encodeHeader(byte allowedType, short protocolVersion) argument
|
/forgerock/opendj-b2.6/src/server/org/opends/server/core/ |
H A D | BindOperationBasis.java | 119 private String protocolVersion; field in class:BindOperationBasis 130 * @param protocolVersion The string representation of the protocol version 139 String protocolVersion, ByteString rawBindDN, 145 this.protocolVersion = protocolVersion; 189 * @param protocolVersion The string representation of the protocol version 199 String protocolVersion, ByteString rawBindDN, 205 this.protocolVersion = protocolVersion; 241 * @param protocolVersion Th 137 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, ByteString rawBindDN, ByteString simplePassword) argument 197 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, ByteString rawBindDN, String saslMechanism, ByteString saslCredentials) argument 247 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, DN bindDN, ByteString simplePassword) argument 306 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, DN bindDN, String saslMechanism, ByteString saslCredentials) argument 732 setProtocolVersion(String protocolVersion) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/ |
H A D | ServerState.java | 292 * @param protocolVersion 297 public void writeTo(ASN1Writer writer, short protocolVersion) argument 302 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V7)
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ReplicationMsg.java | 106 * @param protocolVersion 115 public abstract byte[] getBytes(short protocolVersion) argument 127 * @param protocolVersion 138 public static ReplicationMsg generateMsg(byte[] buffer, short protocolVersion) argument 175 return new InitializeRequestMsg(buffer, protocolVersion); 177 return new InitializeTargetMsg(buffer, protocolVersion); 179 return new EntryMsg(buffer, protocolVersion); 183 return new ErrorMsg(buffer, protocolVersion); 189 return new TopologyMsg(buffer, protocolVersion); 193 return new MonitorMsg(buffer, protocolVersion); [all...] |
H A D | Session.java | 106 private short protocolVersion = ProtocolVersion.getCurrentVersion(); field in class:Session 217 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V4) 337 final byte[] buffer = msg.getBytes(protocolVersion); 457 return ReplicationMsg.generateMsg(buffer, protocolVersion); 496 protocolVersion = version; 507 return protocolVersion;
|
/forgerock/opendj2/src/server/org/opends/server/core/ |
H A D | BindOperationBasis.java | 109 private String protocolVersion; field in class:BindOperationBasis 120 * @param protocolVersion The string representation of the protocol version 129 String protocolVersion, ByteString rawBindDN, 135 this.protocolVersion = protocolVersion; 179 * @param protocolVersion The string representation of the protocol version 189 String protocolVersion, ByteString rawBindDN, 195 this.protocolVersion = protocolVersion; 231 * @param protocolVersion Th 127 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, ByteString rawBindDN, ByteString simplePassword) argument 187 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, ByteString rawBindDN, String saslMechanism, ByteString saslCredentials) argument 237 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, DN bindDN, ByteString simplePassword) argument 296 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, DN bindDN, String saslMechanism, ByteString saslCredentials) argument 627 setProtocolVersion(String protocolVersion) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | AddMsg.java | 151 if (protocolVersion <= 3) 159 if (protocolVersion==ProtocolVersion.getCurrentVersion()) 209 public byte[] getBytes_V45(short protocolVersion) argument 212 encodeHeader(MSG_TYPE_ADD, protocolVersion); 329 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V1) 332 " protocolVersion: " + protocolVersion + 337 (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V2 ? 342 return "!!! Unknown version: " + protocolVersion + "!!!";
|
H A D | LDAPUpdateMsg.java | 87 this.protocolVersion = ProtocolVersion.getCurrentVersion(); 105 this.protocolVersion = ProtocolVersion.getCurrentVersion(); 212 public ByteArrayBuilder encodeHeader(byte msgType, short protocolVersion) argument 220 builder.appendByte((byte) protocolVersion); 253 public byte[] getBytes(short protocolVersion) argument 255 if (protocolVersion == ProtocolVersion.REPLICATION_PROTOCOL_V1) 259 else if (protocolVersion <= ProtocolVersion.REPLICATION_PROTOCOL_V3) 269 bytes = getBytes_V45(protocolVersion); 295 * @param protocolVersion the actual protocol version to encode into 298 protected abstract byte[] getBytes_V45(short protocolVersion); argument [all...] |
H A D | ModifyDNMsg.java | 135 if (protocolVersion <= 3) 144 if (protocolVersion==ProtocolVersion.getCurrentVersion()) 206 public byte[] getBytes_V45(short protocolVersion) argument 209 encodeHeader(MSG_TYPE_MODIFYDN, protocolVersion); 261 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V1) 264 " protocolVersion: " + protocolVersion + 272 (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V2 ? 277 return "!!! Unknown version: " + protocolVersion + "!!!";
|
H A D | ReplicationMsg.java | 110 * @param protocolVersion 116 public abstract byte[] getBytes(short protocolVersion); argument 125 * @param protocolVersion 134 public static ReplicationMsg generateMsg(byte[] buffer, short protocolVersion) argument 170 return new InitializeRequestMsg(buffer, protocolVersion); 172 return new InitializeTargetMsg(buffer, protocolVersion); 174 return new EntryMsg(buffer, protocolVersion); 178 return new ErrorMsg(buffer, protocolVersion); 184 return new TopologyMsg(buffer, protocolVersion); 188 return new MonitorMsg(buffer, protocolVersion); [all...] |
H A D | Session.java | 97 private short protocolVersion = ProtocolVersion.getCurrentVersion(); field in class:Session 208 && protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V4) 327 final byte[] buffer = msg.getBytes(protocolVersion); 433 return ReplicationMsg.generateMsg(buffer, protocolVersion); 487 protocolVersion = version; 498 return protocolVersion;
|
/forgerock/opendj2.6.2/src/server/org/opends/server/core/ |
H A D | BindOperationBasis.java | 119 private String protocolVersion; field in class:BindOperationBasis 130 * @param protocolVersion The string representation of the protocol version 139 String protocolVersion, ByteString rawBindDN, 145 this.protocolVersion = protocolVersion; 189 * @param protocolVersion The string representation of the protocol version 199 String protocolVersion, ByteString rawBindDN, 205 this.protocolVersion = protocolVersion; 241 * @param protocolVersion Th 137 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, ByteString rawBindDN, ByteString simplePassword) argument 197 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, ByteString rawBindDN, String saslMechanism, ByteString saslCredentials) argument 247 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, DN bindDN, ByteString simplePassword) argument 306 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, DN bindDN, String saslMechanism, ByteString saslCredentials) argument 732 setProtocolVersion(String protocolVersion) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
H A D | ServerState.java | 292 * @param protocolVersion 297 public void writeTo(ASN1Writer writer, short protocolVersion) argument 302 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V7)
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | ReplicationMsg.java | 106 * @param protocolVersion 115 public abstract byte[] getBytes(short protocolVersion) argument 127 * @param protocolVersion 138 public static ReplicationMsg generateMsg(byte[] buffer, short protocolVersion) argument 175 return new InitializeRequestMsg(buffer, protocolVersion); 177 return new InitializeTargetMsg(buffer, protocolVersion); 179 return new EntryMsg(buffer, protocolVersion); 183 return new ErrorMsg(buffer, protocolVersion); 189 return new TopologyMsg(buffer, protocolVersion); 193 return new MonitorMsg(buffer, protocolVersion); [all...] |
H A D | Session.java | 106 private short protocolVersion = ProtocolVersion.getCurrentVersion(); field in class:Session 217 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V4) 337 final byte[] buffer = msg.getBytes(protocolVersion); 457 return ReplicationMsg.generateMsg(buffer, protocolVersion); 496 protocolVersion = version; 507 return protocolVersion;
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/ |
H A D | BindOperationBasis.java | 119 private String protocolVersion; field in class:BindOperationBasis 130 * @param protocolVersion The string representation of the protocol version 139 String protocolVersion, ByteString rawBindDN, 145 this.protocolVersion = protocolVersion; 189 * @param protocolVersion The string representation of the protocol version 199 String protocolVersion, ByteString rawBindDN, 205 this.protocolVersion = protocolVersion; 241 * @param protocolVersion Th 137 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, ByteString rawBindDN, ByteString simplePassword) argument 197 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, ByteString rawBindDN, String saslMechanism, ByteString saslCredentials) argument 247 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, DN bindDN, ByteString simplePassword) argument 306 BindOperationBasis(ClientConnection clientConnection, long operationID, int messageID, List<Control> requestControls, String protocolVersion, DN bindDN, String saslMechanism, ByteString saslCredentials) argument 732 setProtocolVersion(String protocolVersion) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
H A D | ServerState.java | 292 * @param protocolVersion 297 public void writeTo(ASN1Writer writer, short protocolVersion) argument 302 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V7)
|