/openjdk10/jdk/src/jdk.httpserver/share/classes/sun/net/httpserver/ |
H A D | FixedLengthInputStream.java | 40 private long remaining; field in class:FixedLengthInputStream 44 this.remaining = len; 49 eof = (remaining == 0L); 53 if (len > remaining) { 54 len = (int)remaining; 58 remaining -= n; 59 if (remaining == 0) { 71 return n < remaining? n: (int)remaining;
|
H A D | FixedLengthOutputStream.java | 43 private long remaining; field in class:FixedLengthOutputStream 51 this.remaining = len; 58 eof = (remaining == 0); 63 remaining --; 70 eof = (remaining == 0); 74 if (len > remaining) { 79 remaining -= len; 87 if (remaining > 0) {
|
H A D | ChunkedInputStream.java | 38 private int remaining; field in class:ChunkedInputStream 118 remaining = readChunkHeader(); 119 if (remaining == 0) { 127 if (len > remaining) { 128 len = remaining; 132 remaining -= n; 134 if (remaining == 0) { 164 return n > remaining? remaining: n;
|
/openjdk10/jdk/test/java/io/FileInputStream/ |
H A D | LargeFileAvailable.java | 62 long remaining = filesize; 63 remaining -= skipBytes(fis, bigSkip, remaining); 64 remaining -= skipBytes(fis, 10L, remaining); 65 remaining -= skipBytes(fis, bigSkip, remaining); 66 int expected = (remaining >= Integer.MAX_VALUE) 68 : (remaining > 0 ? (int) remaining [all...] |
/openjdk10/jdk/test/javax/sound/sampled/DirectAudio/ |
H A D | bug6372428.java | 113 volatile int remaining; field in class:bug6372428.WriteThread 118 remaining = data.length; 123 while (remaining > 0 && !stopRequested) { 126 if (avail > remaining) 127 avail = remaining; 128 int written = line.write(data, data.length - remaining, avail); 129 remaining -= written; 135 if (remaining == 0) { 147 return (remaining <= 0); 223 volatile int remaining; field in class:bug6372428.ReadThread [all...] |
/openjdk10/jaxws/src/java.xml.ws/share/classes/com/sun/xml/internal/ws/util/ |
H A D | MetadataUtil.java | 54 Set<String> remaining = new HashSet<String>(); 55 remaining.add(systemId); 57 while(!remaining.isEmpty()) { 58 Iterator<String> it = remaining.iterator(); 60 remaining.remove(current); 70 remaining.add(importedDoc);
|
H A D | ByteArrayBuffer.java | 104 int cap = buf.length-count; // the remaining buffer space 142 int remaining = count; 144 while(remaining > 0) { 145 int chunk = (remaining > CHUNK_SIZE) ? CHUNK_SIZE : remaining; 147 remaining -= chunk;
|
/openjdk10/hotspot/src/share/vm/gc/g1/ |
H A D | g1ConcurrentMarkObjArrayProcessor.cpp | 33 size_t G1CMObjArrayProcessor::process_array_slice(objArrayOop obj, HeapWord* start_from, size_t remaining) { argument 34 size_t words_to_scan = MIN2(remaining, ObjArrayMarkingStride); 36 if (remaining > ObjArrayMarkingStride) { 73 size_t remaining = objArray->size() - already_scanned; 75 return process_array_slice(objArray, slice, remaining);
|
H A D | g1ConcurrentMarkObjArrayProcessor.hpp | 46 size_t process_array_slice(objArrayOop const obj, HeapWord* start_from, size_t remaining);
|
/openjdk10/jdk/src/java.base/unix/native/libnio/ch/ |
H A D | PollArrayWrapper.c | 45 int remaining = timeout; local 53 int res = poll(fds, nfds, remaining); 55 if (remaining >= 0) { 59 remaining -= diff; 60 if (diff < 0 || remaining <= 0) {
|
/openjdk10/jdk/src/java.base/share/classes/java/io/ |
H A D | LineNumberInputStream.java | 181 long remaining = n; 190 while (remaining > 0) { 191 nr = read(data, 0, (int) Math.min(chunk, remaining)); 195 remaining -= nr; 198 return n - remaining;
|
H A D | InputStream.java | 204 * Reads all remaining bytes from the input stream. This method blocks until 205 * all remaining bytes have been read and end of stream is detected, or an 340 long remaining = n; 347 int size = (int)Math.min(MAX_SKIP_BUFFER_SIZE, remaining); 349 while (remaining > 0) { 350 nr = read(skipBuffer, 0, (int)Math.min(size, remaining)); 354 remaining -= nr; 357 return n - remaining;
|
/openjdk10/jdk/test/java/io/charStreams/ |
H A D | ABCInputStream.java | 83 int remaining = len - count; 84 return (remaining > chunk) ? chunk : remaining;
|
/openjdk10/jdk/src/java.base/share/classes/java/lang/ |
H A D | Process.java | 563 long remaining = n; 570 int size = (int)Math.min(2048, remaining); 572 while (remaining > 0) { 573 nr = read(skipBuffer, 0, (int)Math.min(size, remaining)); 577 remaining -= nr; 580 return n - remaining;
|
/openjdk10/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/internal/websocket/ |
H A D | UTF8AccumulatingDecoder.java | 55 int rem = leftovers.remaining(); 59 b = ByteBuffer.allocate(rem + in.remaining()); 64 CharBuffer out = CharBuffer.allocate(b.remaining()); 70 leftovers = ByteBuffer.allocate(b.remaining()).put(b).flip(); 74 // Since it's UTF-8, the assumption is leftovers.remaining() < 4 76 if (!(leftovers.remaining() < 4)) { 78 leftovers.remaining()); 82 // "...any remaining undecoded input will be treated as being
|
/openjdk10/jdk/src/java.base/share/classes/java/util/concurrent/ |
H A D | Semaphore.java | 186 int remaining = available - acquires; 187 if (remaining < 0 || 188 compareAndSetState(available, remaining)) 189 return remaining; 254 int remaining = available - acquires; 255 if (remaining < 0 || 256 compareAndSetState(available, remaining)) 257 return remaining;
|
/openjdk10/jdk/test/java/lang/ProcessBuilder/ |
H A D | SkipTest.java | 87 int remaining = BLOCK_SIZE; 89 remaining -= in.skip(remaining); 90 } while (remaining != 0); 124 int remaining = BLOCK_SIZE; 126 remaining -= in.skip(remaining); 127 } while (remaining != 0);
|
/openjdk10/jdk/src/java.base/share/classes/sun/security/ssl/ |
H A D | ByteBufferInputStream.java | 60 if (bb.remaining() == 0) { 102 int length = Math.min(bb.remaining(), len); 131 int skip = Math.min(bb.remaining(), nInt); 150 return bb.remaining();
|
H A D | ALPNExtension.java | 109 int remaining = listLength; 111 while (remaining > 0) { 121 remaining -= bytes.length + ALPN_HEADER_LENGTH; 124 if (remaining != 0) { 127 "(length=" + remaining + ")");
|
/openjdk10/jdk/test/com/sun/nio/sctp/SctpChannel/ |
H A D | Send.java | 122 int remaining = buffer.remaining(); 127 check(sent == remaining, "sent should be equal to remaining"); 140 remaining = buffer.remaining(); 145 check(sent == remaining, "sent should be equal to remaining"); 156 remaining = buffer.remaining(); [all...] |
/openjdk10/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/ |
H A D | ResponseContent.java | 158 int e = Math.min(chunkbuf.remaining(), n); 184 bytesread = chunkbuf.remaining(); 186 int space = returnBuffer.remaining(); 217 assert b1.remaining() >= numBytes; 254 int remaining = contentLength; 255 while (b.hasRemaining() && remaining > 0) { 257 int amount = Math.min(b.remaining(), remaining); 259 remaining -= amount; 263 while (remaining > [all...] |
/openjdk10/jdk/src/java.base/share/classes/java/util/zip/ |
H A D | Checksum.java | 73 * The checksum is updated with the remaining bytes in the buffer, starting 86 * buffer.remaining()); 90 * byte[] b = new byte[Math.min(buffer.remaining(), 4096)]; 92 * int length = Math.min(buffer.remaining(), b.length); 116 byte[] b = new byte[Math.min(buffer.remaining(), 4096)]; 118 int length = Math.min(buffer.remaining(), b.length);
|
/openjdk10/jdk/test/java/net/httpclient/websocket/jdk.incubator.httpclient/jdk/incubator/http/internal/websocket/ |
H A D | MaskerTest.java | 97 int srcRemaining = srcCopy.remaining(); 98 int dstRemaining = dstCopy.remaining(); 135 private static ByteBuffer createSourceBuffer(int remaining) { argument 138 byte[] bytes = new byte[leading + remaining + trailing]; 140 return ByteBuffer.wrap(bytes).position(leading).limit(leading + remaining); 143 private static ByteBuffer createDestinationBuffer(int remaining) { argument 146 return ByteBuffer.allocate(leading + remaining + trailing) 147 .position(leading).limit(leading + remaining);
|
/openjdk10/jdk/src/java.naming/share/classes/com/sun/jndi/url/ldap/ |
H A D | ldapURLContextFactory.java | 64 CompositeName remaining = new CompositeName(); 67 remaining.add(dn); 70 return new ResolveResult(ctx, remaining);
|
/openjdk10/langtools/test/jdk/jshell/ |
H A D | HangingRemoteAgent.java | 46 long remaining; 47 while ((remaining = end - System.currentTimeMillis()) > 0L) { 49 Thread.sleep(remaining);
|