Examples of java.nio.channels.DatagramChannel.connect()

java.nio.channels.DatagramChannel.connect()
Connect the socket of this channel to a remote address, which is the only communication peer of getting and sending datagrams after connected.
This method can be called at any moment, and won't affect the processing read and write operation. The connect status won't changed before disconnected and closed.

This method just execute the same security checks as the connect method of the DatagramSocket class.
@param address The address to be connected. @return This channel. @throws ClosedChannelException If the channel is already closed. @throws AsynchronousCloseException If the channel is closed by another thread while this method is in operation. @throws ClosedByInterruptException If another thread interrupts the calling thread while the operation is in progress. The calling thread will have the interrupt state set, and the channel will be closed. @throws SecurityException If there is a security manager, and the address is not permitted to access. @throws IOException Some other IO error occurred.

            channel.read(c.asReadOnlyBuffer());
            fail("Should throw NotYetConnectedException");
        } catch (NotYetConnectedException e){
            // expected
        }
        channel.connect(localAddr1);
        try{
            channel.read(c.asReadOnlyBuffer());
            fail("Should throw IllegalArgumentException");
        } catch (IllegalArgumentException e){
            // expected

View Full Code Here

            ch.socket().setReuseAddress( true );
            if( localAddress != null )
            {
                ch.socket().bind( localAddress );
            }
            ch.connect( address );
            ch.configureBlocking( false );
            initialized = true;
        }
        finally
        {

View Full Code Here

            }
            if( localAddress != null )
            {
                ch.socket().bind( localAddress );
            }
            ch.connect( address );
            ch.configureBlocking( false );
            initialized = true;
        }
        catch( IOException e )
        {

View Full Code Here

            }


            if (localAddress != null) {
                ch.socket().bind(localAddress);
            }
            ch.connect(address);
            ch.configureBlocking(false);
            initialized = true;
        } catch (IOException e) {
            return DefaultConnectFuture.newFailedFuture(e);
        } finally {

View Full Code Here

void
connect(SocketAddress addr) throws IOException {
  if (!bound)
    bind(null);
  DatagramChannel channel = (DatagramChannel) key.channel();
  channel.connect(addr);
}


void
send(byte [] data) throws IOException {
  DatagramChannel channel = (DatagramChannel) key.channel();

View Full Code Here

            socket.bind(localAddress);


            datagramChannel.configureBlocking(false);


            if (remoteAddress != null) {
                datagramChannel.connect(remoteAddress);
            }


            preConfigure(newConnection);


            newConnection.setProcessor(getProcessor());

View Full Code Here


            if( localAddress != null )
            {
                ch.socket().bind( localAddress );
            }
            ch.connect( address );
            ch.configureBlocking( false );
            initialized = true;
        }
        catch( IOException e )
        {

View Full Code Here

      @Override
      public void run() {
        try {
          DatagramChannel udp = DatagramChannel.open();
          udp.configureBlocking(true);
          udp.connect(new InetSocketAddress(port));


          byte[] data = new byte[1024];
          new Random().nextBytes(data);
          for (int i = 0; i < 4; i++) {
            udp.write(ByteBuffer.wrap(data));

View Full Code Here

          channel.connect(connectAddr);
          out = channel;
        }
        else {
          DatagramChannel channel = DatagramChannel.open();
          channel.connect(connectAddr);
          out = channel;
        }


        ByteBuffer buff = ByteBuffer.wrap(
            ("<34>Oct 11 22:14:15 mymachine su: 'su root' failed for lonvick on /dev/pts/8\n").getBytes()

View Full Code Here

            resultingChannel.socket().bind(new InetSocketAddress(0));
        } catch (SocketException e) {
            errorReporter.reportError(e.getMessage(), e);
        }


        resultingChannel.connect(new InetSocketAddress(this.host, this.port));
        resultingChannel.configureBlocking(false);


        return resultingChannel;
    }

View Full Code Here

0 1 2 3 4 5

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.