Searched defs:scanner (Results 1 - 25 of 72) sorted by relevance

123

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java72 final ByteArrayScanner scanner = new ByteArrayScanner(in);
73 final byte msgType = scanner.nextByte();
81 int nDsInfo = scanner.nextByte();
84 while (nDsInfo > 0 && !scanner.isEmpty())
86 final DSInfo dsInfo = nextDSInfo(scanner, version);
92 int nRsInfo = scanner.nextByte();
94 while (nRsInfo > 0 && !scanner.isEmpty())
96 rsInfos.add(nextRSInfo(scanner, version));
104 private DSInfo nextDSInfo(ByteArrayScanner scanner, short version) argument
107 final int dsId = scanner
146 nextRSInfo(ByteArrayScanner scanner, short version) argument
[all...]
H A DModifyMsg.java86 final ByteArrayScanner scanner = new ByteArrayScanner(in);
87 decodeHeader(scanner, MSG_TYPE_MODIFY, MSG_TYPE_MODIFY_V1);
91 decodeBody_V123(scanner);
95 decodeBody_V4(scanner);
214 private void decodeBody_V123(ByteArrayScanner scanner) argument
217 encodedMods = scanner.remainingBytes();
220 private void decodeBody_V4(ByteArrayScanner scanner) argument
223 final int modsLen = scanner.nextIntUTF8();
224 this.encodedMods = scanner.nextByteArray(modsLen);
225 scanner
[all...]
H A DStartMsg.java109 * @param scanner where to read the message from.
114 void decodeHeader(final ByteArrayScanner scanner, byte... allowedTypes) argument
117 final byte msgType = scanner.nextByte();
124 final byte version = scanner.nextByte();
143 scanner.skipZeroSeparator();
144 generationId = scanner.nextLongUTF8();
155 generationId = scanner.nextLongUTF8();
156 groupId = scanner.nextByte();
H A DDeleteMsg.java89 final ByteArrayScanner scanner = new ByteArrayScanner(in);
90 decodeHeader(scanner, MSG_TYPE_DELETE, MSG_TYPE_DELETE_V1);
94 decodeBody_V4(scanner);
160 private void decodeBody_V4(ByteArrayScanner scanner) argument
163 initiatorsName = scanner.nextString();
165 final int eclAttrLen = scanner.nextIntUTF8();
166 encodedEclIncludes = scanner.nextByteArray(eclAttrLen);
167 scanner.skipZeroSeparator();
169 isSubtreeDelete = scanner.nextBoolean();
H A DUpdateMsg.java78 final ByteArrayScanner scanner = new ByteArrayScanner(bytes);
79 decodeHeader(MSG_TYPE_GENERIC_UPDATE, scanner);
81 payload = scanner.remainingBytes();
236 * @param scanner The encoded form of the UpdateMsg.
238 * if the scanner does not contain a valid common header.
240 protected void decodeHeader(byte allowedType, ByteArrayScanner scanner) argument
247 final byte msgType = scanner.nextByte();
254 protocolVersion = scanner.nextByte();
255 csn = scanner.nextCSNUTF8();
256 assuredFlag = scanner
[all...]
H A DAddMsg.java148 final ByteArrayScanner scanner = new ByteArrayScanner(in);
149 decodeHeader(scanner, MSG_TYPE_ADD, MSG_TYPE_ADD_V1);
153 decodeBody_V123(scanner);
157 decodeBody_V4(scanner);
305 private void decodeBody_V123(ByteArrayScanner scanner) argument
308 parentEntryUUID = scanner.nextString();
309 encodedAttributes = scanner.remainingBytes();
312 private void decodeBody_V4(ByteArrayScanner scanner) argument
315 parentEntryUUID = scanner.nextString();
317 final int attrLen = scanner
[all...]
H A DLDAPUpdateMsg.java332 * @param scanner the encoded form of the UpdateMsg.
337 void decodeHeader(ByteArrayScanner scanner, byte... allowedTypes) argument
340 final byte msgType = scanner.nextByte();
358 csn = scanner.nextCSNUTF8();
359 assuredFlag = scanner.nextBoolean();
360 dn = scanner.nextDN();
361 entryUUID = scanner.nextString();
365 protocolVersion = scanner.nextByte();
366 csn = scanner.nextCSNUTF8();
367 dn = scanner
[all...]
H A DModifyDNMsg.java132 final ByteArrayScanner scanner = new ByteArrayScanner(in);
133 decodeHeader(scanner, MSG_TYPE_MODIFYDN, MSG_TYPE_MODIFYDN_V1);
137 decodeBody_V123(scanner, in[0]);
141 decodeBody_V4(scanner);
225 private void decodeBody_V123(ByteArrayScanner scanner, byte msgType) argument
228 newRDN = scanner.nextString();
229 newSuperior = scanner.nextString();
230 newSuperiorEntryUUID = scanner.nextString();
231 deleteOldRdn = scanner.nextBoolean();
237 encodedMods = scanner
241 decodeBody_V4(ByteArrayScanner scanner) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DTopologyMsg.java72 final ByteArrayScanner scanner = new ByteArrayScanner(in);
73 final byte msgType = scanner.nextByte();
81 int nDsInfo = scanner.nextByte();
84 while (nDsInfo > 0 && !scanner.isEmpty())
86 final DSInfo dsInfo = nextDSInfo(scanner, version);
92 int nRsInfo = scanner.nextByte();
94 while (nRsInfo > 0 && !scanner.isEmpty())
96 rsInfos.add(nextRSInfo(scanner, version));
104 private DSInfo nextDSInfo(ByteArrayScanner scanner, short version) argument
107 final int dsId = scanner
146 nextRSInfo(ByteArrayScanner scanner, short version) argument
[all...]
H A DModifyMsg.java86 final ByteArrayScanner scanner = new ByteArrayScanner(in);
87 decodeHeader(scanner, MSG_TYPE_MODIFY, MSG_TYPE_MODIFY_V1);
91 decodeBody_V123(scanner);
95 decodeBody_V4(scanner);
214 private void decodeBody_V123(ByteArrayScanner scanner) argument
217 encodedMods = scanner.remainingBytes();
220 private void decodeBody_V4(ByteArrayScanner scanner) argument
223 final int modsLen = scanner.nextIntUTF8();
224 this.encodedMods = scanner.nextByteArray(modsLen);
225 scanner
[all...]
H A DStartMsg.java109 * @param scanner where to read the message from.
114 void decodeHeader(final ByteArrayScanner scanner, byte... allowedTypes) argument
117 final byte msgType = scanner.nextByte();
124 final byte version = scanner.nextByte();
143 scanner.skipZeroSeparator();
144 generationId = scanner.nextLongUTF8();
155 generationId = scanner.nextLongUTF8();
156 groupId = scanner.nextByte();
H A DDeleteMsg.java89 final ByteArrayScanner scanner = new ByteArrayScanner(in);
90 decodeHeader(scanner, MSG_TYPE_DELETE, MSG_TYPE_DELETE_V1);
94 decodeBody_V4(scanner);
160 private void decodeBody_V4(ByteArrayScanner scanner) argument
163 initiatorsName = scanner.nextString();
165 final int eclAttrLen = scanner.nextIntUTF8();
166 encodedEclIncludes = scanner.nextByteArray(eclAttrLen);
167 scanner.skipZeroSeparator();
169 isSubtreeDelete = scanner.nextBoolean();
H A DUpdateMsg.java78 final ByteArrayScanner scanner = new ByteArrayScanner(bytes);
79 decodeHeader(MSG_TYPE_GENERIC_UPDATE, scanner);
81 payload = scanner.remainingBytes();
236 * @param scanner The encoded form of the UpdateMsg.
238 * if the scanner does not contain a valid common header.
240 protected void decodeHeader(byte allowedType, ByteArrayScanner scanner) argument
247 final byte msgType = scanner.nextByte();
254 protocolVersion = scanner.nextByte();
255 csn = scanner.nextCSNUTF8();
256 assuredFlag = scanner
[all...]
H A DAddMsg.java148 final ByteArrayScanner scanner = new ByteArrayScanner(in);
149 decodeHeader(scanner, MSG_TYPE_ADD, MSG_TYPE_ADD_V1);
153 decodeBody_V123(scanner);
157 decodeBody_V4(scanner);
305 private void decodeBody_V123(ByteArrayScanner scanner) argument
308 parentEntryUUID = scanner.nextString();
309 encodedAttributes = scanner.remainingBytes();
312 private void decodeBody_V4(ByteArrayScanner scanner) argument
315 parentEntryUUID = scanner.nextString();
317 final int attrLen = scanner
[all...]
H A DLDAPUpdateMsg.java332 * @param scanner the encoded form of the UpdateMsg.
337 void decodeHeader(ByteArrayScanner scanner, byte... allowedTypes) argument
340 final byte msgType = scanner.nextByte();
358 csn = scanner.nextCSNUTF8();
359 assuredFlag = scanner.nextBoolean();
360 dn = scanner.nextDN();
361 entryUUID = scanner.nextString();
365 protocolVersion = scanner.nextByte();
366 csn = scanner.nextCSNUTF8();
367 dn = scanner
[all...]
H A DModifyDNMsg.java132 final ByteArrayScanner scanner = new ByteArrayScanner(in);
133 decodeHeader(scanner, MSG_TYPE_MODIFYDN, MSG_TYPE_MODIFYDN_V1);
137 decodeBody_V123(scanner, in[0]);
141 decodeBody_V4(scanner);
225 private void decodeBody_V123(ByteArrayScanner scanner, byte msgType) argument
228 newRDN = scanner.nextString();
229 newSuperior = scanner.nextString();
230 newSuperiorEntryUUID = scanner.nextString();
231 deleteOldRdn = scanner.nextBoolean();
237 encodedMods = scanner
241 decodeBody_V4(ByteArrayScanner scanner) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DTopologyMsg.java72 final ByteArrayScanner scanner = new ByteArrayScanner(in);
73 final byte msgType = scanner.nextByte();
81 int nDsInfo = scanner.nextByte();
83 while (nDsInfo > 0 && !scanner.isEmpty())
85 final DSInfo dsInfo = nextDSInfo(scanner, version);
91 int nRsInfo = scanner.nextByte();
93 while (nRsInfo > 0 && !scanner.isEmpty())
95 rsInfos.add(nextRSInfo(scanner, version));
103 private DSInfo nextDSInfo(ByteArrayScanner scanner, short version) argument
106 final int dsId = scanner
145 nextRSInfo(ByteArrayScanner scanner, short version) argument
[all...]
H A DModifyMsg.java86 final ByteArrayScanner scanner = new ByteArrayScanner(in);
87 decodeHeader(scanner, MSG_TYPE_MODIFY, MSG_TYPE_MODIFY_V1);
91 decodeBody_V123(scanner);
95 decodeBody_V4(scanner);
214 private void decodeBody_V123(ByteArrayScanner scanner) argument
217 encodedMods = scanner.remainingBytes();
220 private void decodeBody_V4(ByteArrayScanner scanner) argument
223 final int modsLen = scanner.nextIntUTF8();
224 this.encodedMods = scanner.nextByteArray(modsLen);
225 scanner
[all...]
H A DStartMsg.java109 * @param scanner where to read the message from.
114 void decodeHeader(final ByteArrayScanner scanner, byte... allowedTypes) argument
117 final byte msgType = scanner.nextByte();
124 final byte version = scanner.nextByte();
143 scanner.skipZeroSeparator();
144 generationId = scanner.nextLongUTF8();
155 generationId = scanner.nextLongUTF8();
156 groupId = scanner.nextByte();
H A DDeleteMsg.java89 final ByteArrayScanner scanner = new ByteArrayScanner(in);
90 decodeHeader(scanner, MSG_TYPE_DELETE, MSG_TYPE_DELETE_V1);
94 decodeBody_V4(scanner);
160 private void decodeBody_V4(ByteArrayScanner scanner) argument
163 initiatorsName = scanner.nextString();
165 final int eclAttrLen = scanner.nextIntUTF8();
166 encodedEclIncludes = scanner.nextByteArray(eclAttrLen);
167 scanner.skipZeroSeparator();
169 isSubtreeDelete = scanner.nextBoolean();
H A DUpdateMsg.java78 final ByteArrayScanner scanner = new ByteArrayScanner(bytes);
79 decodeHeader(MSG_TYPE_GENERIC_UPDATE, scanner);
81 payload = scanner.remainingBytes();
236 * @param scanner The encoded form of the UpdateMsg.
238 * if the scanner does not contain a valid common header.
240 protected void decodeHeader(byte allowedType, ByteArrayScanner scanner) argument
247 final byte msgType = scanner.nextByte();
254 protocolVersion = scanner.nextByte();
255 csn = scanner.nextCSNUTF8();
256 assuredFlag = scanner
[all...]
/forgerock/openidm-v4/openidm-shell/src/main/java/org/forgerock/openidm/shell/felixgogo/debug/
H A DInteractiveObjectSetService.java170 private JsonValue loadFromConsole(Scanner scanner) { argument
176 while (scanner.hasNext()) {
177 input = scanner.next();
195 private void printExceptionHelp(Scanner scanner) throws ResourceException { argument
198 throw ResourceException.getException(scanner.nextInt(), "Test exception");
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DNotAssuredUpdateMsg.java317 protected void decodeHeader(byte msgType, ByteArrayScanner scanner) argument
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DNotAssuredUpdateMsg.java317 protected void decodeHeader(byte msgType, ByteArrayScanner scanner) argument
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DNotAssuredUpdateMsg.java312 protected void decodeHeader(byte msgType, ByteArrayScanner scanner) argument

Completed in 481 milliseconds

123