< prev index next >

src/jdk.sctp/unix/classes/sun/nio/ch/sctp/SctpChannelImpl.java

Print this page

        

*** 157,167 **** throws IOException { super(provider); this.fd = fd; this.fdVal = IOUtil.fdVal(fd); this.state = ChannelState.CONNECTED; ! port = (Net.localAddress(fd)).getPort(); if (association != null) { /* branched */ this.association = association; } else { /* obtained from server channel */ /* Receive COMM_UP */ --- 157,167 ---- throws IOException { super(provider); this.fd = fd; this.fdVal = IOUtil.fdVal(fd); this.state = ChannelState.CONNECTED; ! port = Net.localAddress(fd).getPort(); if (association != null) { /* branched */ this.association = association; } else { /* obtained from server channel */ /* Receive COMM_UP */
*** 398,409 **** if (n > 0) { synchronized (stateLock) { /* Connection succeeded */ state = ChannelState.CONNECTED; if (!isBound()) { ! InetSocketAddress boundIsa = ! Net.localAddress(fd); port = boundIsa.getPort(); } /* Receive COMM_UP */ ByteBuffer buf = Util.getTemporaryDirectBuffer(50); --- 398,408 ---- if (n > 0) { synchronized (stateLock) { /* Connection succeeded */ state = ChannelState.CONNECTED; if (!isBound()) { ! InetSocketAddress boundIsa = Net.localAddress(fd); port = boundIsa.getPort(); } /* Receive COMM_UP */ ByteBuffer buf = Util.getTemporaryDirectBuffer(50);
*** 505,516 **** if (connected) { synchronized (stateLock) { state = ChannelState.CONNECTED; if (!isBound()) { ! InetSocketAddress boundIsa = ! Net.localAddress(fd); port = boundIsa.getPort(); } /* Receive COMM_UP */ ByteBuffer buf = Util.getTemporaryDirectBuffer(50); --- 504,514 ---- if (connected) { synchronized (stateLock) { state = ChannelState.CONNECTED; if (!isBound()) { ! InetSocketAddress boundIsa = Net.localAddress(fd); port = boundIsa.getPort(); } /* Receive COMM_UP */ ByteBuffer buf = Util.getTemporaryDirectBuffer(50);
< prev index next >