MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

test — auto expressions: filter out expression contained unresolved local variable

Browse Source
This commit is contained in:
Vladimir Krivosheev
2014-06-04 16:33:16 +02:00
parent 3677585e9b
commit 1881ceb85b
2 changed files with 31 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-impl/src/org/jetbrains/io/BuiltInServer.java
+3 -1
View File
@@ -63,7 +63,9 @@ public class BuiltInServer implements Disposable {
return port;
}
static ServerBootstrap createServerBootstrap(EventLoopGroup eventLoopGroup, final ChannelRegistrar channelRegistrar, @Nullable Map<String, Object> xmlRpcHandlers) {
static ServerBootstrap createServerBootstrap(@NotNull EventLoopGroup eventLoopGroup,
@NotNull final ChannelRegistrar channelRegistrar,
@Nullable Map<String, Object> xmlRpcHandlers) {
ServerBootstrap bootstrap = NettyUtil.nioServerBootstrap(eventLoopGroup);
if (xmlRpcHandlers == null) {
final PortUnificationServerHandler portUnificationServerHandler = new PortUnificationServerHandler();
platform/platform-impl/src/org/jetbrains/io/NettyUtil.java
+28 -3
View File
@@ -22,6 +22,7 @@ import io.netty.bootstrap.Bootstrap;
import io.netty.bootstrap.BootstrapUtil;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoop;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.oio.OioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
@@ -67,9 +68,29 @@ public final class NettyUtil {
}
@Nullable
public static Channel connect(Bootstrap bootstrap, InetSocketAddress remoteAddress, ActionCallback asyncResult, int maxAttemptCount) {
public static Channel connect(@NotNull Bootstrap bootstrap, @NotNull InetSocketAddress remoteAddress, @NotNull ActionCallback asyncResult, int maxAttemptCount) {
try {
int attemptCount = 0;
if (bootstrap.group() instanceof NioEventLoop) {
while (true) {
ChannelFuture future = bootstrap.connect(remoteAddress).awaitUninterruptibly();
if (future.isSuccess()) {
return future.channel();
}
else if (++attemptCount < maxAttemptCount) {
//noinspection BusyWait
Thread.sleep(attemptCount * MIN_START_TIME);
}
else {
@SuppressWarnings("ThrowableResultOfMethodCallIgnored")
Throwable cause = future.cause();
asyncResult.reject("Cannot connect: " + (cause == null ? "unknown error" : cause.getMessage()));
return null;
}
}
}
Socket socket;
while (true) {
try {
@@ -123,7 +144,7 @@ public final class NettyUtil {
}
}
public static ServerBootstrap nioServerBootstrap(EventLoopGroup eventLoopGroup) {
public static ServerBootstrap nioServerBootstrap(@NotNull EventLoopGroup eventLoopGroup) {
ServerBootstrap bootstrap = new ServerBootstrap().group(eventLoopGroup).channel(NioServerSocketChannel.class);
bootstrap.childOption(ChannelOption.TCP_NODELAY, true).childOption(ChannelOption.SO_KEEPALIVE, true);
return bootstrap;
@@ -137,7 +158,11 @@ public final class NettyUtil {
@SuppressWarnings("UnusedDeclaration")
public static Bootstrap nioClientBootstrap() {
Bootstrap bootstrap = new Bootstrap().group(new NioEventLoopGroup(1, PooledThreadExecutor.INSTANCE)).channel(NioSocketChannel.class);
return nioClientBootstrap(new NioEventLoopGroup(1, PooledThreadExecutor.INSTANCE));
}
public static Bootstrap nioClientBootstrap(@NotNull EventLoopGroup eventLoopGroup) {
Bootstrap bootstrap = new Bootstrap().group(eventLoopGroup).channel(NioSocketChannel.class);
bootstrap.option(ChannelOption.TCP_NODELAY, true).option(ChannelOption.SO_KEEPALIVE, true);
return bootstrap;
}