/openjdk10/jdk/src/jdk.httpserver/share/classes/sun/net/httpserver/ |
H A D | HttpConnection.java | 55 SocketChannel chan; field in class:HttpConnection 70 if (chan != null) { 71 s = chan.toString(); 80 chan = c; 96 InputStream in, OutputStream rawout, SocketChannel chan, 107 this.chan = chan; 114 return chan; 122 if (logger != null && chan != null) { 123 logger.log (Level.TRACE, "Closing connection: " + chan 95 setParameters( InputStream in, OutputStream rawout, SocketChannel chan, SSLEngine engine, SSLStreams sslStreams, SSLContext sslContext, String protocol, HttpContextImpl context, InputStream raw ) argument [all...] |
H A D | SSLStreams.java | 46 SocketChannel chan; field in class:SSLStreams 57 SSLStreams (ServerImpl server, SSLContext sslctx, SocketChannel chan) throws IOException { argument 61 this.chan= chan; 63 (InetSocketAddress)chan.socket().getRemoteSocketAddress(); 68 wrapper = new EngineWrapper (chan, engine); 246 SocketChannel chan; field in class:SSLStreams.EngineWrapper 253 EngineWrapper (SocketChannel chan, SSLEngine engine) throws IOException { argument 254 this.chan = chan; [all...] |
H A D | ServerImpl.java | 329 SocketChannel chan = c.getChannel(); 330 chan.configureBlocking (false); 331 SelectionKey key = chan.register (selector, SelectionKey.OP_READ); 377 SocketChannel chan = schan.accept(); 380 if (chan != null) { 383 chan.socket().setTcpNoDelay(true); 385 chan.configureBlocking (false); 387 chan.register (selector, SelectionKey.OP_READ); 390 c.setChannel (chan); 399 SocketChannel chan 439 handle(SocketChannel chan, HttpConnection conn) argument 496 SocketChannel chan; field in class:ServerImpl.Exchange 506 Exchange(SocketChannel chan, String protocol, HttpConnection conn) argument [all...] |
/openjdk10/nashorn/samples/dynalink/ |
H A D | buffer_index.js | 56 var chan = raf.getChannel() 57 var fileSize = chan.size() 59 chan.read(buf) 60 chan.close()
|
/openjdk10/jdk/src/java.desktop/share/native/libmlib_image/ |
H A D | mlib_c_ImageConvCopyEdge.c | 74 #define EDGES(chan, type, mask) \ 84 for (l = chan - 1; l >= 0; l--) { \ 92 pdst[i*dst_stride + l + j*chan] = psrc[i*src_stride + l + j*chan]; \ 97 pdst[i*dst_stride + l+(img_width-1 - j)*chan] = \ 98 psrc[i*src_stride + l+(img_width-1 - j)*chan]; \ 103 pdst[i*dst_stride + l + j*chan] = psrc[i*src_stride + l + j*chan]; \ 108 pdst[(img_height-1 - i)*dst_stride + l + j*chan] = \ 109 psrc[(img_height-1 - i)*src_stride + l + j*chan]; \ [all...] |
H A D | mlib_ImageConvClearEdge_Fp.c | 71 #define EDGES(chan, type, mask) \ 80 for (l = chan - 1; l >= 0; l--) { \ 89 pimg[i * img_stride + l + j * chan] = color_i; \ 94 pimg[i * img_stride + l + (img_width - 1 - j) * chan] = color_i; \ 99 pimg[i * img_stride + l + j * chan] = color_i; \ 104 pimg[(img_height - 1 - i) * img_stride + l + j * chan] = color_i; \
|
H A D | mlib_c_ImageConvClearEdge.c | 70 #define EDGES(chan, type, mask) \ 79 for (l = chan - 1; l >= 0; l--) { \ 88 pdst[i*dst_stride + l + j*chan] = color_i; \ 93 pdst[i*dst_stride + l+(dst_width-1 - j)*chan] = color_i; \ 98 pdst[i*dst_stride + l + j*chan] = color_i; \ 103 pdst[(dst_height-1 - i)*dst_stride + l + j*chan] = color_i; \
|
/openjdk10/jdk/src/java.desktop/unix/native/libmlib_image/ |
H A D | mlib_ImageConvCopyEdge_Fp.c | 73 #define EDGES(chan, type, mask) \ 83 for (l = chan - 1; l >= 0; l--) { \ 91 pdst[i * dst_stride + l + j * chan] = \ 92 psrc[i * src_stride + l + j * chan]; \ 97 pdst[i * dst_stride + l + (img_width - 1 - j) * chan] = \ 98 psrc[i * src_stride + l + (img_width - 1 - j) * chan]; \ 103 pdst[i * dst_stride + l + j * chan] = \ 104 psrc[i * src_stride + l + j * chan]; \ 109 pdst[(img_height - 1 - i) * dst_stride + l + j * chan] = \ 110 psrc[(img_height - 1 - i) * src_stride + l + j * chan]; \ [all...] |
/openjdk10/jdk/test/javax/sound/midi/Synthesizer/ |
H A D | AsynchronousMidiChannel.java | 49 MidiChannel chan = null; 72 while ((i < mChanArr.length) && (chan == null)) { 74 chan = mChanArr[i++]; 76 if (chan == null) { 81 System.out.println("Got MidiChannel: "+chan); 103 chan.controlChange(contr, val); 113 if (chan.getController(contr) != val) { 117 + chan.getController(contr)); 121 + chan.getController(contr));
|
/openjdk10/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/ |
H A D | PlainHttpConnection.java | 57 protected final SocketChannel chan; field in class:PlainHttpConnection 88 client.cancelRegistration(chan); 101 return chan; 112 chan.finishConnect(); 131 chan.configureBlocking(false); 132 chan.connect(address); 142 chan.connect(address); 148 return chan; 154 this.chan = SocketChannel.open(); 156 chan [all...] |
H A D | RawChannelImpl.java | 55 SocketChannel chan = connection.channel(); 56 client.cancelRegistration(chan); 61 chan.configureBlocking(false); 64 chan.close();
|
H A D | SSLDelegate.java | 52 final SocketChannel chan; field in class:SSLDelegate 56 SSLDelegate(SSLEngine eng, SocketChannel chan, HttpClientImpl client, String sn) argument 59 this.chan = chan; 61 this.wrapper = new EngineWrapper(chan, engine); 67 SSLDelegate(SocketChannel chan, HttpClientImpl client, String[] alpn, String sn) argument 88 wrapper = new EngineWrapper(chan, engine); 89 this.chan = chan; 192 SocketChannel chan; field in class:SSLDelegate.EngineWrapper 199 EngineWrapper(SocketChannel chan, SSLEngine engine) argument [all...] |
H A D | Http1Request.java | 56 final HttpConnection chan; field in class:Http1Request 72 this.chan = connection; 187 chan.write(buffers, 0, 2); 192 chan.configureMode(Mode.BLOCKING); 194 chan.write(buffers, 0, 2); 313 chan.write(buffers, startbuf, nbufs); 339 chan.write(buffers, 3, 2); 402 chan.checkWrite(writing, buffers, startbuf, nbufs);
|
H A D | HttpClientImpl.java | 429 System.err.printf("selector chan:%s ops:%d\n", c, ops); 454 private final SelectableChannel chan; field in class:HttpClientImpl.SelectorAttachment 459 SelectorAttachment(SelectableChannel chan, Selector selector) { argument 461 this.chan = chan; 472 chan.register(selector, interestOps, this); 508 SelectionKey key = chan.keyFor(selector);
|
/openjdk10/langtools/src/jdk.jshell/share/classes/jdk/jshell/execution/ |
H A D | DemultiplexInput.java | 67 String chan = new String(name, "UTF-8"); 68 OutputStream out = io.get(chan); 70 debug("Unexpected channel name: %s", chan);
|
/openjdk10/jdk/src/java.security.jgss/share/classes/sun/security/krb5/internal/rcache/ |
H A D | AuthTime.java | 79 private static String readStringWithLength(SeekableByteChannel chan) argument 83 chan.read(bb); 91 if (chan.read(bb) != len) { 105 public static AuthTime readFrom(SeekableByteChannel chan) argument 107 String client = readStringWithLength(chan); 108 String server = readStringWithLength(chan); 110 chan.read(bb);
|
H A D | DflCache.java | 264 SeekableByteChannel chan; field in class:DflCache.Storage 290 chan = Files.newByteChannel(p, StandardOpenOption.WRITE, 293 long timeLimit = currTime.getSeconds() - readHeader(chan); 299 pos = chan.position(); 300 AuthTime a = AuthTime.readFrom(chan); 326 chan.position(pos); 333 private static int readHeader(SeekableByteChannel chan) argument 336 chan.read(bb); 349 chan.write(bb); 351 chan [all...] |
/openjdk10/jdk/src/java.desktop/unix/native/libawt/java2d/loops/ |
H A D | vis_DrawLine.c | 33 #define SET_PIX(index, chan) \ 34 pPix[chan] = pix##chan 36 #define XOR_PIX(index, chan) \ 37 pPix[chan] ^= pix##chan
|
H A D | java2d_Mlib.c | 63 #define SET_PIX(index, chan) \ 64 dst_ptr[index] = pixel##chan 109 #define XOR_PIX(index, chan) \ 110 dst_ptr[index] ^= pixel##chan 155 #define XOR_COPY(index, chan) \ 156 dst_ptr[index] = dst_ptr[index] ^ src_ptr[index] ^ pixel##chan 329 #define SCALE_COPY(index, chan) \ 330 pDst[chan] = pSrc[index]
|
/openjdk10/jdk/test/java/net/httpclient/whitebox/jdk.incubator.httpclient/jdk/incubator/http/ |
H A D | RawChannelTest.java | 85 final RawChannel chan = channelOf(port); 90 int initialBytes = chan.initialByteBuffer().remaining(); 100 chan.registerEvent(new RawChannel.RawEvent() { 115 chan.shutdownOutput(); 126 n = chan.write(array, 0, 1); 131 chan.registerEvent(this); 139 chan.registerEvent(new RawChannel.RawEvent() { 154 read = chan.read(); 164 chan.registerEvent(this);
|
H A D | SelectorTest.java | 63 String readSomeBytes(RawChannel chan) { argument 65 ByteBuffer buf = chan.read(); 67 out.println("chan read returned null"); 91 final RawChannel chan = getARawChannel(port); 93 chan.registerEvent(new RawChannel.RawEvent() { 101 readSomeBytes(chan); 111 chan.registerEvent(new RawChannel.RawEvent() { 128 chan.write(new ByteBuffer[]{bb}, 0, 1);
|
/openjdk10/jdk/test/com/sun/net/httpserver/bugs/ |
H A D | B6361557.java | 93 SocketChannel chan = (SocketChannel)key.channel(); 96 int x = chan.read(buf); 99 chan.close();
|
/openjdk10/jdk/test/sun/net/www/protocol/https/HttpsURLConnection/ |
H A D | TunnelProxy.java | 183 SocketChannel chan = (SocketChannel) key.channel(); 185 closed = consume (chan); 187 closed = read (chan, key); 190 chan.close (); 216 boolean consume (SocketChannel chan) { argument 219 int c = chan.read (consumeBuffer); 230 private boolean read (SocketChannel chan, SelectionKey key) { argument 234 InputStream is = new BufferedInputStream (new NioInputStream (chan)); 256 OutputStream os = new BufferedOutputStream(new NioOutputStream(chan)); 350 public NioInputStream (SocketChannel chan) throw argument [all...] |
/openjdk10/jdk/test/sun/net/www/protocol/https/ |
H A D | TestHttpsServer.java | 230 SocketChannel chan = (SocketChannel) key.channel(); 232 closed = consume (chan); 236 chan.close (); 265 boolean consume (SocketChannel chan) { argument 268 int c = chan.read (consumeBuffer); 434 private boolean read (SocketChannel chan, SSLEngine sslEng) { argument 438 InputStream is = new BufferedInputStream (new NioInputStream (chan, sslEng, inNetBB, inAppBB)); 457 msg = new HttpTransaction (this, cmd, uri, mhead, data, null, chan); 461 msg = new HttpTransaction (this, cmd, null, null, null, null, chan); 595 public NioInputStream (SocketChannel chan, SSLEngin argument [all...] |
/openjdk10/jdk/test/sun/net/www/httptest/ |
H A D | TestHttpServer.java | 202 System.out.println("SERVER: new connection. chan[" + sock + "]"); 211 SocketChannel chan = (SocketChannel) key.channel(); 212 System.out.println("SERVER: connection readable. chan[" + chan + "]"); 215 closed = consume (chan); 217 closed = read (chan, key); 220 chan.close (); 255 boolean consume (SocketChannel chan) { argument 258 int c = chan.read (consumeBuffer); 269 private boolean read (SocketChannel chan, SelectionKe argument 435 NioInputStream(SocketChannel chan) argument [all...] |