Searched refs:bytesRead (Results 51 - 75 of 150) sorted by relevance

123456

/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/importLDIF/
H A DIndexInputBuffer.java130 int bytesRead = 0;
131 while (bytesRead < bytesToRead)
133 bytesRead += channel.read(cache);
135 offset += bytesRead;
136 indexMgr.addBytesRead(bytesRead);
/forgerock/openam-v13/openam-shared/src/main/java/org/forgerock/openam/utils/
H A DIOUtils.java216 for (int bytesRead = in.read(buffer); bytesRead != -1; bytesRead = in.read(buffer)) {
217 out.write(buffer, 0, bytesRead);
218 bytesCopied += bytesRead;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/tools/
H A DWaitForFileDelete.java343 int bytesRead = logFile.read(logBuffer);
344 if (bytesRead > 0)
348 getOutputStream().write(logBuffer, 0, bytesRead);
355 outputFile.write(logBuffer, 0, bytesRead);
358 logFileOffset += bytesRead;
/forgerock/openam/openam-shared/src/main/java/org/forgerock/openam/utils/
H A DIOUtils.java216 for (int bytesRead = in.read(buffer); bytesRead != -1; bytesRead = in.read(buffer)) {
217 out.write(buffer, 0, bytesRead);
218 bytesCopied += bytesRead;
/forgerock/opendj-b2.6/src/server/org/opends/server/types/
H A DByteStringBuilder.java561 int bytesRead = stream.read(buffer, this.length, length);
562 if (bytesRead > 0)
564 this.length += bytesRead;
567 return bytesRead;
597 int bytesRead = channel.read(ByteBuffer.wrap(buffer, this.length, length));
598 if (bytesRead > 0)
600 this.length += bytesRead;
602 return bytesRead;
/forgerock/opendj2/src/server/org/opends/server/types/
H A DByteStringBuilder.java562 int bytesRead = stream.read(buffer, this.length, length);
563 if (bytesRead > 0)
565 this.length += bytesRead;
568 return bytesRead;
625 int bytesRead = channel.read(ByteBuffer.wrap(buffer, this.length, length));
626 if (bytesRead > 0)
628 this.length += bytesRead;
630 return bytesRead;
/forgerock/opendj2.6.2/src/server/org/opends/server/types/
H A DByteStringBuilder.java561 int bytesRead = stream.read(buffer, this.length, length);
562 if (bytesRead > 0)
564 this.length += bytesRead;
567 return bytesRead;
597 int bytesRead = channel.read(ByteBuffer.wrap(buffer, this.length, length));
598 if (bytesRead > 0)
600 this.length += bytesRead;
602 return bytesRead;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/types/
H A DByteStringBuilder.java561 int bytesRead = stream.read(buffer, this.length, length);
562 if (bytesRead > 0)
564 this.length += bytesRead;
567 return bytesRead;
597 int bytesRead = channel.read(ByteBuffer.wrap(buffer, this.length, length));
598 if (bytesRead > 0)
600 this.length += bytesRead;
602 return bytesRead;
/forgerock/opendj2-hg/src/server/org/opends/server/types/
H A DByteStringBuilder.java562 int bytesRead = stream.read(buffer, this.length, length);
563 if (bytesRead > 0)
565 this.length += bytesRead;
568 return bytesRead;
625 int bytesRead = channel.read(ByteBuffer.wrap(buffer, this.length, length));
626 if (bytesRead > 0)
628 this.length += bytesRead;
630 return bytesRead;
/forgerock/opendj2/src/server/org/opends/server/backends/jeb/
H A DBackupManager.java1011 int bytesRead = zipStream.read(buffer);
1012 while (bytesRead > 0 && !restoreConfig.isCancelled())
1014 totalBytesRead += bytesRead;
1018 mac.update(buffer, 0, bytesRead);
1023 digest.update(buffer, 0, bytesRead);
1028 outputStream.write(buffer, 0, bytesRead);
1031 bytesRead = zipStream.read(buffer);
1113 int bytesRead = inputStream.read(buffer);
1114 while (bytesRead > 0 && !backupConfig.isCancelled())
1118 mac.update(buffer, 0, bytesRead);
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/
H A DBackupManager.java1101 int bytesRead = zipStream.read(buffer);
1102 while (bytesRead > 0 && !restoreConfig.isCancelled())
1104 totalBytesRead += bytesRead;
1108 mac.update(buffer, 0, bytesRead);
1113 digest.update(buffer, 0, bytesRead);
1118 outputStream.write(buffer, 0, bytesRead);
1121 bytesRead = zipStream.read(buffer);
1203 int bytesRead = inputStream.read(buffer);
1204 while (bytesRead > 0 && !backupConfig.isCancelled())
1208 mac.update(buffer, 0, bytesRead);
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/
H A DBackupManager.java1101 int bytesRead = zipStream.read(buffer);
1102 while (bytesRead > 0 && !restoreConfig.isCancelled())
1104 totalBytesRead += bytesRead;
1108 mac.update(buffer, 0, bytesRead);
1113 digest.update(buffer, 0, bytesRead);
1118 outputStream.write(buffer, 0, bytesRead);
1121 bytesRead = zipStream.read(buffer);
1203 int bytesRead = inputStream.read(buffer);
1204 while (bytesRead > 0 && !backupConfig.isCancelled())
1208 mac.update(buffer, 0, bytesRead);
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/
H A DBackupManager.java1011 int bytesRead = zipStream.read(buffer);
1012 while (bytesRead > 0 && !restoreConfig.isCancelled())
1014 totalBytesRead += bytesRead;
1018 mac.update(buffer, 0, bytesRead);
1023 digest.update(buffer, 0, bytesRead);
1028 outputStream.write(buffer, 0, bytesRead);
1031 bytesRead = zipStream.read(buffer);
1113 int bytesRead = inputStream.read(buffer);
1114 while (bytesRead > 0 && !backupConfig.isCancelled())
1118 mac.update(buffer, 0, bytesRead);
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/
H A DBackupManager.java1101 int bytesRead = zipStream.read(buffer);
1102 while (bytesRead > 0 && !restoreConfig.isCancelled())
1104 totalBytesRead += bytesRead;
1108 mac.update(buffer, 0, bytesRead);
1113 digest.update(buffer, 0, bytesRead);
1118 outputStream.write(buffer, 0, bytesRead);
1121 bytesRead = zipStream.read(buffer);
1203 int bytesRead = inputStream.read(buffer);
1204 while (bytesRead > 0 && !backupConfig.isCancelled())
1208 mac.update(buffer, 0, bytesRead);
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DConfigFileHandler.java832 int bytesRead = inputStream.read(buffer);
833 if (bytesRead < 0)
838 sha1Digest.update(buffer, 0, bytesRead);
960 int bytesRead = inputStream.read(buffer);
961 if (bytesRead < 0)
966 sha1Digest.update(buffer, 0, bytesRead);
2019 int bytesRead = inputStream.read(buffer);
2020 if (bytesRead < 0)
2025 outputStream.write(buffer, 0, bytesRead);
2217 int bytesRead
[all...]
/forgerock/opendj2/src/server/org/opends/server/extensions/
H A DConfigFileHandler.java682 int bytesRead = inputStream.read(buffer);
683 if (bytesRead < 0)
688 sha1Digest.update(buffer, 0, bytesRead);
801 int bytesRead = inputStream.read(buffer);
802 if (bytesRead < 0)
807 sha1Digest.update(buffer, 0, bytesRead);
1748 int bytesRead = inputStream.read(buffer);
1749 if (bytesRead < 0)
1754 outputStream.write(buffer, 0, bytesRead);
1945 int bytesRead
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/
H A DConfigFileHandler.java832 int bytesRead = inputStream.read(buffer);
833 if (bytesRead < 0)
838 sha1Digest.update(buffer, 0, bytesRead);
960 int bytesRead = inputStream.read(buffer);
961 if (bytesRead < 0)
966 sha1Digest.update(buffer, 0, bytesRead);
2019 int bytesRead = inputStream.read(buffer);
2020 if (bytesRead < 0)
2025 outputStream.write(buffer, 0, bytesRead);
2217 int bytesRead
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/
H A DConfigFileHandler.java720 int bytesRead = inputStream.read(buffer);
721 if (bytesRead < 0)
726 sha1Digest.update(buffer, 0, bytesRead);
848 int bytesRead = inputStream.read(buffer);
849 if (bytesRead < 0)
854 sha1Digest.update(buffer, 0, bytesRead);
1885 int bytesRead = inputStream.read(buffer);
1886 if (bytesRead < 0)
1891 outputStream.write(buffer, 0, bytesRead);
2083 int bytesRead
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/
H A DConfigFileHandler.java682 int bytesRead = inputStream.read(buffer);
683 if (bytesRead < 0)
688 sha1Digest.update(buffer, 0, bytesRead);
801 int bytesRead = inputStream.read(buffer);
802 if (bytesRead < 0)
807 sha1Digest.update(buffer, 0, bytesRead);
1748 int bytesRead = inputStream.read(buffer);
1749 if (bytesRead < 0)
1754 outputStream.write(buffer, 0, bytesRead);
1945 int bytesRead
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/ldap/
H A DLDAPStatistics.java81 private AtomicLong bytesRead = new AtomicLong(0); field in class:LDAPStatistics
211 long tmpBytesRead = bytesRead.get();
268 attrs.add(createAttribute("bytesRead", String
414 bytesRead.set(0);
492 * @param bytesRead
495 public void updateBytesRead(int bytesRead) argument
497 this.bytesRead.getAndAdd(bytesRead);
712 return bytesRead.get();
/forgerock/opendj2/src/server/org/opends/server/protocols/ldap/
H A DLDAPStatistics.java80 private AtomicLong bytesRead = new AtomicLong(0); field in class:LDAPStatistics
210 long tmpBytesRead = bytesRead.get();
267 attrs.add(createAttribute("bytesRead", String
413 bytesRead.set(0);
491 * @param bytesRead
494 public void updateBytesRead(int bytesRead) argument
496 this.bytesRead.getAndAdd(bytesRead);
711 return bytesRead.get();
/forgerock/opendj2.6.2/src/server/org/opends/server/protocols/ldap/
H A DLDAPStatistics.java81 private AtomicLong bytesRead = new AtomicLong(0); field in class:LDAPStatistics
211 long tmpBytesRead = bytesRead.get();
268 attrs.add(createAttribute("bytesRead", String
414 bytesRead.set(0);
492 * @param bytesRead
495 public void updateBytesRead(int bytesRead) argument
497 this.bytesRead.getAndAdd(bytesRead);
712 return bytesRead.get();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/protocols/ldap/
H A DLDAPStatistics.java81 private AtomicLong bytesRead = new AtomicLong(0); field in class:LDAPStatistics
211 long tmpBytesRead = bytesRead.get();
268 attrs.add(createAttribute("bytesRead", String
414 bytesRead.set(0);
492 * @param bytesRead
495 public void updateBytesRead(int bytesRead) argument
497 this.bytesRead.getAndAdd(bytesRead);
712 return bytesRead.get();
/forgerock/opendj2-hg/src/server/org/opends/server/protocols/ldap/
H A DLDAPStatistics.java80 private AtomicLong bytesRead = new AtomicLong(0); field in class:LDAPStatistics
210 long tmpBytesRead = bytesRead.get();
267 attrs.add(createAttribute("bytesRead", String
413 bytesRead.set(0);
491 * @param bytesRead
494 public void updateBytesRead(int bytesRead) argument
496 this.bytesRead.getAndAdd(bytesRead);
711 return bytesRead.get();
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/protocols/ldap/
H A DLDAPStatistics.java81 private AtomicLong bytesRead = new AtomicLong(0); field in class:LDAPStatistics
205 long tmpBytesRead = bytesRead.get();
260 attrs.add(createAttribute("bytesRead", tmpBytesRead));
344 bytesRead.set(0);
422 * @param bytesRead
425 public void updateBytesRead(int bytesRead) argument
427 this.bytesRead.getAndAdd(bytesRead);
636 return bytesRead.get();

Completed in 127 milliseconds

123456