andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge pull request #21 from normanmaurer/localaddress_fix

Browse Source 
Correctly obtain localAddress after connect was complete
This commit is contained in:
Josef Grieb 2020-09-02 10:28:31 +02:00 committed by GitHub
commit 44f2cba67a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
transport-native-io_uring/src/main/java/io/netty/channel/uring/AbstractIOUringChannel.java
View File

@ -371,6 +371,9 @@ abstract class AbstractIOUringChannel extends AbstractChannel implements UnixCha
}
active = true;
if (local == null) {
local = socket.localAddress();
}
computeRemote();
// Register POLLRDHUP

10
transport-native-io_uring/src/test/java/io/netty/channel/uring/IOUringSocketConnectTest.java
View File

@ -19,8 +19,6 @@ import io.netty.bootstrap.Bootstrap;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.testsuite.transport.TestsuitePermutation;
import io.netty.testsuite.transport.socket.SocketConnectTest;
import org.junit.Ignore;
import org.junit.Test;
import java.util.List;
@ -29,12 +27,4 @@ public class IOUringSocketConnectTest extends SocketConnectTest {
protected List<TestsuitePermutation.BootstrapComboFactory<ServerBootstrap, Bootstrap>> newFactories() {
return IOUringSocketTestPermutation.INSTANCE.socket();
}
@Ignore
@Test
@Override
public void testLocalAddressAfterConnect() throws Throwable {
super.testLocalAddressAfterConnect();
}
}