Lines Matching defs:chan
191 System.out.println("SERVER: new connection. chan[" + sock + "]");
200 SocketChannel chan = (SocketChannel) key.channel();
201 System.out.println("SERVER: connection readable. chan[" + chan + "]");
204 closed = consume (chan);
206 closed = read (chan, key);
209 chan.close ();
235 boolean consume (SocketChannel chan) {
238 int c = chan.read (consumeBuffer);
249 private boolean read (SocketChannel chan, SelectionKey key) {
253 InputStream is = new BufferedInputStream (new NioInputStream (chan));
381 System.out.println("SERVER: orderlyCloseChannel chan[" + ch + "]");
389 System.out.println("SERVER: abortiveCloseChannel chan[" + ch + "]");
415 public NioInputStream (SocketChannel chan) throws IOException {
416 this.channel = chan;
419 key = chan.register (selector, SelectionKey.OP_READ);