/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | AckMsg.java | 196 public byte[] getBytes(short protocolVersion) argument
|
H A D | ModifyMsg.java | 89 if (protocolVersion <= 3) 98 if (protocolVersion==ProtocolVersion.getCurrentVersion()) 146 if (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V1) 149 " protocolVersion: " + protocolVersion + 154 (protocolVersion >= ProtocolVersion.REPLICATION_PROTOCOL_V2 ? 161 return "!!! Unknown version: " + protocolVersion + "!!!"; 199 public byte[] getBytes_V45(short protocolVersion) argument 202 encodeHeader(MSG_TYPE_MODIFY, protocolVersion);
|
H A D | ReplServerStartMsg.java | 123 if (protocolVersion > ProtocolVersion.REPLICATION_PROTOCOL_V1) 170 public byte[] getBytes(short protocolVersion) argument 173 if (protocolVersion == ProtocolVersion.REPLICATION_PROTOCOL_V1) 193 encodeHeader(MSG_TYPE_REPL_SERVER_START, builder, protocolVersion); 250 "\nprotocolVersion: " + protocolVersion +
|
H A D | StartMsg.java | 40 protected short protocolVersion; field in class:StartMsg 57 * @param protocolVersion The Replication Protocol version of the server 62 StartMsg(short protocolVersion, long generationId) argument 64 this.protocolVersion = protocolVersion; 74 * @param protocolVersion The version to use when encoding the header. 76 void encodeHeader(byte msgType, ByteArrayBuilder builder, short protocolVersion) argument 82 builder.appendByte(protocolVersion); 139 protocolVersion = ProtocolVersion.REPLICATION_PROTOCOL_V1; 154 protocolVersion [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/types/operation/ |
H A D | PreParseBindOperation.java | 74 * @param protocolVersion The string representation of the 78 void setProtocolVersion(String protocolVersion); argument
|
/forgerock/opendj-b2.6/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/opendj-b2.6/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/opendj-b2.6/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/opendj-b2.6/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/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/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/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/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/opendj2.6.2/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);
|