Examples of java.nio.channels.SocketChannel.socket()

java.nio.channels.SocketChannel.socket()
Return the related socket of this channel, which won't declare public methods that not declared in Socket. @return The related Socket instance.

                    //Ignore, since can't happen
                }
            }
        }
        SocketChannel sc=sSocket.getChannel().accept();
        Socket s = sc.socket();
        ep.setNote( socketNote, s );
        if(log.isDebugEnabled() )
            log.debug("Accepted socket " + s +" channel "  + sc.isBlocking());


        try {

View Full Code Here

                nextAddrToTry = 0;
            }
            SocketChannel sock;
            sock = SocketChannel.open();
            sock.configureBlocking(false);
            sock.socket().setSoLinger(false, -1);
            sock.socket().setTcpNoDelay(true);
            LOG.info("Attempting connection to server " + addr);
            sockKey = sock.register(selector, SelectionKey.OP_CONNECT);
            if (sock.connect(addr)) {
                primeConnection(sockKey);

View Full Code Here

            }
            SocketChannel sock;
            sock = SocketChannel.open();
            sock.configureBlocking(false);
            sock.socket().setSoLinger(false, -1);
            sock.socket().setTcpNoDelay(true);
            LOG.info("Attempting connection to server " + addr);
            sockKey = sock.register(selector, SelectionKey.OP_CONNECT);
            if (sock.connect(addr)) {
                primeConnection(sockKey);
            }

View Full Code Here

        private void cleanup() {
            if (sockKey != null) {
                SocketChannel sock = (SocketChannel) sockKey.channel();
                sockKey.cancel();
                try {
                    sock.socket().shutdownInput();
                } catch (IOException e) {
                    LOG.warn("Ignoring exception during shutdown input", e);
                }
                try {
                    sock.socket().shutdownOutput();

View Full Code Here

                    sock.socket().shutdownInput();
                } catch (IOException e) {
                    LOG.warn("Ignoring exception during shutdown input", e);
                }
                try {
                    sock.socket().shutdownOutput();
                } catch (IOException e) {
                    LOG.warn("Ignoring exception during shutdown output", e);
                }
                try {
                    sock.socket().close();

View Full Code Here

                    sock.socket().shutdownOutput();
                } catch (IOException e) {
                    LOG.warn("Ignoring exception during shutdown output", e);
                }
                try {
                    sock.socket().close();
                } catch (IOException e) {
                    LOG.warn("Ignoring exception during socket close", e);
                }
                try {
                    sock.close();

View Full Code Here

      ServerSocketChannel server = (ServerSocketChannel) key.channel();


      SocketChannel channel;
      while ((channel = server.accept()) != null) {
        channel.configureBlocking(false);
        channel.socket().setTcpNoDelay(tcpNoDelay);
        channel.socket().setKeepAlive(tcpKeepAlive);


        Reader reader = getReader();
        try {
          reader.startAdd();

View Full Code Here


      SocketChannel channel;
      while ((channel = server.accept()) != null) {
        channel.configureBlocking(false);
        channel.socket().setTcpNoDelay(tcpNoDelay);
        channel.socket().setKeepAlive(tcpKeepAlive);


        Reader reader = getReader();
        try {
          reader.startAdd();
          SelectionKey readKey = reader.registerChannel(channel);

View Full Code Here

                    //further accepts until there is a thread available.
                    if ( running && (!paused) && socket != null ) {
                        //processSocket(socket);
                        if (!setSocketOptions(socket)) {
                            try {
                                socket.socket().close();
                                socket.close();
                            } catch (IOException ix) {
                                if (log.isDebugEnabled())
                                    log.debug("", ix);
                            }

View Full Code Here


                    if ( channel instanceof SocketChannel) {
                        SocketChannel sc = (SocketChannel)channel;
                        if ( !setSocketOptions(sc) ) {
                            try {
                                sc.socket().close();
                                sc.close();
                            }catch ( IOException ix ) {
                                if ( log.isDebugEnabled() ) log.debug("",ix);
                            }
                        } else {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.