< 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 >