Code Review
/
openflowplugin.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Change getIsOnlineFuture() return type
[openflowplugin.git]
/
openflowjava
/
openflow-protocol-impl
/
src
/
main
/
java
/
org
/
opendaylight
/
openflowjava
/
protocol
/
impl
/
core
/
TcpConnectionInitializer.java
diff --git
a/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/TcpConnectionInitializer.java
b/openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/TcpConnectionInitializer.java
index 869f92d62d40831b33f794c7941b405ae3edb28e..35495408890cfd2c0d64a1dfa1f549811b588bb3 100644
(file)
--- a/
openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/TcpConnectionInitializer.java
+++ b/
openflowjava/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/TcpConnectionInitializer.java
@@
-24,12
+24,11
@@
import org.slf4j.LoggerFactory;
* @author martin.uhlir
*/
public class TcpConnectionInitializer implements ServerFacade, ConnectionInitializer {
* @author martin.uhlir
*/
public class TcpConnectionInitializer implements ServerFacade, ConnectionInitializer {
-
private static final Logger LOG = LoggerFactory.getLogger(TcpConnectionInitializer.class);
private static final Logger LOG = LoggerFactory.getLogger(TcpConnectionInitializer.class);
+ private final SettableFuture<Void> hasRun = SettableFuture.create();
private final EventLoopGroup workerGroup;
private final boolean isEpollEnabled;
private final EventLoopGroup workerGroup;
private final boolean isEpollEnabled;
- private final SettableFuture<Boolean> hasRun = SettableFuture.create();
private TcpChannelInitializer channelInitializer;
private Bootstrap bootstrap;
private TcpChannelInitializer channelInitializer;
private Bootstrap bootstrap;
@@
-52,18
+51,18
@@
public class TcpConnectionInitializer implements ServerFacade, ConnectionInitial
} else {
bootstrap.group(workerGroup).channel(NioSocketChannel.class).handler(channelInitializer);
}
} else {
bootstrap.group(workerGroup).channel(NioSocketChannel.class).handler(channelInitializer);
}
- hasRun.set(
true
);
+ hasRun.set(
null
);
}
@Override
public ListenableFuture<Boolean> shutdown() {
}
@Override
public ListenableFuture<Boolean> shutdown() {
- final
SettableFuture<Boolean> result = SettableFuture.
create();
+ final
var result = SettableFuture.<Boolean>
create();
workerGroup.shutdownGracefully();
return result;
}
@Override
workerGroup.shutdownGracefully();
return result;
}
@Override
- public ListenableFuture<
Boolean
> getIsOnlineFuture() {
+ public ListenableFuture<
Void
> getIsOnlineFuture() {
return hasRun;
}
return hasRun;
}