Searched refs:bytesRead (Results 101 - 125 of 150) sorted by relevance

123456

/forgerock/opendj2-jel-hg/src/server/org/opends/server/crypto/
H A DCryptoManagerImpl.java2672 int bytesRead = inputStream.read(buffer);
2673 if (bytesRead < 0)
2678 digest.update(buffer, 0, bytesRead);
2695 int bytesRead = inputStream.read(buffer);
2696 if (bytesRead < 0)
2701 digest.update(buffer, 0, bytesRead);
/forgerock/opendj2-hg/src/server/org/opends/server/crypto/
H A DCryptoManagerImpl.java2677 int bytesRead = inputStream.read(buffer);
2678 if (bytesRead < 0)
2683 digest.update(buffer, 0, bytesRead);
2701 int bytesRead = inputStream.read(buffer);
2702 if (bytesRead < 0)
2707 digest.update(buffer, 0, bytesRead);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/crypto/
H A DCryptoManagerImpl.java2463 int bytesRead = inputStream.read(buffer);
2464 if (bytesRead < 0)
2469 digest.update(buffer, 0, bytesRead);
2487 int bytesRead = inputStream.read(buffer);
2488 if (bytesRead < 0)
2493 digest.update(buffer, 0, bytesRead);
/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java166 int bytesRead = clientChannel.read(byteBuffer);
167 if (bytesRead > 0 && keepStats)
169 statTracker.updateBytesRead(bytesRead);
171 return bytesRead;
/forgerock/opendj2/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java165 int bytesRead = clientChannel.read(byteBuffer);
166 if (bytesRead > 0 && keepStats)
168 statTracker.updateBytesRead(bytesRead);
170 return bytesRead;
/forgerock/opendj2.6.2/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java166 int bytesRead = clientChannel.read(byteBuffer);
167 if (bytesRead > 0 && keepStats)
169 statTracker.updateBytesRead(bytesRead);
171 return bytesRead;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java166 int bytesRead = clientChannel.read(byteBuffer);
167 if (bytesRead > 0 && keepStats)
169 statTracker.updateBytesRead(bytesRead);
171 return bytesRead;
/forgerock/opendj2-hg/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java165 int bytesRead = clientChannel.read(byteBuffer);
166 if (bytesRead > 0 && keepStats)
168 statTracker.updateBytesRead(bytesRead);
170 return bytesRead;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java155 int bytesRead = clientChannel.read(byteBuffer);
156 if (bytesRead > 0 && keepStats)
158 statTracker.updateBytesRead(bytesRead);
160 return bytesRead;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/
H A DOnDiskMergeImporter.java1691 private volatile long bytesRead; field in class:OnDiskMergeImporter.ExternalSortChunk.InMemorySortedChunk.InMemorySortedChunkCursor
1697 if (bytesRead >= totalBytes)
1714 bytesRead += keyHeaderSize + keyLength + valueHeaderSize + valueLength;
1762 return bytesRead;
2081 private volatile long bytesRead; field in class:OnDiskMergeImporter.ExternalSortChunk.CompositeCursor
2107 bytesRead += (cursor.getNbBytesRead() - previousBytesRead);
2140 bytesRead += (lowestCursor.getNbBytesRead() - previousBytesRead);
2191 return bytesRead;
3330 private volatile long bytesRead; field in class:OnDiskMergeImporter.MeteredSequentialCursorDecorator
3345 bytesRead
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/
H A DTestCaseUtils.java1811 int bytesRead;
1812 while ((bytesRead = is.read(buf)) != -1) {
1813 bout.write(buf, 0, bytesRead);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/
H A DTestCaseUtils.java1725 int bytesRead;
1726 while ((bytesRead = is.read(buf)) != -1) {
1727 bout.write(buf, 0, bytesRead);
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/
H A DTestCaseUtils.java1811 int bytesRead;
1812 while ((bytesRead = is.read(buf)) != -1) {
1813 bout.write(buf, 0, bytesRead);
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/
H A DTestCaseUtils.java1725 int bytesRead;
1726 while ((bytesRead = is.read(buf)) != -1) {
1727 bout.write(buf, 0, bytesRead);
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/
H A DTestCaseUtils.java1920 int bytesRead;
1921 while ((bytesRead = is.read(buf)) != -1) {
1922 bout.write(buf, 0, bytesRead);
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/
H A DTestCaseUtils.java1662 int bytesRead;
1663 while ((bytesRead = is.read(buf)) != -1) {
1664 bout.write(buf, 0, bytesRead);
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1912 private final AtomicLong bytesRead = new AtomicLong(); field in class:Importer.IndexDBWriteTask
2112 final long tmpBytesRead = bytesRead.get();
2314 private void addBytesRead(int bytesRead) argument
2316 this.bytesRead.addAndGet(bytesRead);
3088 * @param bytesRead
3091 void addBytesRead(int bytesRead) argument
3095 writer.addBytesRead(bytesRead);
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1878 private final AtomicLong bytesRead = new AtomicLong(); field in class:Importer.IndexDBWriteTask
2078 final long tmpBytesRead = bytesRead.get();
2280 private void addBytesRead(int bytesRead) argument
2282 this.bytesRead.addAndGet(bytesRead);
3054 * @param bytesRead
3057 void addBytesRead(int bytesRead) argument
3061 writer.addBytesRead(bytesRead);
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1878 private final AtomicLong bytesRead = new AtomicLong(); field in class:Importer.IndexDBWriteTask
2078 final long tmpBytesRead = bytesRead.get();
2280 private void addBytesRead(int bytesRead) argument
2282 this.bytesRead.addAndGet(bytesRead);
3054 * @param bytesRead
3057 void addBytesRead(int bytesRead) argument
3061 writer.addBytesRead(bytesRead);
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1912 private final AtomicLong bytesRead = new AtomicLong(); field in class:Importer.IndexDBWriteTask
2112 final long tmpBytesRead = bytesRead.get();
2314 private void addBytesRead(int bytesRead) argument
2316 this.bytesRead.addAndGet(bytesRead);
3088 * @param bytesRead
3091 void addBytesRead(int bytesRead) argument
3095 writer.addBytesRead(bytesRead);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/importLDIF/
H A DImporter.java1878 private final AtomicLong bytesRead = new AtomicLong(); field in class:Importer.IndexDBWriteTask
2078 final long tmpBytesRead = bytesRead.get();
2280 private void addBytesRead(int bytesRead) argument
2282 this.bytesRead.addAndGet(bytesRead);
3054 * @param bytesRead
3057 void addBytesRead(int bytesRead) argument
3061 writer.addBytesRead(bytesRead);
/forgerock/opendj-b2.6/src/server/org/opends/server/util/
H A DLDIFReader.java2024 int bytesRead;
2025 while ((bytesRead = inputStream.read(buffer)) > 0)
2027 builder.append(buffer, 0, bytesRead);
/forgerock/opendj2.6.2/src/server/org/opends/server/util/
H A DLDIFReader.java2024 int bytesRead;
2025 while ((bytesRead = inputStream.read(buffer)) > 0)
2027 builder.append(buffer, 0, bytesRead);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/util/
H A DLDIFReader.java2024 int bytesRead;
2025 while ((bytesRead = inputStream.read(buffer)) > 0)
2027 builder.append(buffer, 0, bytesRead);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/util/
H A DStaticUtils.java2155 int bytesRead = inputStream.read(buffer);
2156 if (bytesRead < 0)
2161 outputStream.write(buffer, 0, bytesRead);

Completed in 329 milliseconds

123456