Searched refs:chan (Results 1 - 25 of 34) sorted by relevance

12

/openjdk10/jdk/src/jdk.httpserver/share/classes/sun/net/httpserver/
H A DHttpConnection.java55 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 DSSLStreams.java46 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 DServerImpl.java329 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 Dbuffer_index.js56 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 Dmlib_c_ImageConvCopyEdge.c74 #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 Dmlib_ImageConvClearEdge_Fp.c71 #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 Dmlib_c_ImageConvClearEdge.c70 #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 Dmlib_ImageConvCopyEdge_Fp.c73 #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 DAsynchronousMidiChannel.java49 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 DPlainHttpConnection.java57 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 DRawChannelImpl.java55 SocketChannel chan = connection.channel();
56 client.cancelRegistration(chan);
61 chan.configureBlocking(false);
64 chan.close();
H A DSSLDelegate.java52 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 DHttp1Request.java56 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 DHttpClientImpl.java429 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 DDemultiplexInput.java67 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 DAuthTime.java79 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 DDflCache.java264 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 Dvis_DrawLine.c33 #define SET_PIX(index, chan) \
34 pPix[chan] = pix##chan
36 #define XOR_PIX(index, chan) \
37 pPix[chan] ^= pix##chan
H A Djava2d_Mlib.c63 #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 DRawChannelTest.java85 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 DSelectorTest.java63 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 DB6361557.java93 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 DTunnelProxy.java183 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 DTestHttpsServer.java230 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 DTestHttpServer.java202 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...]

Completed in 112 milliseconds

12