| /openjdk7/jdk/test/sun/misc/IoTrace/ |
| H A D | IoTraceListener.java | 69 * @param bytesRead
74 int timeout, long bytesRead);
114 * @param bytesRead
118 public void fileReadEnd(Object context, long bytesRead); argument
73 socketReadEnd(Object context, InetAddress address, int port, int timeout, long bytesRead) argument
|
| H A D | IoTraceAgent.java | 64 int timeout, long bytesRead) {
67 l.socketReadEnd(context, address, port, timeout, bytesRead);
95 public static void fileReadEnd(Object context, long bytesRead) { argument
98 l.fileReadEnd(context, bytesRead);
63 socketReadEnd(Object context, InetAddress address, int port, int timeout, long bytesRead) argument
|
| H A D | IoTraceBase.java | 34 private long bytesRead; field in class:IoTraceBase
43 bytesRead = 0;
72 bytesRead = br;
82 int timeout, long bytesRead) {
87 this.bytesRead = bytesRead;
120 if (bytesRead != br) {
139 if (bytesRead != br) {
81 socketReadEnd(Object context, InetAddress address, int port, int timeout, long bytesRead) argument
|
| /openjdk7/jdk/src/solaris/demo/jni/Poller/ |
| H A D | SimpleServer.java | 57 * data (bytesRead,eventsToProcess) by concurrent Consumer threads.
62 private static int bytesRead; field in class:SimpleServer
77 bytesRead = 0;
104 while ( bytesRead < bytesToRead ) {
136 while ( bytesRead < bytesToRead ) {
140 bytesRead += bytes;
150 if (bytesRead < bytesToRead)
|
| H A D | PollingServer.java | 66 * data (bytesRead,eventsToProcess) by concurrent Consumer threads.
73 private static int bytesRead = 0; field in class:PollingServer
126 while ( bytesRead < bytesToRead ) {
139 " bytes read : " + bytesRead );
141 if (bytesRead >= bytesToRead) break; // may be done!
154 while ( (cnt < numEvents) && (bytesRead < bytesToRead) ) {
230 while (bytesRead < bytesToRead) {
255 bytesRead += bytes;
|
| /openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/ |
| H A D | StressLoopback.java | 133 private volatile long bytesRead; field in class:StressLoopback.Sink
148 bytesRead += nread;
162 return bytesRead;
|
| /openjdk7/jdk/src/share/classes/sun/misc/ |
| H A D | IoTrace.java | 90 * @param bytesRead
95 int timeout, long bytesRead) {
141 * @param bytesRead
145 public static void fileReadEnd(Object context, long bytesRead) { argument
94 socketReadEnd(Object context, InetAddress address, int port, int timeout, long bytesRead) argument
|
| /openjdk7/jdk/src/share/classes/java/util/zip/ |
| H A D | Inflater.java | 81 private long bytesRead; field in class:Inflater
261 bytesRead += (thisLen - this.len);
316 return bytesRead;
357 bytesRead = bytesWritten = 0;
|
| H A D | Deflater.java | 82 private long bytesRead; field in class:Deflater
432 bytesRead += (thisLen - this.len);
472 return bytesRead;
513 bytesRead = bytesWritten = 0;
|
| /openjdk7/jdk/src/windows/classes/sun/nio/ch/ |
| H A D | WindowsAsynchronousSocketChannelImpl.java | 424 void updateBuffers(int bytesRead) { argument
429 if (bytesRead >= len) {
430 bytesRead -= len;
438 if (bytesRead > 0) {
439 assert(pos + bytesRead < (long)Integer.MAX_VALUE);
440 int newPosition = pos + bytesRead;
|
| /openjdk7/hotspot/agent/src/os/win32/windbg/ |
| H A D | sawindbg.cpp | 806 ULONG bytesRead; local
808 (ULONG)numBytes, &bytesRead) != S_OK) {
812 if (bytesRead != numBytes) {
|
| /openjdk7/hotspot/agent/src/os/solaris/proc/ |
| H A D | saproc.cpp | 1119 ssize_t bytesRead = pread(classes_jsa_fd, bufPtr, bytesToRead, offset); local
1120 if (bytesRead != bytesToRead) {
|
| /openjdk7/jdk/src/macosx/native/com/sun/media/sound/ |
| H A D | PLATFORM_API_MacOSX_PCM.cpp | 708 int bytesRead = device->ringBuffer.Read(audioBuffer->mData, bytesToRead); local
709 if (bytesRead < bytesToRead) {
711 TRACE2("--OutputCallback: !!! UNDERRUN (read %d bytes of %d)!!!\n", bytesRead, bytesToRead);
713 memset((Byte*)audioBuffer->mData + bytesRead, 0, bytesToRead-bytesRead);
714 bytesRead = bytesToRead;
717 audioBuffer->mDataByteSize = (UInt32)bytesRead;
723 TRACE1("<<OutputCallback (returns %d)\n", bytesRead);
|