Searched defs:protocolVersion (Results 101 - 125 of 200) sorted by relevance

12345678

/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DAckMsg.java196 public byte[] getBytes(short protocolVersion) argument
H A DModifyMsg.java89 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 DReplServerStartMsg.java123 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 DStartMsg.java40 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 DPreParseBindOperation.java74 * @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 DBindOperation.java84 * @param protocolVersion The string representation of the protocol version
87 public void setProtocolVersion(String protocolVersion); argument
H A DBindOperationWrapper.java244 public void setProtocolVersion(String protocolVersion) argument
246 getOperation().setProtocolVersion(protocolVersion);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/
H A DDSInfo.java65 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 DMonitorMsg.java333 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 DStartECLSessionMsg.java215 public byte[] getBytes(short protocolVersion) argument
H A DUpdateMsg.java46 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 DLightweightServerHandler.java93 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 DBindOperation.java83 * @param protocolVersion The string representation of the protocol version
86 public void setProtocolVersion(String protocolVersion); argument
H A DBindOperationWrapper.java243 public void setProtocolVersion(String protocolVersion) argument
245 getOperation().setProtocolVersion(protocolVersion);
/forgerock/opendj2/src/server/org/opends/server/replication/common/
H A DDSInfo.java63 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 DServerState.java228 * @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 DDeleteMsg.java92 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 DMonitorMsg.java272 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 DReplServerStartDSMsg.java176 public byte[] getBytes(short protocolVersion) argument
184 encodeHeader(MSG_TYPE_REPL_SERVER_START_DS, builder, protocolVersion);
242 "\nprotocolVersion: " + protocolVersion +
H A DServerStartMsg.java203 public byte[] getBytes(short protocolVersion) argument
206 encodeHeader(MSG_TYPE_SERVER_START, builder, protocolVersion);
261 "\nprotocolVersion: " + protocolVersion +
H A DStartSessionMsg.java116 public byte[] getBytes(short protocolVersion) argument
118 if (protocolVersion <= ProtocolVersion.REPLICATION_PROTOCOL_V3)
124 return getBytes_V45(protocolVersion);
H A DUpdateMsg.java44 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 DNotAssuredUpdateMsg.java167 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 DBindOperation.java84 * @param protocolVersion The string representation of the protocol version
87 public void setProtocolVersion(String protocolVersion); argument
H A DBindOperationWrapper.java244 public void setProtocolVersion(String protocolVersion) argument
246 getOperation().setProtocolVersion(protocolVersion);

Completed in 113 milliseconds

12345678