/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
H A D | DSInfo.java | 65 private short protocolVersion = -1; field in class:DSInfo 99 * @param protocolVersion 106 Set<String> eclIncludesForDeletes, short protocolVersion) 120 this.protocolVersion = protocolVersion; 238 return protocolVersion; 264 (protocolVersion == dsInfo.getProtocolVersion()) && 300 hash = 73 * hash + this.protocolVersion; 331 sb.append(protocolVersion); 102 DSInfo(int dsId, String dsUrl, int rsId, long generationId, ServerStatus status, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, byte groupId, List<String> refUrls, Set<String> eclIncludes, Set<String> eclIncludesForDeletes, short protocolVersion) argument
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 328 public byte[] getBytes(short protocolVersion) argument 334 if (protocolVersion > ProtocolVersion.REPLICATION_PROTOCOL_V1) 343 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V4) 362 data.replServerDbState.writeTo(writer, protocolVersion); 367 writeServerStates(protocolVersion, writer, false /* DS */); 370 writeServerStates(protocolVersion, writer, true /* RS */); 374 if (protocolVersion > ProtocolVersion.REPLICATION_PROTOCOL_V1) 406 private void writeServerStates(short protocolVersion, ASN1Writer writer, argument 423 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V7) 433 server.getValue().state.writeTo(writer, protocolVersion); [all...] |
H A D | StartECLSessionMsg.java | 215 public byte[] getBytes(short protocolVersion) argument
|
H A D | UpdateMsg.java | 46 protected short protocolVersion; field in class:UpdateMsg 122 this.protocolVersion = ProtocolVersion.getCurrentVersion(); 230 return protocolVersion; 317 protocolVersion = (short)encodedMsg[1]; 368 public byte[] getBytes(short protocolVersion) argument
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | LightweightServerHandler.java | 93 private short protocolVersion = -1; field in class:LightweightServerHandler 119 * @param protocolVersion The protocol version supported by the remote DS. 126 Set<String> eclIncludeForDeletes, short protocolVersion) 142 this.protocolVersion = protocolVersion; 161 eclInclude, eclIncludeForDeletes, protocolVersion); 121 LightweightServerHandler(ReplicationServerHandler replServerHandler, int replicationServerId, int serverId, String serverUrl, long generationId, byte groupId, ServerStatus status, List<String> refUrls, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, Set<String> eclInclude, Set<String> eclIncludeForDeletes, short protocolVersion) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/ |
H A D | BindOperation.java | 84 * @param protocolVersion The string representation of the protocol version 87 public void setProtocolVersion(String protocolVersion); argument
|
H A D | BindOperationWrapper.java | 244 public void setProtocolVersion(String protocolVersion) argument 246 getOperation().setProtocolVersion(protocolVersion);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
H A D | DSInfo.java | 65 private short protocolVersion = -1; field in class:DSInfo 99 * @param protocolVersion 106 Set<String> eclIncludesForDeletes, short protocolVersion) 120 this.protocolVersion = protocolVersion; 238 return protocolVersion; 264 (protocolVersion == dsInfo.getProtocolVersion()) && 300 hash = 73 * hash + this.protocolVersion; 331 sb.append(protocolVersion); 102 DSInfo(int dsId, String dsUrl, int rsId, long generationId, ServerStatus status, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, byte groupId, List<String> refUrls, Set<String> eclIncludes, Set<String> eclIncludesForDeletes, short protocolVersion) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 333 public byte[] getBytes(short protocolVersion) argument 339 if (protocolVersion > ProtocolVersion.REPLICATION_PROTOCOL_V1) 348 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V4) 367 data.replServerDbState.writeTo(writer, protocolVersion); 372 writeServerStates(protocolVersion, writer, false /* DS */); 375 writeServerStates(protocolVersion, writer, true /* RS */); 379 if (protocolVersion > ProtocolVersion.REPLICATION_PROTOCOL_V1) 411 private void writeServerStates(short protocolVersion, ASN1Writer writer, argument 428 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V7) 438 server.getValue().state.writeTo(writer, protocolVersion); [all...] |
H A D | StartECLSessionMsg.java | 215 public byte[] getBytes(short protocolVersion) argument
|
H A D | UpdateMsg.java | 46 protected short protocolVersion; field in class:UpdateMsg 122 this.protocolVersion = ProtocolVersion.getCurrentVersion(); 230 return protocolVersion; 317 protocolVersion = (short)encodedMsg[1]; 368 public byte[] getBytes(short protocolVersion) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | LightweightServerHandler.java | 93 private short protocolVersion = -1; field in class:LightweightServerHandler 119 * @param protocolVersion The protocol version supported by the remote DS. 126 Set<String> eclIncludeForDeletes, short protocolVersion) 142 this.protocolVersion = protocolVersion; 161 eclInclude, eclIncludeForDeletes, protocolVersion); 121 LightweightServerHandler(ReplicationServerHandler replServerHandler, int replicationServerId, int serverId, String serverUrl, long generationId, byte groupId, ServerStatus status, List<String> refUrls, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, Set<String> eclInclude, Set<String> eclIncludeForDeletes, short protocolVersion) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/core/ |
H A D | BindOperation.java | 83 * @param protocolVersion The string representation of the protocol version 86 public void setProtocolVersion(String protocolVersion); argument
|
H A D | BindOperationWrapper.java | 243 public void setProtocolVersion(String protocolVersion) argument 245 getOperation().setProtocolVersion(protocolVersion);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/ |
H A D | DSInfo.java | 63 private final short protocolVersion; field in class:DSInfo 95 * @param protocolVersion 102 Collection<String> eclIncludesForDeletes, short protocolVersion) 118 this.protocolVersion = protocolVersion; 236 return protocolVersion; 252 eclIncludesForDeletes, protocolVersion); 280 && protocolVersion == dsInfo.getProtocolVersion() 312 hash = 73 * hash + this.protocolVersion; 336 sb.append(" ; Protocol version: ").append(protocolVersion); 98 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 | 228 * @param protocolVersion 233 public void writeTo(ASN1Writer writer, short protocolVersion) argument 236 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V7)
|
/forgerock/opendj2-hg/src/server/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 | 272 public byte[] getBytes(short protocolVersion) argument 278 append(builder, senderID, protocolVersion); 279 append(builder, destination, protocolVersion); 288 data.replServerDbState.writeTo(writer, protocolVersion); 293 writeServerStates(protocolVersion, writer, false /* DS */); 294 writeServerStates(protocolVersion, writer, true /* RS */); 298 if (protocolVersion == ProtocolVersion.REPLICATION_PROTOCOL_V1) 312 short protocolVersion) 314 if (protocolVersion == ProtocolVersion.REPLICATION_PROTOCOL_V1) 318 else if (protocolVersion < 311 append(final ByteArrayBuilder builder, int data, short protocolVersion) argument 328 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(); 198 return protocolVersion; 216 * @param protocolVersion The ProtocolVersion to use when encoding. 219 protected ByteArrayBuilder encodeHeader(byte msgType, short protocolVersion) argument 254 protocolVersion = scanner.nextByte(); 280 public byte[] getBytes(short protocolVersion) argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | NotAssuredUpdateMsg.java | 167 private byte[] getRealUpdateMsgBytes(final short protocolVersion) argument 169 byte[] origBytes = realUpdateMsg.getBytes(protocolVersion); 253 public byte[] getBytes(short protocolVersion) argument 255 if (protocolVersion == ProtocolVersion.REPLICATION_PROTOCOL_V1) 309 short protocolVersion) 308 encodeHeader(byte allowedType, short protocolVersion) argument
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/core/ |
H A D | BindOperation.java | 85 * @param protocolVersion The string representation of the protocol version 88 void setProtocolVersion(String protocolVersion); argument
|
H A D | BindOperationWrapper.java | 200 public void setProtocolVersion(String protocolVersion) argument 202 getOperation().setProtocolVersion(protocolVersion);
|