83     private static final int ST_CONNECTED = 1;

    83     private static final int ST_CONNECTED = 1;

    84     private static final int ST_KILLED = 2;

    84     private static final int ST_KILLED = 2;

    85     private int state = ST_UNINITIALIZED;

    85     private int state = ST_UNINITIALIZED;

    86 

    86 

    87     // Binding

    87     // Binding

    90 

    90 

    91     // Our socket adaptor, if any

    91     // Our socket adaptor, if any

    92     private DatagramSocket socket;

    92     private DatagramSocket socket;

    93 

    93 

    94     // Multicast support

    94     // Multicast support

   166     @Override

   166     @Override

   167     public SocketAddress getLocalAddress() throws IOException {

   167     public SocketAddress getLocalAddress() throws IOException {

   168         synchronized (stateLock) {

   168         synchronized (stateLock) {

   169             if (!isOpen())

   169             if (!isOpen())

   170                 throw new ClosedChannelException();

   170                 throw new ClosedChannelException();

   172         }

   173         }

   173     }

   174     }

   174 

   175 

   175     @Override

   176     @Override

   176     public SocketAddress getRemoteAddress() throws IOException {

   177     public SocketAddress getRemoteAddress() throws IOException {

   719             if (state != ST_UNCONNECTED)

   720             if (state != ST_UNCONNECTED)

   720                 throw new IllegalStateException("Connect already invoked");

   721                 throw new IllegalStateException("Connect already invoked");

   721         }

   722         }

   722     }

   723     }

   723 

   724 

   724     public DatagramChannel connect(SocketAddress sa) throws IOException {

   726     public DatagramChannel connect(SocketAddress sa) throws IOException {

   725         int localPort = 0;

   727         int localPort = 0;

   726 

   728 

   727         synchronized(readLock) {

   729         synchronized(readLock) {

   728             synchronized(writeLock) {

   730             synchronized(writeLock) {

   740                     if (n <= 0)

   742                     if (n <= 0)

   741                         throw new Error();      // Can't happen

   743                         throw new Error();      // Can't happen

   742 

   744 

   743                     // Connection succeeded; disallow further invocation

   745                     // Connection succeeded; disallow further invocation

   744                     state = ST_CONNECTED;

   746                     state = ST_CONNECTED;

   746                     sender = isa;

   748                     sender = isa;

   747                     cachedSenderInetAddress = isa.getAddress();

   749                     cachedSenderInetAddress = isa.getAddress();

   748                     cachedSenderPort = isa.getPort();

   750                     cachedSenderPort = isa.getPort();

   749 

   751 

   750                     // set or refresh local address

   752                     // set or refresh local address

   759         synchronized(readLock) {

   761         synchronized(readLock) {

   760             synchronized(writeLock) {

   762             synchronized(writeLock) {

   761                 synchronized (stateLock) {

   763                 synchronized (stateLock) {

   762                     if (!isConnected() || !isOpen())

   764                     if (!isConnected() || !isOpen())

   763                         return this;

   765                         return this;

   765                     SecurityManager sm = System.getSecurityManager();

   767                     SecurityManager sm = System.getSecurityManager();

   766                     if (sm != null)

   768                     if (sm != null)

   767                         sm.checkConnect(isa.getAddress().getHostAddress(),

   769                         sm.checkConnect(isa.getAddress().getHostAddress(),

   768                                         isa.getPort());

   770                                         isa.getPort());

   769                     boolean isIPv6 = (family == StandardProtocolFamily.INET6);

   771                     boolean isIPv6 = (family == StandardProtocolFamily.INET6);