Searched refs:cio (Results 1 - 13 of 13) sorted by relevance

/openjdk7/jdk/src/share/sample/nio/server/
H A DRequestServicer.java53 private ChannelIO cio; field in class:RequestServicer
57 RequestServicer(ChannelIO cio) { argument
58 this.cio = cio;
84 do {} while (rp.send(cio)); // Send
85 do {} while (!cio.shutdown());
86 cio.close();
102 cio.shutdown();
107 cio.close();
124 do {} while (!cio
[all...]
H A DSendable.java58 boolean send(ChannelIO cio) throws IOException; argument
H A DRequestHandler.java54 private ChannelIO cio; field in class:RequestHandler
63 RequestHandler(ChannelIO cio) { argument
64 this.cio = cio;
88 if (!cio.doHandshake(sk)) {
92 if ((cio.read() < 0) || Request.isComplete(cio.getReadBuf())) {
93 rbb = cio.getReadBuf();
147 if (cio.shutdown()) {
148 cio
[all...]
H A DB1.java61 ChannelIO cio = (sslContext != null ?
67 RequestServicer svc = new RequestServicer(cio);
H A DAcceptHandler.java76 ChannelIO cio = (sslContext != null ?
82 RequestHandler rh = new RequestHandler(cio);
83 dsp.register(cio.getSocketChannel(), SelectionKey.OP_READ, rh);
H A DAcceptor.java70 ChannelIO cio = (sslContext != null ?
76 RequestHandler rh = new RequestHandler(cio);
78 d.register(cio.getSocketChannel(), SelectionKey.OP_READ, rh);
H A DBN.java62 ChannelIO cio = (sslContext != null ?
68 RequestServicer svc = new RequestServicer(cio);
H A DBP.java68 ChannelIO cio = (sslContext != null ?
74 RequestServicer svc = new RequestServicer(cio);
H A DReply.java115 public boolean send(ChannelIO cio) throws IOException { argument
121 if (cio.write(hbb) <= 0)
126 if (content.send(cio))
130 if (!cio.dataFlush())
H A DChannelIO.java76 ChannelIO cio = new ChannelIO(sc, blocking);
77 cio.requestBB = ByteBuffer.allocate(requestBBSize);
79 return cio;
H A DFileContent.java95 public boolean send(ChannelIO cio) throws IOException { argument
108 position += cio.transferTo(fc, position, length - position);
H A DStringContent.java97 public boolean send(ChannelIO cio) throws IOException { argument
100 cio.write(bb);
H A DChannelIOSecure.java190 ChannelIOSecure cio = new ChannelIOSecure(sc, blocking, sslc);
195 cio.appBBSize = cio.sslEngine.getSession().getApplicationBufferSize();
196 cio.requestBB = ByteBuffer.allocate(cio.appBBSize);
198 return cio;

Completed in 55 milliseconds